LifetimeManager.ts
197 lines
| 5.4 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r129 | import { IDestroyable, MapOf } from "../interfaces"; | ||
|
cin
|
r144 | import { argumentNotNull, isDestroyable, argumentNotEmptyString } from "../safe"; | ||
| import { ILifetime, ServiceContainer } from "./interfaces"; | ||||
|
cin
|
r130 | import { ActivationContext } from "./ActivationContext"; | ||
|
cin
|
r129 | |||
| function safeCall(item: () => void) { | ||||
| try { | ||||
| item(); | ||||
| } catch { | ||||
|
cin
|
r131 | // silence! | ||
|
cin
|
r129 | } | ||
| } | ||||
|
cin
|
r135 | const emptyLifetime: ILifetime = Object.freeze({ | ||
|
cin
|
r131 | has() { | ||
| return false; | ||||
| }, | ||||
|
cin
|
r134 | initialize() { | ||
|
cin
|
r131 | |||
| }, | ||||
| get() { | ||||
| throw new Error("The specified item isn't registered with this lifetime manager"); | ||||
| }, | ||||
| store() { | ||||
| // does nothing | ||||
| } | ||||
|
cin
|
r135 | }); | ||
|
cin
|
r131 | |||
|
cin
|
r135 | const unknownLifetime: ILifetime = Object.freeze({ | ||
|
cin
|
r134 | has() { | ||
|
cin
|
r135 | return false; | ||
|
cin
|
r134 | }, | ||
| initialize() { | ||||
| throw new Error("Can't call initialize on the unknown lifetime object"); | ||||
| }, | ||||
| get() { | ||||
| throw new Error("The lifetime object isn't initialized"); | ||||
| }, | ||||
| store() { | ||||
| throw new Error("Can't store a value in the unknown lifetime object"); | ||||
| } | ||||
|
cin
|
r135 | }); | ||
|
cin
|
r134 | |||
|
cin
|
r133 | let nextId = 0; | ||
|
cin
|
r144 | const singletons: any = {}; | ||
|
cin
|
r135 | |||
| export class LifetimeManager implements IDestroyable { | ||||
|
cin
|
r129 | private _cleanup: (() => void)[] = []; | ||
| private _cache: MapOf<any> = {}; | ||||
| private _destroyed = false; | ||||
|
cin
|
r132 | private _pending: MapOf<boolean> = {}; | ||
|
cin
|
r134 | create(): ILifetime { | ||
|
cin
|
r130 | const self = this; | ||
|
cin
|
r133 | const id = ++nextId; | ||
|
cin
|
r130 | return { | ||
| has() { | ||||
| return (id in self._cache); | ||||
| }, | ||||
| get() { | ||||
| const t = self._cache[id]; | ||||
| if (t === undefined) | ||||
| throw new Error(`The item with with the key ${id} isn't found`); | ||||
| return t; | ||||
| }, | ||||
|
cin
|
r129 | |||
|
cin
|
r134 | initialize() { | ||
|
cin
|
r132 | if (self._pending[id]) | ||
|
cin
|
r130 | throw Error(`Cyclic reference detected: the item with the key ${id} is already activating.`); | ||
|
cin
|
r132 | self._pending[id] = true; | ||
|
cin
|
r130 | }, | ||
| store(item: any, cleanup?: (item: any) => void) { | ||||
| argumentNotNull(id, "id"); | ||||
| argumentNotNull(item, "item"); | ||||
| if (this.has()) | ||||
| throw new Error(`The item with with the key ${id} already registered with this lifetime manager`); | ||||
|
cin
|
r132 | delete self._pending[id]; | ||
|
cin
|
r130 | |||
| self._cache[id] = item; | ||||
| if (self._destroyed) | ||||
| throw new Error("Lifetime manager is destroyed"); | ||||
| if (cleanup) { | ||||
| self._cleanup.push(() => cleanup(item)); | ||||
| } else if (isDestroyable(item)) { | ||||
| self._cleanup.push(() => item.destroy()); | ||||
| } | ||||
| } | ||||
| }; | ||||
|
cin
|
r129 | } | ||
| destroy() { | ||||
| if (!this._destroyed) { | ||||
| this._destroyed = true; | ||||
| this._cleanup.forEach(safeCall); | ||||
| this._cleanup.length = 0; | ||||
| } | ||||
| } | ||||
|
cin
|
r134 | static empty(): ILifetime { | ||
| return emptyLifetime; | ||||
| } | ||||
| static hierarchyLifetime(): ILifetime { | ||||
| let _lifetime = unknownLifetime; | ||||
| return { | ||||
| initialize(context: ActivationContext<any>) { | ||||
| if (_lifetime !== unknownLifetime) | ||||
| throw new Error("Cyclic reference activation detected"); | ||||
|
cin
|
r131 | |||
|
cin
|
r135 | _lifetime = context.getContainer().getLifetimeManager().create(); | ||
|
cin
|
r134 | }, | ||
| get() { | ||||
| return _lifetime.get(); | ||||
| }, | ||||
| has() { | ||||
| return _lifetime.has(); | ||||
| }, | ||||
| store(item: any, cleanup?: (item: any) => void) { | ||||
| return _lifetime.store(item, cleanup); | ||||
| } | ||||
| }; | ||||
| } | ||||
|
cin
|
r129 | |||
|
cin
|
r134 | static contextLifetime(): ILifetime { | ||
| let _lifetime = unknownLifetime; | ||||
| return { | ||||
| initialize(context: ActivationContext<any>) { | ||||
| if (_lifetime !== unknownLifetime) | ||||
| throw new Error("Cyclic reference detected"); | ||||
| _lifetime = context.createLifetime(); | ||||
| }, | ||||
| get() { | ||||
| return _lifetime.get(); | ||||
| }, | ||||
| has() { | ||||
| return _lifetime.has(); | ||||
| }, | ||||
| store(item: any) { | ||||
| _lifetime.store(item); | ||||
| } | ||||
| }; | ||||
| } | ||||
|
cin
|
r133 | |||
|
cin
|
r134 | static singletonLifetime(typeId: string): ILifetime { | ||
|
cin
|
r135 | argumentNotEmptyString(typeId, "typeId"); | ||
| let pending = false; | ||||
| return { | ||||
| has() { | ||||
| return typeId in singletons; | ||||
| }, | ||||
| get() { | ||||
| if (!this.has()) | ||||
| throw new Error(`The instance ${typeId} doesn't exists`); | ||||
| return singletons[typeId]; | ||||
| }, | ||||
| initialize() { | ||||
| if (pending) | ||||
| throw new Error("Cyclic reference detected"); | ||||
| pending = true; | ||||
| }, | ||||
| store(item: any) { | ||||
| singletons[typeId] = item; | ||||
| pending = false; | ||||
| } | ||||
| }; | ||||
|
cin
|
r134 | } | ||
|
cin
|
r144 | static containerLifetime(container: ServiceContainer<any>) { | ||
|
cin
|
r134 | let _lifetime = unknownLifetime; | ||
|
cin
|
r133 | return { | ||
|
cin
|
r134 | initialize(context: ActivationContext<any>) { | ||
| if (_lifetime !== unknownLifetime) | ||||
| throw new Error("Cyclic reference detected"); | ||||
|
cin
|
r135 | _lifetime = container.getLifetimeManager().create(); | ||
|
cin
|
r134 | }, | ||
| get() { | ||||
| return _lifetime.get(); | ||||
| }, | ||||
| has() { | ||||
| return _lifetime.has(); | ||||
| }, | ||||
| store(item: any) { | ||||
| _lifetime.store(item); | ||||
|
cin
|
r133 | } | ||
| }; | ||||
| } | ||||
|
cin
|
r129 | } | ||