'use strict';
const test = require('node:test'), assert = require('node:assert/strict');
const fs = require('fs'), os = require('os'), path = require('path'), { EventEmitter } = require('events');
const { Supervisor } = require('../../runtime/supervisor');
const delay = ms => new Promise(resolve => setTimeout(resolve, ms));
test('supervisor isolates a child crash and persists its bounded restart budget', async () => {
  const dir = fs.mkdtempSync(path.join(os.tmpdir(), 'mc-supervisor-')), file = path.join(dir, 'runtime.json');
  let starts = 0;
  const spawn = () => { const child = new EventEmitter(); child.pid = ++starts; child.kill = () => { child.emit('exit', 0); child.emit('close', 0); }; return child; };
  const supervisor = new Supervisor('reader', { file, spawn, retryBaseMs: 1 });
  try {
    supervisor.start();
    for (let n = 0; n < 3; n++) {
      supervisor.child.emit('close', 1, null);
      for (let i = 0; i < 50 && supervisor.state.status === 'retry_wait'; i++) await delay(2);
    }
    assert.equal(starts, 3); assert.equal(supervisor.state.status, 'parked'); assert.equal(supervisor.child, null);
    const restored = new Supervisor('reader', { file, spawn, retryBaseMs: 1 }); restored.start();
    assert.equal(starts, 3); assert.equal(restored.state.status, 'parked'); await restored.close();
  } finally { await supervisor.close(); fs.rmSync(dir, { recursive: true, force: true }); }
});
test('intentional supervisor shutdown does not consume the crash budget', async () => {
  const dir = fs.mkdtempSync(path.join(os.tmpdir(), 'mc-supervisor-stop-'));
  const child = new EventEmitter(); child.pid = 1; child.kill = () => { child.emit('exit', 0); child.emit('close', 0); };
  const supervisor = new Supervisor('scraper', { file: path.join(dir, 'runtime.json'), spawn: () => child });
  try { supervisor.start(); await supervisor.close(); assert.equal(supervisor.state.status, 'stopped'); assert.equal(supervisor.state.failures.length, 0); }
  finally { await supervisor.close(); fs.rmSync(dir, { recursive: true, force: true }); }
});