1import { enterKlusterCtxs, type KlusterCfg } from './k8sF/ctxF/klusterCtxF.mts'
2import { importMetaUrlCtx } from '../serverF/importMetaUrlCtxF.mts'
3import { appCfgCtx } from './k8sF/ctxF/appCfgCtxF.mts'
4import { getAction } from './ctxF/actionCtxF.mts'
5import { getProcArgv, getImportMetaUrlPath } from '../serverF/isDirectlyRunF.mts'
6import { absPathToPtPath } from '../serverF/pathF/absPathToPtPathF.mts'
7import { tsAbsPath, type importMetaUrlType } from '../ptDirF.mts'
8import { ptnodeBin } from './constantsF.mts'
9import { exitOnUnknownArgs } from './k8sF/isActionSupportedF.mts'
10import { cliValidatedCtx } from './ctxF/cliValidatedCtxF.mts'
11import { throPtErr } from '../sharedF/throwErrorF/sharedErrF.mts'
12import { applyCli } from './cliF/cliSchemaSetsF.mts'
13import { mkRuntests } from './testsF/runTestsCoreAI.mts'
14import { runClusterCliTestsSuite } from './testsF/cliTestsSuiteAI.mts'
15import { availActionsCtx } from './ctxF/availActionsCtxF.mts'
16import { tryDispatchAction } from './ptDeployActions/do1PtDeployActionF.mts'
17import { overwriteextdnsowner } from './hostnameF/overwriteExtDnsOwnerAI.mts'
18import { listcfdnsrecords } from './hostnameF/listCfDnsRecordsAI.mts'
19import { cfensuressl } from './hostnameF/cfEnsureSslFullAI.mts'
20import { ensurewcdnsrecords } from './hostnameF/ensureWcDnsRecordsAI.mts'
21
22const parseStepsArg = () => {
23  const stepsArg = getProcArgv().find(a => a.startsWith('--steps='))
24  return stepsArg ? stepsArg.slice(8).split(',') : null
25}
26
27export const eptClusterSync = async ({importMetaUrl, steps, extraActionsH, ...klusterCfg}: {importMetaUrl: importMetaUrlType, steps: Record<string, () => Promise<unknown>>, extraActionsH?: Record<string, (...a: any[]) => any>, cluster_name: string, [k: string]: unknown}) => {
28  importMetaUrlCtx.enterWith({importMetaUrl}) // ctx:clear
29  enterKlusterCtxs(klusterCfg as KlusterCfg, {importMetaUrl})
30  
31  if (extraActionsH) {
32    availActionsCtx.enterWith({...availActionsCtx.getStore(), ...extraActionsH})
33  }
34  
35  if (klusterCfg.cfApiKeySecretName) {
36    availActionsCtx.enterWith({...availActionsCtx.getStore(), overwriteextdnsowner, listcfdnsrecords, cfensuressl, ensurewcdnsrecords})
37  }
38  
39  const action = getAction()
40  const stepNames = Object.keys(steps)
41  const requestedSteps = parseStepsArg() ?? (action === 'delete' || action === 'help' ? null : stepNames)
42  const epPath = absPathToPtPath(tsAbsPath(getImportMetaUrlPath(importMetaUrl)))
43  
44  if (action === 'runtests') {
45    await mkRuntests({
46      allSuites: ['clitests'],
47      localAppCfg: {importMetaUrl},
48      suiteConfigs: [{name: 'clitests', runner: runClusterCliTestsSuite, deps: []}],
49    })()
50    return
51  }
52
53  if (await tryDispatchAction()) return
54
55  // help --steps=X shows step-specific help, help alone lists steps
56  if (action === 'help') {
57    if (!requestedSteps) {
58      console.log(`$ ${ptnodeBin} ${epPath} help\n`)
59      console.log(`[action] --steps=step1,step2\n\nAvailable steps: ${stepNames.join(', ')}`)
60      return
61    }
62    const invalidSteps = requestedSteps.filter(s => !steps[s])
63    if (invalidSteps.length) {
64      throPtErr('unknown steps', {invalidSteps, available: stepNames})
65    }
66    for (const name of requestedSteps) {
67      console.log(`\n--- ${name} ---`)
68      await steps[name]()
69    }
70    return
71  }
72  
73  const coreActions = ['apply', 'delete', 'info', 'help', 'runtests']
74  const isCustomAction = !coreActions.includes(action)
75  
76  if (isCustomAction) {
77    const customActionsH = availActionsCtx.getStore() || {}
78    const customAction = customActionsH[action]
79    if (customAction) {
80      if (customAction.cliSchema) exitOnUnknownArgs(customAction)
81      cliValidatedCtx.enterWith({validated: true}) // ctx:clear
82      if (typeof customAction === 'function') await customAction()
83      return
84    }
85  }
86  
87  exitOnUnknownArgs({cliSchema: {steps: {}, ...applyCli}, cliAcceptsPositional: isCustomAction})
88  
89  cliValidatedCtx.enterWith({validated: true}) // ctx:clear
90  
91  if (!requestedSteps) {
92    console.log(`Usage: ${ptnodeBin} ${epPath} ${action} --steps=step1,step2`)
93    console.log(`Available: ${stepNames.join(', ')}`)
94    return
95  }
96
97  const invalidSteps = requestedSteps.filter(s => !steps[s])
98  if (invalidSteps.length) {
99    throPtErr('unknown steps', {invalidSteps, available: stepNames})
100  }
101  
102  for (const [name, fn] of Object.entries(steps)) {
103    if (requestedSteps.includes(name)) {
104      console.log(`\n--- ${name} ---`)
105      await fn()
106    }
107  }
108}
109