Interrupted Completion Report

1#!/usr/bin/env node
2'use strict';
3
4// Records an import that stopped without recording it (SIGKILL, a crash in finalize): writes an
5// `aborted` completion report from the attempt journal, then the discovered-set status and the
6// post-execution handoff, so cutover sees the pause. Never resumes or writes to Wix.
7const fs = require('node:fs');
8const path = require('node:path');
9const { createProgressLogger, parseProgressArgs } = require('../lib/progress-log.js');
10const { ensureInterruptedCompletionReport, refreshInterruptedHandoff } = require('../lib/import-interruption.js');
11
12let progress;
13
14async function main() {
15  const parsed = parseProgressArgs(process.argv.slice(2));
16  progress = createProgressLogger({ script: 'skills/wix-replatform/scripts/interrupted-completion-report.js', ...parsed.progress });
17  const step = { phase: 'execution', step: 'interrupted-completion-report' };
18  progress.start('Interrupted import report started', step);
19  const projectDirArg = parsed.args[0];
20  if (!projectDirArg) {
21    console.error('Usage: node scripts/interrupted-completion-report.js <projectDir> [--progress-log <path>]');
22    progress.error('Missing project directory', step);
23    process.exit(1);
24  }
25  const projectDir = path.resolve(projectDirArg);
26  // A report with no interruption is a finished run's record; only a resumed run replaces it.
27  let existing = null;
28  try { existing = JSON.parse(fs.readFileSync(path.join(projectDir, 'execution/completion-report.json'), 'utf8')); } catch (error) { if (error.code !== 'ENOENT') throw error; }
29  if (existing && !existing.interruption) {
30    console.error('execution/completion-report.json records a finished run; resume the import instead of replacing it');
31    progress.error('Completion report already present', step);
32    process.exitCode = 1;
33    return;
34  }
35  const interruption = { kind: 'error', code: 'stopped_without_record', at: new Date().toISOString() };
36  const result = await ensureInterruptedCompletionReport(projectDir, { interruption });
37  const handoff = await refreshInterruptedHandoff(projectDir);
38  console.log(JSON.stringify({
39    ok: true,
40    action: result.action,
41    status: result.report.status,
42    interruption: result.report.interruption,
43    handoff: handoff.ok ? 'written' : handoff.reason,
44  }, null, 2));
45  progress.complete(`Interrupted import report ${result.action}`, { ...step, artifact: 'execution/completion-report.json' });
46}
47
48main().catch((error) => {
49  if (progress) progress.error(error && error.message ? error.message : 'Interrupted import report failed', { phase: 'execution', step: 'interrupted-completion-report' });
50  console.error(error && error.message ? error.message : error);
51  process.exitCode = 1;
52});