ServiceDescriptor.ts
157 lines
| 4.4 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r49 | import { ActivationContext } from "./ActivationContext"; | ||
|
cin
|
r129 | import { Descriptor, ServiceMap, PartialServiceMap, ActivationType, ILifetimeManager } from "./interfaces"; | ||
|
cin
|
r118 | import { argumentNotNull, isPrimitive, keys, isNull } from "../safe"; | ||
|
cin
|
r49 | import { TraceSource } from "../log/TraceSource"; | ||
|
cin
|
r118 | import { isDescriptor } from "./traits"; | ||
|
cin
|
r129 | import { LifetimeManager } from "./LifetimeManager"; | ||
| import { MatchingMemberKeys } from "../interfaces"; | ||||
|
cin
|
r49 | |||
| let cacheId = 0; | ||||
| const trace = TraceSource.get("@implab/core/di/ActivationContext"); | ||||
|
cin
|
r120 | function injectMethod<T, M extends keyof T, S extends object, A>(target: T, method: M, context: ActivationContext<S>, args: A) { | ||
|
cin
|
r115 | |||
|
cin
|
r49 | const m = target[method]; | ||
|
cin
|
r115 | if (!m || typeof m !== "function") | ||
|
cin
|
r49 | throw new Error("Method '" + method + "' not found"); | ||
| if (args instanceof Array) | ||||
|
cin
|
r65 | return m.apply(target, _parse(args, context, "." + method)); | ||
|
cin
|
r49 | else | ||
|
cin
|
r65 | return m.call(target, _parse(args, context, "." + method)); | ||
|
cin
|
r49 | } | ||
|
cin
|
r130 | function makeCleanupCallback<T>(method: Cleaner<T>) { | ||
|
cin
|
r129 | if (typeof (method) === "function") { | ||
| return (target: T) => { | ||||
| method(target); | ||||
|
cin
|
r49 | }; | ||
| } else { | ||||
|
cin
|
r129 | return (target: T) => { | ||
|
cin
|
r130 | const m = target[method] as any; | ||
| m.apply(target); | ||||
|
cin
|
r49 | }; | ||
| } | ||||
| } | ||||
|
cin
|
r118 | function _parse(value: any, context: ActivationContext<any>, path: string): any { | ||
|
cin
|
r49 | if (isPrimitive(value)) | ||
|
cin
|
r115 | return value as any; | ||
|
cin
|
r49 | |||
| trace.debug("parse {0}", path); | ||||
| if (isDescriptor(value)) | ||||
| return context.activate(value, path); | ||||
| if (value instanceof Array) | ||||
|
cin
|
r115 | return value.map((x, i) => _parse(x, context, `${path}[${i}]`)) as any; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | const t: any = {}; | ||
| keys(value).forEach(p => t[p] = _parse(value[p], context, `${path}.${p}`)); | ||||
|
cin
|
r49 | |||
| return t; | ||||
| } | ||||
|
cin
|
r129 | export type Cleaner<T> = ((x: T) => void) | MatchingMemberKeys<() => void, T>; | ||
|
cin
|
r115 | |||
| export type InjectionSpec<T> = { | ||||
| [m in keyof T]?: any; | ||||
| }; | ||||
|
cin
|
r120 | export interface ServiceDescriptorParams<S extends object, T, P extends any[]> { | ||
|
cin
|
r129 | lifetime: ILifetimeManager; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | params?: P; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | inject?: InjectionSpec<T>[]; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | services?: PartialServiceMap<S>; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | cleanup?: Cleaner<T>; | ||
|
cin
|
r49 | } | ||
|
cin
|
r120 | export class ServiceDescriptor<S extends object, T, P extends any[]> implements Descriptor<S, T> { | ||
|
cin
|
r115 | _services: ServiceMap<S>; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | _params: P | undefined; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | _inject: InjectionSpec<T>[]; | ||
|
cin
|
r49 | |||
|
cin
|
r129 | _cleanup: ((item: T) => void) | undefined; | ||
|
cin
|
r49 | |||
|
cin
|
r129 | _cacheId = String(++cacheId); | ||
|
cin
|
r49 | |||
|
cin
|
r129 | _lifetime = LifetimeManager.empty; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | constructor(opts: ServiceDescriptorParams<S, T, P>) { | ||
|
cin
|
r49 | argumentNotNull(opts, "opts"); | ||
|
cin
|
r129 | if (opts.lifetime) | ||
| this._lifetime = opts.lifetime; | ||||
|
cin
|
r49 | |||
|
cin
|
r115 | if (!isNull(opts.params)) | ||
|
cin
|
r49 | this._params = opts.params; | ||
|
cin
|
r115 | this._inject = opts.inject || []; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | this._services = (opts.services || {}) as ServiceMap<S>; | ||
|
cin
|
r49 | |||
| if (opts.cleanup) { | ||||
| if (!(typeof (opts.cleanup) === "string" || opts.cleanup instanceof Function)) | ||||
| throw new Error( | ||||
| "The cleanup parameter must be either a function or a function name"); | ||||
|
cin
|
r130 | this._cleanup = makeCleanupCallback(opts.cleanup); | ||
|
cin
|
r49 | } | ||
| } | ||||
|
cin
|
r115 | activate(context: ActivationContext<S>) { | ||
|
cin
|
r129 | const lifetime = this._lifetime.initialize(this._cacheId, context); | ||
|
cin
|
r49 | |||
|
cin
|
r129 | if (lifetime.has()) { | ||
| return lifetime.get(); | ||||
| } else { | ||||
|
cin
|
r130 | lifetime.enter(); | ||
|
cin
|
r129 | const instance = this._create(context); | ||
| lifetime.store(this._cacheId, this._cleanup); | ||||
| return instance; | ||||
|
cin
|
r49 | } | ||
| } | ||||
|
cin
|
r115 | _factory(...params: any[]): T { | ||
|
cin
|
r49 | throw Error("Not implemented"); | ||
| } | ||||
|
cin
|
r115 | _create(context: ActivationContext<S>) { | ||
|
cin
|
r49 | trace.debug(`constructing ${context._name}`); | ||
| if (this._services) { | ||||
|
cin
|
r115 | keys(this._services).forEach(p => context.register(p, this._services[p])); | ||
|
cin
|
r49 | } | ||
|
cin
|
r115 | let instance: T; | ||
|
cin
|
r49 | |||
| if (this._params === undefined) { | ||||
| instance = this._factory(); | ||||
| } else if (this._params instanceof Array) { | ||||
| instance = this._factory.apply(this, _parse(this._params, context, "args")); | ||||
| } else { | ||||
| instance = this._factory(_parse(this._params, context, "args")); | ||||
| } | ||||
| if (this._inject) { | ||||
| this._inject.forEach(spec => { | ||||
| for (const m in spec) | ||||
| injectMethod(instance, m, context, spec[m]); | ||||
| }); | ||||
| } | ||||
| return instance; | ||||
| } | ||||
|
cin
|
r129 | |||
| clone() { | ||||
| return Object.create(this); | ||||
| } | ||||
|
cin
|
r49 | } | ||