Stop Capture

1#!/usr/bin/env node
2// Stop an in-progress capture and stamp the manifest with stopped_at.
3//
4// Usage:
5//   node scripts/stop-capture.mjs <run-id>
6
7import fs from 'node:fs';
8import path from 'node:path';
9
10import { runDir, readJson, writeJson, isoUtcSeconds, isAlive, sleepMs } from './lib.mjs';
11
12const [runId] = process.argv.slice(2);
13if (!runId) {
14  console.error('usage: stop-capture.mjs <run-id>');
15  process.exit(2);
16}
17
18const RD = runDir(runId);
19if (!fs.existsSync(RD)) {
20  console.error(`run dir not found: ${RD}`);
21  process.exit(1);
22}
23
24for (const pidFile of ['.cdp.pid', '.loop.pid']) {
25  const p = path.join(RD, pidFile);
26  if (!fs.existsSync(p)) continue;
27  const pid = parseInt(fs.readFileSync(p, 'utf8').trim(), 10);
28  if (!Number.isInteger(pid)) { fs.unlinkSync(p); continue; }
29
30  try { process.kill(pid, 'SIGTERM'); } catch {}
31  for (let i = 0; i < 3 && isAlive(pid); i++) {
32    await sleepMs(1000);
33  }
34  if (isAlive(pid)) {
35    try { process.kill(pid, 'SIGKILL'); } catch {}
36  }
37  fs.unlinkSync(p);
38}
39
40const manifestPath = path.join(RD, 'manifest.json');
41const manifest = readJson(manifestPath);
42if (manifest) {
43  manifest.stopped_at = isoUtcSeconds();
44  writeJson(manifestPath, manifest);
45}
46
47// Sweep half-written DOM dumps if the loop got SIGTERM'd mid-write.
48const domDir = path.join(RD, 'dom');
49if (fs.existsSync(domDir)) {
50  for (const f of fs.readdirSync(domDir)) {
51    if (f.endsWith('.partial')) {
52      try { fs.unlinkSync(path.join(domDir, f)); } catch {}
53    }
54  }
55}
56
57console.log(`stopped: ${RD}`);