import test from 'node:test';
import assert from 'node:assert/strict';
import fs from 'node:fs';
import { tmpdir } from 'node:os';
import { join } from 'node:path';
import { watchModelOutput } from '../src/model-stall.mjs';
function fixture(t) { const root = fs.mkdtempSync(join(tmpdir(), 'p2-stall-')); t.after(() => fs.rmSync(root, { recursive: true, force: true })); return root; }
test('proxy-stall: silent run stops and logs only ids, never output or key values', async t => {
  const root = fixture(t), receipts = []; let stops = 0;
  const watch = watchModelOutput({ runDir: root, seconds: 0.02, keyId: '0123456789ab', stop: async () => { stops++; }, receipt: r => receipts.push(r) });
  t.after(watch.cancel); await watch.done;
  assert.equal(stops, 1); assert.deepEqual(receipts, [{ action: 'proxy-stall', keyIds: ['0123456789ab'] }]);
});
test('first stdout marker cancels stall without reading or logging marker text', async t => {
  const root = fixture(t), receipts = []; let stops = 0;
  fs.writeFileSync(join(root, 'proxy-first-output'), 'fx331-private-output');
  const watch = watchModelOutput({ runDir: root, seconds: 0.02, keyId: '0123456789ab', stop: async () => { stops++; }, receipt: r => receipts.push(r) });
  t.after(watch.cancel); await watch.done; assert.equal(stops, 0); assert.deepEqual(receipts, []);
});
test('proxy-stop-failed: failed stall stop is logged by code and never leaks error text', async t => {
  const root = fixture(t), receipts = [];
  const watch = watchModelOutput({ runDir: root, seconds: 0.02, keyId: '0123456789ab', stop: async () => { throw Error('fx331-private-output'); }, receipt: r => receipts.push(r) });
  t.after(watch.cancel); await watch.done;
  assert.deepEqual(receipts, [{ action: 'proxy-stall', code: 'proxy-stop-failed', keyIds: ['0123456789ab'] }]);
});
test('run exit cancellation settles watcher without stopping the run', async t => {
  const root = fixture(t); let stops = 0;
  const watch = watchModelOutput({ runDir: root, seconds: 0.02, keyId: '0123456789ab', stop: async () => { stops++; }, receipt: () => {} });
  watch.cancel(); await watch.done; assert.equal(stops, 0);
});