Multilingual Inventory

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');
7const { loadAdapter } = require('./multilingual-execute.js');
8
9const CAPABILITIES = 'mapping/multilingual-public-capabilities.json';
10
11function recoveryInventoryError(message, cause) {
12  return Object.assign(new Error(message), {
13    code: 'LANG_RECOVERY_JOURNAL_NOT_READY',
14    route: 'recovery-row-query',
15    rowId: 'inventory',
16    ...(cause ? { cause } : {}),
17  });
18}
19
20async function persistFailure(projectDir, error) {
21  await core.writeJsonAtomic(path.join(projectDir, CAPABILITIES), {
22    schemaVersion: 1,
23    fields: [],
24    contents: [],
25    recoveryRows: [],
26    failure: { rowId: error.rowId || 'inventory', code: error.code, route: error.route || null },
27  });
28}
29
30async function run(projectDir, adapterModule) {
31  const adapter = await loadAdapter(adapterModule, projectDir);
32  try {
33    if (typeof adapter.queryRecoveryRows !== 'function') {
34      throw recoveryInventoryError('target adapter must implement queryRecoveryRows(cursor)');
35    }
36    const [localeSettings, locales, schemas, contents, recoveryRows] = await Promise.all([
37      adapter.readLocaleSettings(),
38      core.collectPages((cursor) => adapter.queryLocales(cursor), 'locales'),
39      core.collectPages((cursor) => adapter.queryTranslationSchemas(cursor), 'translation schemas'),
40      core.collectPages((cursor) => adapter.queryTranslationContents(cursor), 'translation content'),
41      core.collectPages((cursor) => adapter.queryRecoveryRows(cursor), 'translation recovery rows')
42        .catch((error) => { throw recoveryInventoryError('translation recovery rows could not be inventoried', error); }),
43    ]);
44    const manifest = core.buildCapabilityManifest({ localeSettings, locales, schemas, contents, recoveryRows });
45    await core.writeJsonAtomic(path.join(projectDir, CAPABILITIES), manifest);
46    return manifest;
47  } catch (error) {
48    if (error.code === 'LANG_RECOVERY_JOURNAL_NOT_READY') await persistFailure(projectDir, error);
49    throw error;
50  }
51}
52
53async function main() {
54  const projectDir = process.argv[2] && path.resolve(process.argv[2]);
55  const adapterIndex = process.argv.indexOf('--adapter');
56  if (!projectDir || adapterIndex < 0 || !process.argv[adapterIndex + 1]) throw new Error('Usage: multilingual-inventory.js <projectDir> --adapter <module.js>');
57  const result = await run(projectDir, process.argv[adapterIndex + 1]);
58  process.stdout.write(`${JSON.stringify({ schemas: result.schemas.length, fields: result.fields.length, contents: result.contents.length })}\n`);
59}
60
61if (require.main === module) main().catch((error) => { console.error(error.message); process.exitCode = 1; });
62module.exports = { run };