Extract Ledger

1#!/usr/bin/env node
2'use strict';
3
4// Record or check a source extract version in the toolkit's extract ledger.
5//   node scripts/extract-ledger.js record --project <dir> --entity <entity> --extract <path> [--key-field id]
6//   node scripts/extract-ledger.js check  --project <dir> --extract <path>
7// Prints JSON with typed codes only (never source text); exits 2 when the extract is unrecorded,
8// changed since recorded, or lost fields.
9
10const ledger = require('../lib/extract-ledger');
11
12async function main() {
13  const [command, ...rest] = process.argv.slice(2);
14  const flags = {};
15  for (let i = 0; i < rest.length; i += 2) flags[rest[i].replace(/^--/, '')] = rest[i + 1];
16  if (!flags.project || !flags.extract || !['record', 'check'].includes(command) || (command === 'record' && !flags.entity)) return { ok: false, errors: ['extract_ledger_usage'] };
17  if (command === 'record') {
18    try { await ledger.recordExtract(flags.project, { entity: flags.entity, extractPath: flags.extract, keyField: flags['key-field'] || 'id', recordedBy: 'extract-ledger-cli' }); }
19    catch (error) { const code = /^(extract|source_extract)_[a-z_]+$/.test(error.code || '') ? error.code : 'extract_unreadable'; return { ok: false, errors: [code], next: [ledger.nextStep(code)].filter(Boolean) }; }
20  }
21  const errors = await ledger.extractErrors(flags.project, flags.extract);
22  let latest = null;
23  try { latest = ledger.entries(flags.project, flags.extract).pop() || null; } catch { /* reported by extractErrors */ }
24  return { ok: errors.length === 0, extract: latest ? { path: latest.extractPath, version: latest.version, sha256: latest.sha256, rows: latest.rows, lostPaths: latest.lostPaths } : null, errors, next: [...new Set(errors.map(ledger.nextStep).filter(Boolean))] };
25}
26main().then(result => { console.log(JSON.stringify(result)); process.exitCode = result.ok ? 0 : 2; },
27  () => { console.log(JSON.stringify({ ok: false, errors: ['extract_ledger_failed'] })); process.exitCode = 2; });