Batch

1import { once } from 'node:events';
2import { createInterface } from 'node:readline';
3
4const scenario = process.argv[2] ?? 'normal';
5if (!['normal', 'mixed', 'partial-zero', 'empty', 'unknown', 'fail-fast', 'cancelled', 'live'].includes(scenario)) {
6  throw new Error('Unknown fixture scenario');
7}
8const count = scenario === 'empty' ? 0 : scenario === 'mixed' ? 4 : 3;
9const total = scenario === 'unknown' ? null : count;
10const stats = { processed: 0, succeeded: 0, failed: 0, skipped: 0 };
11const started = performance.now();
12let lastReport = started;
13let status = 'completed';
14const results = [];
15
16async function writeRecord(stream, record) {
17  if (!stream.write(`${JSON.stringify(record)}\n`)) await once(stream, 'drain');
18}
19
20async function emit(event, fields = {}) {
21  await writeRecord(process.stderr, { event, total, ...stats, elapsed_ms: Math.round(performance.now() - started), ...fields });
22}
23
24await emit('start');
25for (let index = 1; index <= count; index++) {
26  if (scenario === 'cancelled' && index === 2) {
27    status = 'cancelled';
28    break;
29  }
30  if (scenario === 'mixed' && index === 2) {
31    stats.skipped++;
32  } else {
33    try {
34      if ((scenario === 'mixed' && index === 3) || (['fail-fast', 'partial-zero'].includes(scenario) && index === 2)) {
35        throw new Error('fixture-rejected');
36      }
37      results.push({ id: `item-${index}`, value: index * 2 });
38      stats.succeeded++;
39    } catch {
40      stats.failed++;
41      stats.processed++;
42      await emit('item-failed', { item_id: `item-${index}`, reason: 'fixture-rejected', will_continue: scenario !== 'fail-fast' });
43      if (scenario === 'fail-fast') {
44        status = 'failed';
45        break;
46      }
47      stats.processed--;
48    }
49  }
50  stats.processed++;
51  const now = performance.now();
52  if (stats.processed % 2 === 0 || now - lastReport >= 1000 || scenario === 'live') {
53    if (scenario === 'live' && index === 1) {
54      const input = createInterface({ input: process.stdin });
55      const released = once(input, 'line');
56      await emit('progress');
57      await released;
58      input.close();
59    } else {
60      await emit('progress');
61    }
62    lastReport = now;
63  }
64}
65if (status === 'completed' && stats.failed) status = 'partial';
66const exitCode = status === 'cancelled' ? 130 : stats.failed && scenario !== 'partial-zero' ? 1 : 0;
67await emit('summary', { status, exit_code: exitCode, unprocessed: total === null ? null : total - stats.processed });
68if (status !== 'cancelled') await writeRecord(process.stdout, { results });
69process.exitCode = exitCode;