Method run

testing/test.ts:48–103

(ctx: IRunContext)

  constructor(public readonly options: ITestOptions, private readonly fn: () => any) {}

  public async run(ctx: IRunContext) {
    const path = [...ctx.path, this.options.name];
    if (!path.join(" > ").match(ctx.testNameMatcher)) {
      return;
    }
    const retries = this.options.retries || 0;
    let lastResult: IRunResult;
    for (let i = 0; i <= retries; i++) {
      let timer: NodeJS.Timer;
      const timeout = this.options.timeout || Test.DEFAULT_TIMEOUT_MILLIS;
      const result: IRunResult = {
        path,
        outcome: "failed"
      };
      try {
        await Promise.race([
          (async () => {
            const hookCtx = {
              ...ctx,
              path
            };
            for (const beforeEach of ctx.beforeEaches) {
              await beforeEach.run(hookCtx);
            }
            try {
              // Run the test.
              await this.fn();
            } finally {
              // Always run the after eaches.
              for (const afterEach of ctx.afterEaches) {
                await afterEach.run(hookCtx);
              }
            }
          })(),
          new Promise((_, reject) => {
            timer = setTimeout(() => {
              result.outcome = "timeout";
              reject(new Error(`Timed out (${timeout}ms).`));
            }, timeout);
          })
        ]);
        result.outcome = "passed";
      } catch (e) {
        result.err = e;
      } finally {
        clearTimeout(timer);
      }

      lastResult = result;
      if (result.outcome === "passed") {
        break;
      }
    }

    ctx.results.push(lastResult);
  }
}