Subchapter 45.5

Crosswalk Adopt

Execution Manifest Validate

Execution State Prepare

Expectations Ledger

169 more in the appendix

scripts/crosswalk-adopt.js

Raw file

wix/skills

scripts/crosswalk-adopt.js

JavaScript53 lines3 KB

1#!/usr/bin/env node
2'use strict';
3
4// Adopt a quick-mode crosswalk into the standard crosswalk for adopt-only import tasks.
5//
6//   node scripts/crosswalk-adopt.js --project-dir <dir> [--dry-run] [--site-id <id>]
7//       [--source <file>] [--adapter <quick adapter id>] [--bindings <json file>]
8//
9// Reads state/crosswalk/<adapter id>.json (the adapter id comes from state/quick-import-started.json),
10// takes the adopted refs and their keys from the approved mapping plan (`adopt-only-no-writes`) and the
11// execution manifest when present, and appends the missing rows to state/crosswalk/crosswalk.ndjson.
12// Idempotent; never overwrites a row. Prints ids and counts only. Exit 2 when it reports conflicts.
13
14const

crosswalk-adopt.js on GitHub

fs

=

require

(

'node:fs'

);

const path = require('node:path');

const { adoptCrosswalk, deriveBindings } = require('../lib/crosswalk-adoption.js');

function parseArgs(argv) {

const args = {};

for (let i = 0; i < argv.length; i += 1) {

if (!argv[i].startsWith('--')) throw new Error(`unexpected argument: ${argv[i]}`);

const key = argv[i].slice(2).replace(/-([a-z])/g, (_, c) => c.toUpperCase());

if (key === 'dryRun') args.dryRun = true; else { args[key] = argv[i + 1]; i += 1; }

}

return args;

}

const readJson = (file) => JSON.parse(fs.readFileSync(file, 'utf8'));

async function main() {

const args = parseArgs(process.argv.slice(2));

if (!args.projectDir) throw new Error('Usage: node scripts/crosswalk-adopt.js --project-dir <dir> [--dry-run] [--site-id <id>] [--source <file>] [--adapter <id>] [--bindings <file>]');

const projectDir = path.resolve(args.projectDir);

const started = fs.existsSync(path.join(projectDir, 'state', 'quick-import-started.json')) ? readJson(path.join(projectDir, 'state', 'quick-import-started.json')) : {};

const adapterId = args.adapter || started.adapter?.id;

if (!adapterId && !(args.source && args.bindings)) throw new Error('no quick adapter id: pass --adapter, or --source with --bindings');

const sourceFile = path.resolve(args.source || path.join(projectDir, 'state', 'crosswalk', `${adapterId}.json`));

const contractFile = path.join(__dirname, '..', 'resources', `rp-${adapterId}`, 'quick-mode.json');

const bindings = args.bindings ? readJson(path.resolve(args.bindings)) : deriveBindings(projectDir, { contract: readJson(contractFile) });

if (!bindings.length) throw new Error('no adopt-only entity in mapping/mapping-plan.json maps to a quick adapter section');

let siteId = args.siteId;

if (!siteId && !args.dryRun) {

const destination = path.join(projectDir, 'orchestration', 'destination.json');

siteId = fs.existsSync(destination) ? readJson(destination).metaSiteId : undefined;

}

const result = await adoptCrosswalk({ projectDir, sourceFile, bindings, siteId, dryRun: args.dryRun === true });

console.log(JSON.stringify({ siteId: siteId || null, ...result }, null, 2));

if (!result.ok) process.exitCode = 2;

}

main().catch((error) => {

console.error(error && error.message ? error.message : error);

process.exit(1);

});