1import { backupDb } from "./dbToolsF.mts"
2import { validateWalRecency } from "./validateWalRecencyAI.mts"
3import { dbBackupCtx } from "./dbBackupCtxF.mts"
4import { decomposeForkedKubeQs } from '../../serverF/dbF/decompForkedKubeQsF.mts'
5
6export const zhongDbBackup = (qsName: string, backupBktName?: string) => {
7  const serverName = qsName.replace(/_qs$/, '')
8  return {
9    intervalSec: 60 * 60 * 24,
10    name: 'backup2db_' + qsName,
11    runFnc: async () => {
12      const {cluster_name: dbClusterName} = await decomposeForkedKubeQs({qsName})
13      dbBackupCtx.enterWith({dbClusterName})
14      await backupDb({qsName, isQuiet: true})
15      if (backupBktName) await validateWalRecency({bucket_name: backupBktName, serverName})
16    }
17  }
18}
19