TestTraits.ts
74 lines
| 2.3 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r50 | import { IObservable, ICancellation, IDestroyable } from "@implab/core/interfaces"; | ||
| import { Cancellation } from "@implab/core/Cancellation"; | ||||
| import { TraceEvent, LogLevel, WarnLevel, DebugLevel, TraceSource } from "@implab/core/log/TraceSource"; | ||||
| import * as tape from "tape"; | ||||
|
cin
|
r59 | import { argumentNotNull, destroy } from "@implab/core/safe"; | ||
|
cin
|
r50 | |||
| export class TapeWriter implements IDestroyable { | ||||
|
cin
|
r82 | private readonly _tape: tape.Test; | ||
|
cin
|
r50 | |||
|
cin
|
r82 | private readonly _subscriptions = new Array<IDestroyable>(); | ||
| private _destroyed; | ||||
|
cin
|
r50 | |||
| constructor(t: tape.Test) { | ||||
| argumentNotNull(t, "tape"); | ||||
| this._tape = t; | ||||
| } | ||||
| writeEvents(source: IObservable<TraceEvent>, ct: ICancellation = Cancellation.none) { | ||||
|
cin
|
r82 | if (!this._destroyed) { | ||
| const subscription = source.on(this.writeEvent.bind(this)); | ||||
| if (ct.isSupported()) { | ||||
| ct.register(subscription.destroy.bind(subscription)); | ||||
| } | ||||
| this._subscriptions.push(subscription); | ||||
|
cin
|
r50 | } | ||
| } | ||||
| writeEvent(next: TraceEvent) { | ||||
| if (next.level >= DebugLevel) { | ||||
|
cin
|
r82 | this._tape.comment(`DEBUG ${next.source.id} ${next}`); | ||
|
cin
|
r50 | } else if (next.level >= LogLevel) { | ||
|
cin
|
r82 | this._tape.comment(`LOG ${next.source.id} ${next}`); | ||
|
cin
|
r50 | } else if (next.level >= WarnLevel) { | ||
|
cin
|
r82 | this._tape.comment(`WARN ${next.source.id} ${next}`); | ||
|
cin
|
r50 | } else { | ||
|
cin
|
r82 | this._tape.comment(`ERROR ${next.source.id} ${next}`); | ||
|
cin
|
r50 | } | ||
| } | ||||
| destroy() { | ||||
|
cin
|
r59 | this._subscriptions.forEach(destroy); | ||
|
cin
|
r50 | } | ||
| } | ||||
|
cin
|
r82 | export function test(name: string, cb: (t: tape.Test, trace: TraceSource) => any) { | ||
|
cin
|
r50 | tape(name, async t => { | ||
| const writer = new TapeWriter(t); | ||||
|
cin
|
r82 | // this trace is not announced through the TraceSource global registry | ||
| const trace = new TraceSource(name); | ||||
| trace.level = DebugLevel; | ||||
| writer.writeEvents(trace.events); | ||||
| const h = TraceSource.on(ts => { | ||||
|
cin
|
r50 | ts.level = DebugLevel; | ||
| writer.writeEvents(ts.events); | ||||
| }); | ||||
| try { | ||||
|
cin
|
r82 | await cb(t, trace); | ||
|
cin
|
r50 | } catch (e) { | ||
| // verbose error information | ||||
| // tslint:disable-next-line | ||||
| console.error(e); | ||||
| t.fail(e); | ||||
| } finally { | ||||
| t.end(); | ||||
|
cin
|
r59 | destroy(writer); | ||
|
cin
|
r82 | destroy(h); | ||
|
cin
|
r50 | } | ||
| }); | ||||
| } | ||||