ActivationContext.ts
170 lines
| 5.1 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r49 | import { TraceSource } from "../log/TraceSource"; | ||
|
cin
|
r133 | import { argumentNotEmptyString } from "../safe"; | ||
|
cin
|
r134 | import { Descriptor, ContainerServiceMap, ContainerKeys, TypeOfService, ILifetime } from "./interfaces"; | ||
|
cin
|
r49 | import { Container } from "./Container"; | ||
|
cin
|
r114 | import { MapOf } from "../interfaces"; | ||
|
cin
|
r49 | |||
| const trace = TraceSource.get("@implab/core/di/ActivationContext"); | ||||
|
cin
|
r131 | export interface ActivationContextInfo { | ||
|
cin
|
r49 | name: string; | ||
| service: string; | ||||
| } | ||||
|
cin
|
r134 | let nextId = 1; | ||
|
cin
|
r135 | /** This class is created once per `Container.resolve` method call and used to | ||
| * cache dependencies and to track created instances. The activation context | ||||
| * tracks services with `context` activation type. | ||||
| */ | ||||
|
cin
|
r120 | export class ActivationContext<S extends object> { | ||
|
cin
|
r114 | _cache: MapOf<any>; | ||
|
cin
|
r49 | |||
|
cin
|
r120 | _services: ContainerServiceMap<S>; | ||
|
cin
|
r49 | |||
|
cin
|
r114 | _visited: MapOf<any>; | ||
|
cin
|
r49 | |||
| _name: string; | ||||
|
cin
|
r131 | _service: Descriptor<S, any>; | ||
|
cin
|
r49 | |||
|
cin
|
r131 | _container: Container<S>; | ||
| _parent: ActivationContext<S> | undefined; | ||||
|
cin
|
r49 | |||
|
cin
|
r135 | /** Creates a new activation context with the specified parameters. | ||
| * @param container the container which starts the activation process | ||||
| * @param services the initial service registrations | ||||
| * @param name the name of the service being activated, this parameter is | ||||
| * used for the debug purpose. | ||||
| * @param service the service to activate, this parameter is used for the | ||||
| * debug purpose. | ||||
| */ | ||||
|
cin
|
r131 | constructor(container: Container<S>, services: ContainerServiceMap<S>, name: string, service: Descriptor<S, any>) { | ||
| this._name = name; | ||||
| this._service = service; | ||||
| this._visited = {}; | ||||
| this._cache = {}; | ||||
|
cin
|
r49 | this._services = services; | ||
|
cin
|
r131 | this._container = container; | ||
|
cin
|
r49 | } | ||
|
cin
|
r135 | /** the name of the current resolving dependency */ | ||
|
cin
|
r49 | getName() { | ||
| return this._name; | ||||
| } | ||||
|
cin
|
r135 | /** Returns the container for which 'resolve' method was called */ | ||
|
cin
|
r131 | getContainer() { | ||
| return this._container; | ||||
| } | ||||
|
cin
|
r135 | /** Resolves the specified dependency in the current context | ||
| * @param name The name of the dependency being resolved | ||||
| */ | ||||
|
cin
|
r133 | resolve<K extends ContainerKeys<S>>(name: K): TypeOfService<S, K>; | ||
|
cin
|
r135 | /** Resolves the specified dependency with the specified default value if | ||
| * the dependency is missing. | ||||
| * | ||||
| * @param name The name of the dependency being resolved | ||||
| * @param def A default value to return in case of the specified dependency | ||||
| * is missing. | ||||
| */ | ||||
|
cin
|
r133 | resolve<K extends ContainerKeys<S>, T>(name: K, def: T): TypeOfService<S, K> | T; | ||
|
cin
|
r135 | /** Resolves the specified dependency and returns undefined in case if the | ||
| * dependency is missing. | ||||
| * | ||||
| * @param name The name of the dependency being resolved | ||||
| */ | ||||
|
cin
|
r133 | resolve<K extends ContainerKeys<S>>(name: K, def: undefined): TypeOfService<S, K> | undefined; | ||
| resolve<K extends ContainerKeys<S>, T>(name: K, def?: T): TypeOfService<S, K> | T | undefined { | ||||
|
cin
|
r49 | const d = this._services[name]; | ||
|
cin
|
r114 | if (d !== undefined) { | ||
|
cin
|
r120 | return this.activate(d, name.toString()); | ||
|
cin
|
r114 | } else { | ||
|
cin
|
r133 | if (arguments.length > 1) | ||
|
cin
|
r49 | return def; | ||
| else | ||||
| throw new Error(`Service ${name} not found`); | ||||
|
cin
|
r114 | } | ||
|
cin
|
r49 | } | ||
| /** | ||||
| * registers services local to the the activation context | ||||
| * | ||||
| * @name{string} the name of the service | ||||
| * @service{string} the service descriptor to register | ||||
| */ | ||||
|
cin
|
r115 | register<K extends keyof S>(name: K, service: Descriptor<S, S[K]>) { | ||
|
cin
|
r49 | argumentNotEmptyString(name, "name"); | ||
|
cin
|
r120 | this._services[name] = service as any; | ||
|
cin
|
r49 | } | ||
|
cin
|
r134 | createLifetime(): ILifetime { | ||
| const id = nextId++; | ||||
| const me = this; | ||||
| return { | ||||
| initialize() { | ||||
| }, | ||||
| has() { | ||||
| return id in me._cache; | ||||
| }, | ||||
| get() { | ||||
| return me._cache[id]; | ||||
| }, | ||||
| store(item: any) { | ||||
| me._cache[id] = item; | ||||
| } | ||||
| }; | ||||
|
cin
|
r49 | } | ||
|
cin
|
r135 | |||
|
cin
|
r115 | activate<T>(d: Descriptor<S, T>, name: string) { | ||
|
cin
|
r49 | if (trace.isLogEnabled()) | ||
| trace.log(`enter ${name} ${d}`); | ||||
|
cin
|
r131 | const ctx = this.enter(d, name); | ||
| const v = d.activate(ctx); | ||||
|
cin
|
r49 | |||
| if (trace.isLogEnabled()) | ||||
| trace.log(`leave ${name}`); | ||||
| return v; | ||||
| } | ||||
| visit(id: string) { | ||||
| const count = this._visited[id] || 0; | ||||
| this._visited[id] = count + 1; | ||||
| return count; | ||||
| } | ||||
|
cin
|
r131 | getStack(): ActivationContextInfo[] { | ||
| const stack = [{ | ||||
| name: this._name, | ||||
| service: this._service.toString() | ||||
| }]; | ||||
| return this._parent ? | ||||
| stack.concat(this._parent.getStack()) : | ||||
| stack; | ||||
|
cin
|
r49 | } | ||
|
cin
|
r131 | private enter(service: Descriptor<S, any>, name: string): this { | ||
| const clone = Object.create(this); | ||||
| clone._name = name; | ||||
| clone._services = Object.create(this._services); | ||||
| clone._parent = this; | ||||
| clone._service = service; | ||||
| return clone; | ||||
|
cin
|
r49 | } | ||
|
cin
|
r132 | |||
| /** Creates a clone for the current context, used to protect it from modifications */ | ||||
| clone(): this { | ||||
| const clone = Object.create(this); | ||||
| clone._services = Object.create(this._services); | ||||
| return clone; | ||||
| } | ||||
|
cin
|
r49 | } | ||