Record Gap Decision

1#!/usr/bin/env node
2import path from "node:path";
3import { docsDir, parseArgs, readJson, writeJson } from "./lib/common.mjs";
4import { finalizeExtractionReport } from "./finalize-extraction-report.mjs";
5
6export const GAP_DECISIONS = new Set(["accept-as-is", "retry-or-fix", "provide-material", "replace", "omit", "leave-unresolved"]);
7
8export async function recordGapDecision({ outputDir, gapId, decision, note = "", materialRefs = [] }) {
9  if (!gapId) throw new Error("gapId is required");
10  if (!GAP_DECISIONS.has(decision)) throw new Error(`Unsupported gap decision: ${decision}`);
11  const docs = docsDir(outputDir);
12  const latest = await readJson(path.join(docs, "extraction", "latest.json"));
13  const gaps = await readJson(path.join(docs, "extraction", latest.captureId, "extraction-gaps.json"));
14  if (!(gaps.gaps || []).some((gap) => gap.id === gapId)) throw new Error(`Unknown extraction gap: ${gapId}`);
15  const decisionPath = path.join(docs, "gap-decisions.json");
16  let artifact;
17  try { artifact = await readJson(decisionPath); } catch { artifact = { schemaVersion: "0083.1", manifestHash: latest.manifestHash, decisions: [] }; }
18  if (artifact.manifestHash !== latest.manifestHash) throw new Error("Gap decisions belong to a stale frozen manifest; review the current final report first");
19  const record = { gapId, decision, note, materialRefs };
20  artifact.decisions = [...artifact.decisions.filter((item) => item.gapId !== gapId), record].sort((a, b) => a.gapId.localeCompare(b.gapId));
21  await writeJson(decisionPath, artifact);
22  const report = await finalizeExtractionReport({ outputDir });
23  return { decisionPath, record, finalStatus: report.status };
24}
25
26async function main() {
27  const args = parseArgs();
28  if (!args.out || !args.gap || !args.decision) throw new Error("--out, --gap, and --decision are required");
29  const materialRefs = String(args.material || "").split(",").map((item) => item.trim()).filter(Boolean);
30  console.log(JSON.stringify(await recordGapDecision({
31    outputDir: path.resolve(String(args.out)),
32    gapId: String(args.gap),
33    decision: String(args.decision),
34    note: String(args.note || ""),
35    materialRefs,
36  }), null, 2));
37}
38
39if (import.meta.url === `file://${process.argv[1]}`) main().catch((error) => { console.error(error.stack || error.message); process.exit(1); });