export function saveState(cwd, state) {
  const previousJobs = loadState(cwd).jobs;   // read
  ...
  const nextJobs = pruneJobs(state.jobs ?? []); // keeps top-50 by updatedAt
  ...
  const retainedIds = new Set(nextJobs.map((job) => job.id));
  for (const job of previousJobs) {
    if (retainedIds.has(job.id)) continue;
    removeJobFile(resolveJobFile(cwd, job.id)); // <-- destructive
    removeFileIfExists(job.logFile);            // <-- destructive
  }
  fs.writeFileSync(...);                         // write
}

import fs from "node:fs";
import os from "node:os";
import path from "node:path";

process.env.CLAUDE_PLUGIN_DATA = fs.mkdtempSync(path.join(os.tmpdir(), "cxc-repro-"));
const state = await import("./plugins/codex/scripts/lib/state.mjs");
const cwd = process.cwd();

// --- Concurrent read-modify-write clobber ---
const a = state.loadState(cwd);   // process A sees empty jobs
const b = state.loadState(cwd);   // process B sees empty jobs
a.jobs.push({ id: "job-A", updatedAt: new Date().toISOString() });
state.saveState(cwd, a);          // A persists job-A
b.jobs.push({ id: "job-B", updatedAt: new Date().toISOString() });
state.saveState(cwd, b);          // B, with a stale snapshot, clobbers A
console.log(state.listJobs(cwd).map((j) => j.id));                 // ['job-B']
console.log(fs.existsSync(state.resolveJobFile(cwd, "job-A")));     // false  <-- A's file deleted

// --- Prune deletes a live job's log past the 50 cap ---
const log = state.resolveJobLogFile(cwd, "job-running");
fs.writeFileSync(log, "live worker output\n");
state.upsertJob(cwd, { id: "job-running", status: "running", logFile: log, updatedAt: "2000-01-01T00:00:00.000Z" });
for (let i = 0; i < 55; i++) state.upsertJob(cwd, { id: `filler-${i}`, status: "completed", updatedAt: `2026-07-0${(i%9)+1}T00:0${i%6}:00.000Z` });
console.log(state.listJobs(cwd).some((j) => j.id === "job-running")); // false
console.log(fs.existsSync(log));                                      // false  <-- live log deleted