import { ActivationContext } from "./ActivationContext"; import { ValueDescriptor } from "./ValueDescriptor"; import { ActivationError } from "./ActivationError"; import { ServiceMap, Descriptor, PartialServiceMap, ContainerProvided, ServiceLocator, ContainerServiceMap, ContainerKeys, TypeOfService, ILifetimeManager } from "./interfaces"; import { TraceSource } from "../log/TraceSource"; import { Configuration, RegistrationMap } from "./Configuration"; import { Cancellation } from "../Cancellation"; import { MapOf, IDestroyable } from "../interfaces"; import { isDescriptor } from "./traits"; import { LifetimeManager } from "./LifetimeManager"; import { each } from "../safe"; const trace = TraceSource.get("@implab/core/di/ActivationContext"); export class Container implements ServiceLocator, IDestroyable { readonly _services: ContainerServiceMap; readonly _lifetimeManager: ILifetimeManager; readonly _cleanup: (() => void)[]; readonly _root: Container; readonly _parent?: Container; _disposed: boolean; constructor(parent?: Container) { this._parent = parent; this._services = parent ? Object.create(parent._services) : {}; this._cleanup = []; this._root = parent ? parent.getRootContainer() : this; this._services.container = new ValueDescriptor(this) as any; this._disposed = false; this._lifetimeManager = new LifetimeManager(); } getRootContainer() { return this._root; } getParent() { return this._parent; } getLifetimeManager() { return this._lifetimeManager; } resolve>(name: K, def?: TypeOfService): TypeOfService { trace.debug("resolve {0}", name); const d = this._services[name]; if (d === undefined) { if (def !== undefined) return def; else throw new Error("Service '" + name + "' isn't found"); } else { const context = new ActivationContext(this, this._services, String(name), d); try { return d.activate(context); } catch (error) { throw new ActivationError(name.toString(), context.getStack(), error); } } } /** * @deprecated use resolve() method */ getService>(name: K, def?: TypeOfService) { return this.resolve(name, def); } register(name: K, service: Descriptor): this; register(services: PartialServiceMap): this; register(nameOrCollection: K | ServiceMap, service?: Descriptor) { if (arguments.length === 1) { const data = nameOrCollection as ServiceMap; each(data, (v, k) => this.register(k, v)); } else { if (!isDescriptor(service)) throw new Error("The service parameter must be a descriptor"); this._services[nameOrCollection as K] = service as any; } return this; } onDispose(callback: () => void) { if (!(callback instanceof Function)) throw new Error("The callback must be a function"); this._cleanup.push(callback); } destroy() { return this.dispose(); } dispose() { if (this._disposed) return; this._disposed = true; for (const f of this._cleanup) f(); } /** * @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. * * @param{Function} opts.contextRequire * The function which will be used to load a configuration or types for services. * */ async configure(config: string | RegistrationMap, opts?: any, ct = Cancellation.none) { const c = new Configuration(this); if (typeof (config) === "string") { return c.loadConfiguration(config, opts && opts.contextRequire, ct); } else { return c.applyConfiguration(config, opts && opts.contextRequire, ct); } } createChildContainer(): Container { return new Container(this as any); } }