ActivatableMixin.ts
83 lines
| 2.5 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r49 | import { IActivationController, IActivatable, ICancellation } from "../interfaces"; | ||
| import { AsyncComponent } from "./AsyncComponent"; | ||||
| import { Cancellation } from "../Cancellation"; | ||||
| import { TraceSource } from "../log/TraceSource"; | ||||
| type Constructor<T = {}> = new (...args: any[]) => T; | ||||
| const log = TraceSource.get("@implab/core/components/ActivatableMixin"); | ||||
| export function ActivatableMixin<TBase extends Constructor<AsyncComponent>>(Base: TBase) { | ||||
| 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); | ||||
| } | ||||
| activate(ct: ICancellation = Cancellation.none) { | ||||
| return this.runOperation(this._activateAsync.bind(this), ct); | ||||
| } | ||||
| async _activateAsync(ct: ICancellation) { | ||||
| if (this.isActive()) | ||||
| return; | ||||
| await this.onActivating(ct); | ||||
| this._active = true; | ||||
| try { | ||||
| await this.onActivated(ct); | ||||
| } catch (e) { | ||||
| log.error("Suppressed onActivated error: {0}", e); | ||||
| } | ||||
| } | ||||
| 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); | ||||
| } | ||||
| deactivate(ct: ICancellation = Cancellation.none) { | ||||
| return this.runOperation(this._deactivateAsync.bind(this), ct); | ||||
| } | ||||
| async _deactivateAsync(ct: ICancellation) { | ||||
| if (!this.isActive()) | ||||
| return; | ||||
| await this.onDeactivating(ct); | ||||
| this._active = false; | ||||
| try { | ||||
| await this.onDeactivated(ct); | ||||
| } catch (e) { | ||||
| log.error("Suppressed onDeactivated error: {0}", e); | ||||
| } | ||||
| } | ||||
| }; | ||||
| } | ||||
| export const traceSource = log; | ||||