1import fs from 'fs'
2import * as _ from 'lodash-es'
3import { ptDir } from './ptDirF.mts'
4import { throPtErr } from '../sharedF/throwErrorF/sharedErrF.mts'
5import { pathDownJoin } from './pathF.mts'
6import { json1ParseCatch } from '../sharedF/jsonF.mts'
7import { isDevPc } from '../sharedF/isDevPcF.mts'
8import { throwIf } from '../sharedF/throwErrorF/throwIfF.mts'
9import { assertDefined } from '../sharedF/assertsF/assertDefinedF.mts'
10import { genContext } from './genContextF.mts'
11import type { NodePortsCfg } from '../deployF/k8sF/ctxF/klusterCtxF.mts'
12
13export type envConfType = Record<string, any> & {
14  allNodePorts?: Record<string, NodePortsCfg>
15  nodePorts?: Record<string, NodePortsCfg>
16  secretsMapping?: Record<string, string>
17  dbSecrets?: Record<string, string>
18  readonly __brand: unique symbol
19}
20
21export const tsEnvConf = <T extends Record<string, any>>(s: T): T & envConfType => s as T & envConfType
22
23export const envConfCtx = genContext<envConfType>('envConf')
24
25export const readSecretPath = (secretPath: string): string | undefined => {
26  if (!fs.existsSync(secretPath)) return
27
28  const isDir = fs.lstatSync(secretPath).isDirectory()
29  throwIf(() => isDir, {secretPath})
30
31  return _.trim(fs.readFileSync(secretPath, 'utf8'))
32}
33
34export const envConfPath = pathDownJoin(ptDir, 'data/envConf.json')
35
36export let cachedEnvConf: envConfType | undefined
37let cachedEnvConfS: string | undefined
38
39export const setEnvConf = (envConf: envConfType): boolean => {
40  const ctxStore = envConfCtx.getStore()
41  if (ctxStore) {
42    Object.assign(ctxStore, envConf)
43    return false
44  }
45  cachedEnvConf = envConf
46  cachedEnvConfS = JSON.stringify(envConf)
47  return true
48}
49
50export const getEnvConfOpt = (): envConfType | undefined => {
51  const ctxConf = envConfCtx.getStore()
52  if (ctxConf) return ctxConf
53  const envConfS = isDevPc ? process.env.ENVCONFS : (process.env.ENVCONFS || readSecretPath(envConfPath))
54  if (envConfS !== cachedEnvConfS) {
55    cachedEnvConfS = envConfS
56    if (envConfS) cachedEnvConf = undefined
57  }
58  if (cachedEnvConf) return cachedEnvConf as envConfType
59  const parsedJson = json1ParseCatch(envConfS as string)
60  if (!parsedJson) return
61  cachedEnvConf = parsedJson as envConfType
62  return cachedEnvConf
63}
64
65export const getEnvConf = (): envConfType => {
66  const envConf = getEnvConfOpt()
67  assertDefined(envConf)
68  return envConf
69}
70
71export const getEnvConfItem = (key: string): unknown => getEnvConf()[key]
72
73