ActivationContext.ts
134 lines
| 3.3 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r33 | import { TraceSource } from "../log/TraceSource"; | ||
| import { argumentNotNull, argumentNotEmptyString, isPrimitive, each, isNull } from "../safe"; | ||||
|
cin
|
r34 | import { Descriptor, ServiceMap, isDescriptor } from "./interfaces"; | ||
| import { Container } from "./Container"; | ||||
|
cin
|
r33 | |||
|
cin
|
r39 | const trace = TraceSource.get("@implab/core/di/ActivationContext"); | ||
|
cin
|
r33 | |||
|
cin
|
r39 | export interface ActivationContextInfo { | ||
| name: string; | ||||
|
cin
|
r34 | |||
|
cin
|
r39 | service: Descriptor; | ||
|
cin
|
r34 | |||
|
cin
|
r39 | scope: ServiceMap; | ||
|
cin
|
r34 | } | ||
|
cin
|
r39 | export class ActivationContext { | ||
| _cache: object; | ||||
|
cin
|
r33 | |||
|
cin
|
r39 | _services: ServiceMap; | ||
|
cin
|
r33 | |||
|
cin
|
r39 | _stack: ActivationContextInfo[]; | ||
|
cin
|
r33 | |||
|
cin
|
r39 | _visited: object; | ||
|
cin
|
r33 | |||
|
cin
|
r39 | container: Container; | ||
|
cin
|
r33 | |||
| constructor(container: Container, services: ServiceMap, cache?: object, visited?) { | ||||
| argumentNotNull(container, "container"); | ||||
| argumentNotNull(services, "services"); | ||||
| this._visited = visited || {}; | ||||
| this._stack = []; | ||||
| this._cache = cache || {}; | ||||
| this._services = services; | ||||
| this.container = container; | ||||
| } | ||||
| getService(name, def?): any { | ||||
|
cin
|
r39 | const d = this._services[name]; | ||
|
cin
|
r33 | |||
| if (!d) | ||||
| if (arguments.length > 1) | ||||
| return def; | ||||
| else | ||||
|
cin
|
r39 | throw new Error(`Service ${name} not found`); | ||
|
cin
|
r33 | |||
|
cin
|
r40 | return isDescriptor(d) ? d.activate(this, name) : d; | ||
|
cin
|
r33 | } | ||
| /** | ||||
| * registers services local to the the activation context | ||||
|
cin
|
r39 | * | ||
|
cin
|
r33 | * @name{string} the name of the service | ||
| * @service{string} the service descriptor to register | ||||
| */ | ||||
| register(name: string, service: Descriptor) { | ||||
| argumentNotEmptyString(name, "name"); | ||||
| this._services[name] = service; | ||||
| } | ||||
| clone() { | ||||
| return new ActivationContext( | ||||
| this.container, | ||||
| Object.create(this._services), | ||||
| this._cache, | ||||
| this._visited | ||||
| ); | ||||
| } | ||||
|
cin
|
r39 | has(id: string) { | ||
|
cin
|
r33 | return id in this._cache; | ||
| } | ||||
|
cin
|
r39 | get(id: string) { | ||
|
cin
|
r33 | return this._cache[id]; | ||
| } | ||||
|
cin
|
r39 | store(id: string, value) { | ||
|
cin
|
r33 | return (this._cache[id] = value); | ||
| } | ||||
|
cin
|
r40 | parse(data, name: string) { | ||
|
cin
|
r33 | if (isPrimitive(data)) | ||
| return data; | ||||
| if (isDescriptor(data)) { | ||||
| return data.activate(this, name); | ||||
| } else if (data instanceof Array) { | ||||
|
cin
|
r39 | this.enter(name); | ||
| const v = data.map( (x, i) => this.parse(x, `[${i}]`)); | ||||
| this.leave(); | ||||
|
cin
|
r33 | return v; | ||
| } else { | ||||
|
cin
|
r39 | this.enter(name); | ||
| const result = {}; | ||||
| for (const p in data) | ||||
| result[p] = this.parse(data[p], "." + p); | ||||
| this.leave(); | ||||
|
cin
|
r33 | return result; | ||
| } | ||||
| } | ||||
|
cin
|
r39 | visit(id: string) { | ||
| const count = this._visited[id] || 0; | ||||
|
cin
|
r33 | this._visited[id] = count + 1; | ||
| return count; | ||||
| } | ||||
| getStack() { | ||||
| return this._stack.slice().reverse(); | ||||
| } | ||||
|
cin
|
r39 | enter(name: string, d?: Descriptor, localize?: boolean) { | ||
|
cin
|
r33 | if (trace.isLogEnabled()) | ||
| trace.log("enter " + name + " " + (d || "") + | ||||
| (localize ? " localize" : "")); | ||||
| this._stack.push({ | ||||
|
cin
|
r39 | name, | ||
|
cin
|
r33 | service: d, | ||
| scope: this._services | ||||
| }); | ||||
| if (localize) | ||||
| this._services = Object.create(this._services); | ||||
| } | ||||
| leave() { | ||||
|
cin
|
r39 | const ctx = this._stack.pop(); | ||
|
cin
|
r33 | this._services = ctx.scope; | ||
| if (trace.isLogEnabled()) | ||||
| trace.log("leave " + ctx.name + " " + (ctx.service || "")); | ||||
| } | ||||
|
cin
|
r39 | } | ||