ActivatableMixin.ts
82 lines
| 2.5 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r13 | import { IActivationController, IActivatable, ICancellation } from '../interfaces'; | |
|
cin
|
r9 | import { AsyncComponent } from './AsyncComponent'; | |
|
cin
|
r13 | import { Cancellation } from '../Cancellation'; | |
|
cin
|
r22 | import { TraceSource } from '../log/TraceSource'; | |
|
cin
|
r9 | ||
| type Constructor<T = {}> = new (...args: any[]) => T; | |||
|
cin
|
r11 | const log = TraceSource.get('@implab/core/components/ActivatableMixin'); | |
|
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
|
r22 | export const traceSource = log; |