ActivationContext.ts
145 lines
| 4.5 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r11 | import { ActivationError } from "./ActivationError"; | ||
|
cin
|
r9 | import { Descriptor, ILifetime, IActivationContext, DescriptorMap, ILifetimeManager } from "./interfaces"; | ||
|
cin
|
r11 | import { argumentNotNull, prototype } from "./traits"; | ||
|
cin
|
r0 | |||
| export interface ActivationContextInfo { | ||||
| name: string; | ||||
| service: string; | ||||
| } | ||||
| let nextId = 1; | ||||
|
cin
|
r9 | /** This object is created once per `Container.resolve` method call and used to | ||
|
cin
|
r0 | * cache dependencies and to track created instances. The activation context | ||
| * tracks services with `context` activation type. | ||||
|
cin
|
r9 | * | ||
| * @template S The service map used in the activation context, services from | ||||
| * this map are available to resolution. | ||||
| * @template U A set of keys from the service map which can be overridden in | ||||
| * this activation context. | ||||
|
cin
|
r0 | */ | ||
|
cin
|
r9 | export class ActivationContext<S> implements IActivationContext<S> { | ||
|
cin
|
r3 | private readonly _cache: Record<string, unknown>; | ||
|
cin
|
r0 | |||
|
cin
|
r9 | private readonly _services: DescriptorMap<S>; | ||
|
cin
|
r0 | |||
|
cin
|
r3 | private readonly _name: string; | ||
|
cin
|
r0 | |||
|
cin
|
r3 | private readonly _service: Descriptor<S, unknown>; | ||
|
cin
|
r0 | |||
|
cin
|
r9 | private readonly _containerLifetimeManager: ILifetimeManager; | ||
|
cin
|
r0 | |||
|
cin
|
r3 | private readonly _parent: ActivationContext<S> | undefined; | ||
|
cin
|
r0 | |||
| /** Creates a new activation context with the specified parameters. | ||||
|
cin
|
r1 | * @param containerLifetimeManager the container which starts the activation process | ||
|
cin
|
r0 | * @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
|
r9 | constructor(containerLifetimeManager: ILifetimeManager, services: DescriptorMap<S>, name: string, service: Descriptor<S, unknown>, cache = {}) { | ||
|
cin
|
r0 | this._name = name; | ||
| this._service = service; | ||||
|
cin
|
r3 | this._cache = cache; | ||
|
cin
|
r0 | this._services = services; | ||
|
cin
|
r1 | this._containerLifetimeManager = containerLifetimeManager; | ||
|
cin
|
r0 | } | ||
| /** the name of the current resolving dependency */ | ||||
| getName() { | ||||
| return this._name; | ||||
| } | ||||
|
cin
|
r1 | createContainerLifetime<T>() { | ||
|
cin
|
r5 | return this._containerLifetimeManager.create<T>(); | ||
|
cin
|
r0 | } | ||
|
cin
|
r1 | resolve<K extends keyof S>(name: K): NonNullable<S[K]>; | ||
| resolve<K extends keyof S, T>(name: K, def: T): NonNullable<S[K]> | T; | ||||
|
cin
|
r9 | resolve<K extends keyof S, T>(name: K, def?: T): NonNullable<S[K]> | T | undefined { | ||
|
cin
|
r0 | const d = this._services[name]; | ||
| if (d !== undefined) { | ||||
| return this.activate(d, name.toString()); | ||||
| } else { | ||||
| if (arguments.length > 1) | ||||
| return def; | ||||
| else | ||||
|
cin
|
r1 | throw new Error(`Service ${String(name)} not found`); | ||
|
cin
|
r0 | } | ||
| } | ||||
| /** | ||||
| * registers services local to the the activation context | ||||
| * | ||||
| * @name{string} the name of the service | ||||
| * @service{string} the service descriptor to register | ||||
| */ | ||||
|
cin
|
r9 | register<K extends keyof S>(name: K, service: DescriptorMap<S>[K]) { | ||
|
cin
|
r1 | argumentNotNull(name, "name"); | ||
|
cin
|
r0 | |||
|
cin
|
r9 | const d = this._services[name]; | ||
| if (d !== undefined && !d.configurable) | ||||
| throw new Error(`Service ${String(name)} can't be overridden`); | ||||
|
cin
|
r1 | this._services[name] = service; | ||
|
cin
|
r0 | } | ||
|
cin
|
r1 | createLifetime<T>(): ILifetime<T> { | ||
|
cin
|
r0 | const id = nextId++; | ||
| return { | ||||
|
cin
|
r9 | initialize() { }, | ||
|
cin
|
r1 | has: () => id in this._cache, | ||
|
cin
|
r9 | get: () => { | ||
| const v = this._cache[id] as T; | ||||
| if (v === undefined || v === null) | ||||
| throw new Error("The value isn't present in the activation context"); | ||||
| return v; | ||||
| }, | ||||
|
cin
|
r1 | store: item => { | ||
| this._cache[id] = item; | ||||
|
cin
|
r0 | } | ||
| }; | ||||
| } | ||||
| activate<T>(d: Descriptor<S, T>, name: string) { | ||||
|
cin
|
r1 | // TODO: add logging | ||
| // if (trace.isLogEnabled()) | ||||
| // trace.log("enter {0} {1}", name, d); | ||||
|
cin
|
r0 | |||
|
cin
|
r11 | const ctx = new ActivationContext( | ||
| this._containerLifetimeManager, | ||||
| d.hasOverrides ? prototype(this._services) : this._services, | ||||
| name, | ||||
| d, | ||||
| this._cache | ||||
| ); | ||||
|
cin
|
r0 | const v = d.activate(ctx); | ||
|
cin
|
r1 | // if (trace.isLogEnabled()) | ||
| // trace.log(`leave ${name}`); | ||||
|
cin
|
r0 | |||
| return v; | ||||
| } | ||||
| getStack(): ActivationContextInfo[] { | ||||
| const stack = [{ | ||||
| name: this._name, | ||||
| service: this._service.toString() | ||||
| }]; | ||||
| return this._parent ? | ||||
| stack.concat(this._parent.getStack()) : | ||||
| stack; | ||||
| } | ||||
|
cin
|
r11 | fail(innerException: unknown): never { | ||
| throw new ActivationError(this._name, this.getStack(), innerException); | ||||
|
cin
|
r0 | } | ||
|
cin
|
r11 | |||
|
cin
|
r0 | } | ||