LifetimeManager.ts
97 lines
| 2.9 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r15 | import { ILifetime, ILifetimeContext, ILifetimeManager, ILifetimeSlot } from "../typings/interfaces"; | ||
| import { LifetimeSlot } from "./LifetimeSlot"; | ||||
| import { argumentNotNull } from "./traits"; | ||||
|
cin
|
r0 | |||
|
cin
|
r12 | const noop = () => { }; | ||
|
cin
|
r11 | |||
|
cin
|
r12 | const fail = (message: string) => (): never => { | ||
|
cin
|
r11 | throw new Error(message); | ||
| }; | ||||
|
cin
|
r10 | const _emptySlot = Object.freeze({ | ||
| has: () => false, | ||||
|
cin
|
r0 | |||
|
cin
|
r15 | initialize: () => false, | ||
|
cin
|
r11 | |||
| get: fail("The specified item isn't registered with a lifetime manager"), | ||||
|
cin
|
r0 | |||
|
cin
|
r11 | store: noop, | ||
|
cin
|
r0 | |||
|
cin
|
r12 | remove: noop, | ||
|
cin
|
r10 | |||
|
cin
|
r12 | cleanup: noop, | ||
|
cin
|
r0 | }); | ||
|
cin
|
r9 | export class LifetimeManager implements ILifetimeManager { | ||
|
cin
|
r0 | private _destroyed = false; | ||
|
cin
|
r10 | private readonly _slots: Record<string, ILifetimeSlot<unknown>> = {}; | ||
|
cin
|
r1 | |||
|
cin
|
r15 | slot<T>(slotId: string | number): ILifetimeSlot<T> { | ||
|
cin
|
r10 | if (this._destroyed) | ||
| throw new Error("The lifetime manager is destroyed"); | ||||
|
cin
|
r15 | if (slotId in this._slots) | ||
| return this._slots[slotId] as ILifetimeSlot<T>; | ||||
| return this._slots[slotId] = new LifetimeSlot<T>(() => delete this._slots[slotId]); | ||||
|
cin
|
r10 | } | ||
|
cin
|
r15 | |||
|
cin
|
r0 | destroy() { | ||
| if (!this._destroyed) { | ||||
| this._destroyed = true; | ||||
|
cin
|
r15 | Object.values(this._slots).forEach(slot => { | ||
| try { | ||||
| slot.cleanup(); | ||||
| } catch { | ||||
| // ignore | ||||
| } | ||||
| }); | ||||
|
cin
|
r0 | } | ||
| } | ||||
|
cin
|
r9 | } | ||
|
cin
|
r15 | export const emptySlot = <T>() => _emptySlot as ILifetimeSlot<T>; | ||
|
cin
|
r0 | |||
|
cin
|
r15 | export const emptyLifetime = <T>() => emptySlot as ILifetime<T>; | ||
|
cin
|
r0 | |||
|
cin
|
r15 | export const scopeLifetime = <T>(level: number, slotId: string | number) => | ||
| (context: ILifetimeContext) => | ||||
| context.scopeSlot<T>(level, slotId); | ||||
|
cin
|
r13 | |||
|
cin
|
r15 | export const hierarchyLifetime = <T>(slotId: string | number) => | ||
| (context: ILifetimeContext) => | ||||
| context.hierarchySlot<T>(slotId); | ||||
|
cin
|
r0 | |||
|
cin
|
r10 | /** | ||
| * Creates a lifetime instance bound to the current activation context. This | ||||
| * lifetime will store the service instance per activation context. Every | ||||
| * top level service resolution will create a new activation context. This | ||||
| * context is propagated to subsequent service resolution thus all services | ||||
| * with context lifetime will be shared among their consumers. | ||||
| * | ||||
| * @returns The instance of the lifetime. | ||||
| */ | ||||
|
cin
|
r15 | export const contextLifetime = <T>(slotId: string | number) => | ||
| (context: ILifetimeContext) => | ||||
|
cin
|
r12 | context.contextSlot<T>(slotId); | ||
|
cin
|
r0 | |||
|
cin
|
r12 | const singletons = new LifetimeManager(); | ||
|
cin
|
r10 | /** | ||
| * Creates the lifetime for the service which will allow existence only one | ||||
| * instance with the specified {@linkcode typeId}. If there will be created | ||||
| * several lifetime instances with same `typeId` in the runtime, they will | ||||
| * share the same service instance. | ||||
| * | ||||
| * @param typeId The identified for the global instance, usually this is a | ||||
| * fully qualified class name | ||||
| * @returns The lifetime instance | ||||
| */ | ||||
|
cin
|
r12 | export const singletonLifetime = <T>(typeId: string) => { | ||
|
cin
|
r9 | argumentNotNull(typeId, "typeId"); | ||
|
cin
|
r12 | |||
| return () => singletons.slot<T>(typeId); | ||||
|
cin
|
r9 | }; | ||