index.js

const { createReadStream } = require('node:fs');
const { inspect } = require('node:util');
const junitReporter = require('@reporters/junit');
const { YAMLToJs } = require('internal/test_runner/yaml_to_js');
const { TapParser } = require('internal/test_runner/tap_parser');
const { TokenKind } = require('internal/test_runner/tap_lexer');

createReadStream(process.argv[2])
  .pipe(new TapParser())
  .compose(async function* (source) {
    let failing = false;
    yield { type: 'test:start', data: { nesting: 0, name: 'test' } };
    for await (const ast of source) {
      if (ast.kind === TokenKind.TAP_TEST_POINT) {
        failing ||= !ast.node.status.pass;

        const type = ast.node.status.pass ? 'test:pass' : 'test:fail';
        const parts = ast.node.description.split('/')
        const name = parts.pop();
        const classname = parts.join('.');
        const directive = ast.node.status.skip ? { skip: ast.node.reason } : ast.node.status.todo ? { todo: ast.node.reason } : {};
        const details = YAMLToJs(ast.node.diagnostics);
        if (details.stack) {
          details.error = {
            [inspect.custom]() {
              return `---\n${ast.node.diagnostics.slice(0, 3).join('\n')}\n...`;
            },
            message: `fail (${details.exitcode})`,
            code: details.exitcode,
          }
        }
        yield { type, data: { nesting: ast.nesting + 1, name, classname, testNumber: Number(ast.node.id), details, ...directive } };
      }
    }

    const type = failing ? 'test:fail' : 'test:pass';
    yield { type, data: { nesting: 0, name: 'test', testNumber: 0, details: {} } };
  })
  .compose(junitReporter)
  .pipe(process.stdout)