Setting the file. One moment. lib/orchestration-preflight.js
lib/orchestration-preflight.js
JavaScript·143 lines·7 KB
10 woocommerce: ['WP_BASE_URL'],
11 shopify: ['SHOPIFY_STORE_URL'],
12 // CSV is a file-provided flow: source.csv.env holds only optional
13 // delimiter/encoding/vendor/rewrite hints, so no key is required. The
14 // files_only branch above enforces fileInputPaths instead.
15 csv: [],
16};
17
18function makeCheck(id, label, status, message, details = {}) {
19 return { id, label, status, message, ...details };
20}
21
22async function defaultProbeWixCli() {
23 return { available: false, authState: 'unknown', reason: 'no probe configured' };
24}
25
26function configFileForPlatform(projectDir, platform) {
27 return path.join(projectDir, 'config', `source.${platform}.env`);
28}
29
30async function runPreflight(projectDir, artifacts, options = {}) {
31 const probeWixCli = options.probeWixCli || defaultProbeWixCli;
32 const progress = options.progress || null;
33 const checks = [];
34 const decisions = artifacts.decisions || {};
35 const sourceMode = decisions.sourceMode && decisions.sourceMode.value;
36 const sourcePlatform = decisions.sourcePlatform && decisions.sourcePlatform.value;
37 const deliveryMode = decisions.deliveryMode && decisions.deliveryMode.value;
38 const targetSiteStrategy = decisions.targetSiteStrategy && decisions.targetSiteStrategy.value;
39 const fileInputPaths = decisions.fileInputPaths && decisions.fileInputPaths.value;
40 const credentialRef = decisions.sourceCredentialRef && decisions.sourceCredentialRef.value;
41
42 checks.push(
43 sourceMode
44 ? makeCheck('source_mode', 'Source acquisition mode', 'pass', `sourceMode=${sourceMode}`)
45 : makeCheck('source_mode', 'Source acquisition mode', 'blocked', 'sourceMode decision is missing'),
46 );
47 progress?.progress('Checked source acquisition mode', { phase: 'preflight', step: 'source-mode' });
48
49 if (sourceMode === 'private_data' || sourceMode === 'authenticated_api') {
50 checks.push(
51 credentialRef
52 ? makeCheck('source_credentials', 'Source credential reference', 'pass', 'credential reference present')
53 : makeCheck('source_credentials', 'Source credential reference', 'blocked', 'private/authenticated mode requires sourceCredentialRef'),
54 );
55 progress?.progress('Checked source credential reference', { phase: 'preflight', step: 'source-credentials' });
56 }
57
58 if (sourceMode === 'files_only' || (decisions.includeAdditionalFiles && decisions.includeAdditionalFiles.value === true)) {
59 const files = Array.isArray(fileInputPaths) ? fileInputPaths : [];
60 checks.push(
61 files.length > 0
62 ? makeCheck('file_inputs', 'Input files', 'pass', `${files.length} file input path(s) recorded`)
63 : makeCheck('file_inputs', 'Input files', 'blocked', 'file-based flow requires fileInputPaths'),
64 );
65 progress?.progress('Checked file inputs', { phase: 'preflight', step: 'file-inputs' });
66 }
67
68 checks.push(
69 deliveryMode
70 ? makeCheck('delivery_mode', 'Delivery mode', 'pass', `deliveryMode=${deliveryMode}`)
71 : makeCheck('delivery_mode', 'Delivery mode', 'blocked', 'deliveryMode decision is missing'),
72 );
73 checks.push(
74 targetSiteStrategy
75 ? makeCheck('target_site_strategy', 'Target site strategy', 'pass', `targetSiteStrategy=${targetSiteStrategy}`)
76 : makeCheck('target_site_strategy', 'Target site strategy', 'blocked', 'targetSiteStrategy decision is missing'),
77 );
78 progress?.progress('Checked delivery and target site decisions', { phase: 'preflight', step: 'target-decisions' });
79
80 const wixEnv = await statEnvKeys(path.join(projectDir, 'config', 'wix.env'), ['WIX_SITE_STRATEGY', 'WIX_SITE_ID', 'WIX_AUTH_TOKEN']);
81 checks.push(makeCheck('wix_env', 'Wix config file', wixEnv.exists ? 'pass' : 'blocked', wixEnv.exists ? 'wix.env exists' : 'wix.env is missing', { keyStatus: wixEnv.keys }));
82 progress?.progress('Checked Wix config file', { phase: 'preflight', step: 'wix-env' });
83
84 if (targetSiteStrategy === 'existing_site') {
85 const siteIdStatus = wixEnv.keys.WIX_SITE_ID;
86 checks.push(
87 siteIdStatus === 'present'
88 ? makeCheck('wix_site_id', 'Existing site id', 'pass', 'WIX_SITE_ID present')
89 : makeCheck('wix_site_id', 'Existing site id', 'blocked', `WIX_SITE_ID is ${siteIdStatus}`),
90 );
91 progress?.progress('Checked existing Wix site id', { phase: 'preflight', step: 'wix-site-id' });
92 }
93
94 if (sourcePlatform) {
95 const requiredSourceKeys = SOURCE_CONFIG_BY_PLATFORM[sourcePlatform] || [];
96 if (requiredSourceKeys.length > 0) {
97 const sourceEnv = await statEnvKeys(configFileForPlatform(projectDir, sourcePlatform), requiredSourceKeys);
98 const allGood = Object.values(sourceEnv.keys).every((status) => status === 'present');
99 checks.push(
100 makeCheck(
101 'source_env',
102 'Source config file',
103 allGood ? 'pass' : 'blocked',
104 sourceEnv.exists ? `checked source.${sourcePlatform}.env` : `source.${sourcePlatform}.env is missing`,
105 { keyStatus: sourceEnv.keys },
106 ),
107 );
108 progress?.progress(`Checked source ${sourcePlatform} config file`, { phase: 'preflight', step: 'source-env', entity: sourcePlatform });
109 }
110 }
111
112 progress?.progress('Wix CLI probe started', { phase: 'preflight', step: 'wix-cli' });
113 const wixCli = progress
114 ? await progress.withHeartbeat({ phase: 'preflight', step: 'wix-cli', message: 'Still probing Wix CLI' }, probeWixCli)
115 : await probeWixCli();
116 checks.push(
117 wixCli.available
118 ? makeCheck('wix_cli_available', 'Wix CLI availability', 'pass', 'Wix CLI probe succeeded', { cli: wixCli })
119 : makeCheck('wix_cli_available', 'Wix CLI availability', 'blocked', wixCli.reason || 'Wix CLI probe failed', { cli: wixCli }),
120 );
121 checks.push(
122 wixCli.authState === 'authenticated'
123 ? makeCheck('wix_cli_auth', 'Wix CLI auth state', 'pass', 'Wix CLI is authenticated', { cli: wixCli })
124 : makeCheck('wix_cli_auth', 'Wix CLI auth state', 'blocked', wixCli.reason || 'Wix CLI auth could not be confirmed', { cli: wixCli }),
125 );
126 progress?.progress('Checked Wix CLI availability and auth', { phase: 'preflight', step: 'wix-cli' });
127
128 const blocked = checks.filter((check) => check.status === 'blocked');
129 const failed = checks.filter((check) => check.status === 'failed');
130 const status = failed.length > 0 ? 'failed' : blocked.length > 0 ? 'blocked' : 'pass';
131
132 return {
133 schemaVersion: SCHEMA_VERSION,
134 status,
135 updatedAt: new Date().toISOString(),
136 checks,
137 };
138}
139
140module.exports = {
141 SCHEMA_VERSION,
142 runPreflight,
143};