Container.ts
128 lines
| 3.4 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r33 | import { ActivationContext } from "./ActivationContext"; | ||
|
cin
|
r34 | import { ValueDescriptor } from "./ValueDescriptor"; | ||
| import { ActivationError } from "./ActivationError"; | ||||
|
cin
|
r44 | import { isDescriptor, ServiceMap } from "./interfaces"; | ||
|
cin
|
r42 | import { TraceSource } from "../log/TraceSource"; | ||
|
cin
|
r44 | import { Configuration } from "./Configuration"; | ||
| import { Cancellation } from "../Cancellation"; | ||||
|
cin
|
r42 | |||
| const trace = TraceSource.get("@implab/core/di/ActivationContext"); | ||||
|
cin
|
r33 | |||
| export class Container { | ||||
|
cin
|
r38 | _services: ServiceMap; | ||
|
cin
|
r33 | |||
|
cin
|
r38 | _cache: object; | ||
| _cleanup: (() => void)[]; | ||||
|
cin
|
r33 | |||
|
cin
|
r38 | _root: Container; | ||
|
cin
|
r33 | |||
|
cin
|
r38 | _parent: Container; | ||
|
cin
|
r33 | |||
| constructor(parent?: Container) { | ||||
| this._parent = parent; | ||||
| this._services = parent ? Object.create(parent._services) : {}; | ||||
| this._cache = {}; | ||||
| this._cleanup = []; | ||||
| this._root = parent ? parent.getRootContainer() : this; | ||||
| this._services.container = new ValueDescriptor(this); | ||||
| } | ||||
| getRootContainer() { | ||||
| return this._root; | ||||
| } | ||||
| getParent() { | ||||
| return this._parent; | ||||
| } | ||||
|
cin
|
r41 | resolve(name: string, def?) { | ||
|
cin
|
r44 | trace.debug("resolve {0}", name); | ||
|
cin
|
r38 | const d = this._services[name]; | ||
|
cin
|
r41 | if (d === undefined) { | ||
|
cin
|
r33 | if (arguments.length > 1) | ||
| return def; | ||||
| else | ||||
| throw new Error("Service '" + name + "' isn't found"); | ||||
|
cin
|
r41 | } | ||
|
cin
|
r33 | |||
|
cin
|
r38 | const context = new ActivationContext(this, this._services); | ||
|
cin
|
r33 | try { | ||
|
cin
|
r41 | return context.activate(d, name); | ||
|
cin
|
r33 | } catch (error) { | ||
| throw new ActivationError(name, context.getStack(), error); | ||||
| } | ||||
| } | ||||
|
cin
|
r42 | /** | ||
| * @deprecated use resolve() method | ||||
| */ | ||||
|
cin
|
r44 | getService() { | ||
|
cin
|
r41 | return this.resolve.apply(this, arguments); | ||
| } | ||||
|
cin
|
r33 | register(nameOrCollection, service?) { | ||
|
cin
|
r38 | if (arguments.length === 1) { | ||
| const data = nameOrCollection; | ||||
| for (const name in data) | ||||
|
cin
|
r33 | this.register(name, data[name]); | ||
| } else { | ||||
|
cin
|
r41 | if (!isDescriptor(service)) | ||
| throw new Error("The service parameter must be a descriptor"); | ||||
|
cin
|
r33 | this._services[nameOrCollection] = service; | ||
| } | ||||
| return this; | ||||
| } | ||||
| onDispose(callback) { | ||||
| if (!(callback instanceof Function)) | ||||
| throw new Error("The callback must be a function"); | ||||
| this._cleanup.push(callback); | ||||
| } | ||||
| dispose() { | ||||
| if (this._cleanup) { | ||||
|
cin
|
r38 | for (const f of this._cleanup) | ||
| f(); | ||||
|
cin
|
r33 | this._cleanup = null; | ||
| } | ||||
| } | ||||
| /** | ||||
| * @param{String|Object} config | ||||
| * The configuration of the contaier. Can be either a string or an object, | ||||
| * if the configuration is an object it's treated as a collection of | ||||
| * services which will be registed in the contaier. | ||||
|
cin
|
r38 | * | ||
|
cin
|
r33 | * @param{Function} opts.contextRequire | ||
| * The function which will be used to load a configuration or types for services. | ||||
|
cin
|
r38 | * | ||
|
cin
|
r33 | */ | ||
|
cin
|
r44 | async configure(config: string | object, opts?: any, ct = Cancellation.none) { | ||
| const c = new Configuration(this); | ||||
|
cin
|
r33 | if (typeof (config) === "string") { | ||
|
cin
|
r44 | return c.loadConfiguration(config, ct); | ||
|
cin
|
r33 | } else { | ||
|
cin
|
r44 | return c.applyConfiguration(config, opts && opts.contextRequire, ct); | ||
|
cin
|
r33 | } | ||
| } | ||||
| createChildContainer() { | ||||
| return new Container(this); | ||||
| } | ||||
| has(id) { | ||||
| return id in this._cache; | ||||
| } | ||||
| get(id) { | ||||
| return this._cache[id]; | ||||
| } | ||||
| store(id, value) { | ||||
| return (this._cache[id] = value); | ||||
| } | ||||
|
cin
|
r38 | } | ||