ActivatableMixin.ts
83 lines
| 2.5 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r38 | import { IActivationController, IActivatable, ICancellation } from "../interfaces"; | ||
| import { AsyncComponent } from "./AsyncComponent"; | ||||
| import { Cancellation } from "../Cancellation"; | ||||
| import { TraceSource } from "../log/TraceSource"; | ||||
|
cin
|
r9 | |||
| type Constructor<T = {}> = new (...args: any[]) => T; | ||||
|
cin
|
r38 | const log = TraceSource.get("@implab/core/components/ActivatableMixin"); | ||
|
cin
|
r11 | |||
|
cin
|
r22 | export function ActivatableMixin<TBase extends Constructor<AsyncComponent>>(Base: TBase) { | ||
|
cin
|
r9 | return class extends Base implements IActivatable { | ||
| _controller: IActivationController; | ||||
| _active: boolean; | ||||
| isActive() { | ||||
| return this._active; | ||||
| } | ||||
| getActivationController() { | ||||
| return this._controller; | ||||
| } | ||||
| setActivationController(controller: IActivationController) { | ||||
| this._controller = controller; | ||||
| } | ||||
| async onActivating(ct: ICancellation) { | ||||
| if (this._controller) | ||||
| await this._controller.activating(this, ct); | ||||
| } | ||||
| async onActivated(ct: ICancellation) { | ||||
| if (this._controller) | ||||
| await this._controller.activated(this, ct); | ||||
| } | ||||
|
cin
|
r13 | activate(ct: ICancellation = Cancellation.none) { | ||
| return this.runOperation(this._activateAsync.bind(this), ct); | ||||
| } | ||||
| async _activateAsync(ct: ICancellation) { | ||||
|
cin
|
r9 | if (this.isActive()) | ||
| return; | ||||
|
cin
|
r13 | |||
| await this.onActivating(ct); | ||||
| this._active = true; | ||||
|
cin
|
r9 | try { | ||
|
cin
|
r13 | await this.onActivated(ct); | ||
|
cin
|
r9 | } catch (e) { | ||
|
cin
|
r13 | log.error("Suppressed onActivated error: {0}", e); | ||
|
cin
|
r9 | } | ||
| } | ||||
| async onDeactivating(ct: ICancellation) { | ||||
| if (this._controller) | ||||
| await this._controller.deactivating(this, ct); | ||||
| } | ||||
| async onDeactivated(ct: ICancellation) { | ||||
| if (this._controller) | ||||
| await this._controller.deactivated(this, ct); | ||||
| } | ||||
|
cin
|
r13 | deactivate(ct: ICancellation = Cancellation.none) { | ||
| return this.runOperation(this._deactivateAsync.bind(this), ct); | ||||
| } | ||||
| async _deactivateAsync(ct: ICancellation) { | ||||
|
cin
|
r9 | if (!this.isActive()) | ||
| return; | ||||
|
cin
|
r13 | await this.onDeactivating(ct); | ||
| this._active = false; | ||||
|
cin
|
r9 | try { | ||
|
cin
|
r13 | await this.onDeactivated(ct); | ||
|
cin
|
r9 | } catch (e) { | ||
|
cin
|
r13 | log.error("Suppressed onDeactivated error: {0}", e); | ||
|
cin
|
r9 | } | ||
| } | ||||
|
cin
|
r38 | }; | ||
|
cin
|
r9 | } | ||
|
cin
|
r38 | export const traceSource = log; | ||