Multilingual Public Plan

1#!/usr/bin/env node
2'use strict';
3
4const fs = require('node:fs/promises');
5const path = require('node:path');
6const core = require('../../../lib/multilingual-public.js');
7
8async function readJson(file, fallback) {
9  try { return JSON.parse(await fs.readFile(file, 'utf8')); } catch (error) { if (error.code === 'ENOENT') return fallback; throw error; }
10}
11
12async function run(projectDir) {
13  const topology = await readJson(path.join(projectDir, 'discovery/public-source-languages.json'), null);
14  if (!topology) throw new Error('discovery/public-source-languages.json is required');
15  const contentRows = core.readNdjson(path.join(projectDir, 'discovery/public-multilingual-content.ndjson'));
16  const objectPairings = core.readNdjson(path.join(projectDir, 'state/default-object-identity.ndjson'));
17  const pairings = core.readNdjson(path.join(projectDir, 'state/default-member-identity.ndjson'));
18  const capabilities = await readJson(path.join(projectDir, 'mapping/multilingual-public-capabilities.json'), { fields: [], contents: [] });
19  const output = path.join(projectDir, 'mapping/multilingual-public-plan.ndjson');
20  const priorPlanRows = core.readNdjson(output);
21  const journalRows = [...(capabilities.recoveryRows || []), ...core.readNdjson(path.join(projectDir, 'state/multilingual-public/changes.ndjson'))];
22  const plan = core.buildPlan({ topology, contentRows, objectPairings, pairings, capabilities, liveContents: capabilities.contents || [], journalRows, priorPlanRows });
23  await fs.mkdir(path.dirname(output), { recursive: true });
24  await fs.writeFile(output, plan.rows.map((row) => JSON.stringify(row)).join('\n') + (plan.rows.length ? '\n' : ''));
25  await core.writeJsonAtomic(path.join(projectDir, 'state/multilingual-public/plan.json'), {
26    schemaVersion: 1,
27    inputDigest: plan.inputDigest,
28    capabilityDigest: capabilities.digest || core.digest(capabilities),
29    counts: plan.rows.reduce((counts, row) => ({ ...counts, [row.state]: (counts[row.state] || 0) + 1 }), {}),
30  });
31  return plan;
32}
33
34async function main() {
35  const projectDir = process.argv[2] && path.resolve(process.argv[2]);
36  if (!projectDir) throw new Error('Usage: multilingual-public-plan.js <projectDir>');
37  const plan = await run(projectDir);
38  process.stdout.write(`${JSON.stringify({ rows: plan.rows.length, inputDigest: plan.inputDigest })}\n`);
39}
40
41if (require.main === module) main().catch((error) => { console.error(error.message); process.exitCode = 1; });
42module.exports = { run };