TestTraits.ts
75 lines
| 2.1 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r22 | import { IObservable, ICancellation, IDestroyable } from "@implab/core/interfaces"; | ||
| import { Cancellation } from "@implab/core/Cancellation"; | ||||
| import { TraceEvent, LogLevel, WarnLevel } from "@implab/core/log/TraceSource"; | ||||
|
cin
|
r40 | import * as tape from "tape"; | ||
|
cin
|
r22 | import { argumentNotNull } from "@implab/core/safe"; | ||
|
cin
|
r15 | |||
| export class TapeWriter implements IDestroyable { | ||||
|
cin
|
r40 | readonly _tape: tape.Test; | ||
|
cin
|
r15 | |||
| _subscriptions = new Array<IDestroyable>(); | ||||
|
cin
|
r40 | constructor(t: tape.Test) { | ||
| argumentNotNull(t, "tape"); | ||||
| this._tape = t; | ||||
|
cin
|
r15 | } | ||
| writeEvents(source: IObservable<TraceEvent>, ct: ICancellation = Cancellation.none) { | ||||
|
cin
|
r40 | const subscription = source.on(this.writeEvent.bind(this)); | ||
|
cin
|
r15 | if (ct.isSupported()) { | ||
| ct.register(subscription.destroy.bind(subscription)); | ||||
| } | ||||
| this._subscriptions.push(subscription); | ||||
| } | ||||
| writeEvent(next: TraceEvent) { | ||||
|
cin
|
r22 | if (next.level >= LogLevel) { | ||
|
cin
|
r15 | this._tape.comment("LOG " + next.arg); | ||
|
cin
|
r22 | } else if (next.level >= WarnLevel) { | ||
|
cin
|
r15 | this._tape.comment("WARN " + next.arg); | ||
| } else { | ||||
| this._tape.comment("ERROR " + next.arg); | ||||
| } | ||||
| } | ||||
| destroy() { | ||||
| this._subscriptions.forEach(x => x.destroy()); | ||||
| } | ||||
|
cin
|
r18 | } | ||
| export async function delay(timeout: number, ct: ICancellation = Cancellation.none) { | ||||
| let un: IDestroyable; | ||||
|
cin
|
r40 | |||
|
cin
|
r18 | try { | ||
|
cin
|
r40 | await new Promise((resolve, reject) => { | ||
|
cin
|
r18 | if (ct.isRequested()) { | ||
|
cin
|
r40 | un = ct.register(reject); | ||
| } else { | ||||
| const ht = setTimeout(() => { | ||||
| resolve(); | ||||
| }, timeout); | ||||
| un = ct.register(e => { | ||||
| clearTimeout(ht); | ||||
| reject(e); | ||||
| }); | ||||
| } | ||||
| }); | ||||
|
cin
|
r18 | } finally { | ||
|
cin
|
r40 | if (un) | ||
| un.destroy(); | ||||
| } | ||||
| } | ||||
| export function test(name: string, cb: (t: tape.Test) => any) { | ||||
| tape(name, async t => { | ||||
| try { | ||||
| await cb(t); | ||||
| } catch (e) { | ||||
| console.error(e); | ||||
| t.fail(e); | ||||
| } finally { | ||||
| t.end(); | ||||
| } | ||||
| }); | ||||
| } | ||||