1import { getSinglePod } from '../../k8sF/getSinglePodF.mts'
2import { kubeCpDown, kubeCpUp } from "../../k8sF/kubeCpF.mts"
3import { luxNow } from "../../../sharedF/timeF/luxon0NowF.mts"
4import { appCfgCtx, getAppCfg} from "../../k8sF/ctxF/appCfgCtxF.mts"
5import { eptKubeCli } from "../../k8sF/cliF/eptKubeCliF.mts"
6import { getReqKlusterCtx } from "../../k8sF/ctxF/klusterCtxF.mts"
7import { assertNonEmpty } from "../../../sharedF/assertsF/assertNonEmptyF.mts"
8import { assertDefined } from "../../../sharedF/assertsF/assertDefinedF.mts"
9import { pathDownJoin } from "../../../serverF/pathF.mts"
10import { envHome } from '../../../sharedF/isDevPcF.mts'
11import { doKubeExecCapture } from '../../k8sF/kubeExecF.mts'
12import { chalkGray, chalkGreen } from '../../../serverF/libChalkF.mts'
13
14const mbpMcSavesDir = pathDownJoin(envHome!, `/Library/Application Support/minecraft/saves`)
15const mbpMcSavesDirDisplay = `~/Library/Application Support/minecraft/saves`
16
17const worldManifestCmd = ['sh', '-c', 'cd /data/world && find . -type f -printf "%P %s %T@\\n" | sort | md5sum']
18
19export const mcbackup = async (lastRunData?: {worldHash?: string}) => {
20  const {name} = getAppCfg()
21  assertDefined(name)
22  const {cluster_name} = getReqKlusterCtx()
23
24  const podInfo = await getSinglePod({labels: {name}, cluster_name})
25  assertDefined(podInfo)
26  const {podName, containerName} = podInfo
27
28  const worldHash = await doKubeExecCapture({cmdA: worldManifestCmd, podName, containerName, isQuiet: true})
29  if (lastRunData?.worldHash && worldHash === lastRunData.worldHash) {
30    console.log(chalkGray(`world unchanged since last backup, skipping download`))
31    return lastRunData
32  }
33
34  const localWorldName = luxNow().toFormat('yyLLdd')
35
36  await kubeCpDown({podName, containerName, fromRemotePath: '/data/world/',
37    toLocalPath: pathDownJoin(mbpMcSavesDir, localWorldName)
38  })
39  console.log(chalkGreen(`world backed up (hash changed)`))
40  return {worldHash}
41}
42mcbackup.cliDescript = `backup world to ${mbpMcSavesDirDisplay}`
43
44export const mcrestore = async () => {
45  const {name} = getAppCfg()
46  assertDefined(name)
47  const {cluster_name} = getReqKlusterCtx()
48  
49  const {readdirSync} = await import('fs')
50  const backupDirs = readdirSync(mbpMcSavesDir, {withFileTypes: true})
51    .filter(dirent => dirent.isDirectory())
52    .map(dirent => dirent.name)
53    .filter(name => /^\d{6}$/.test(name))
54    .sort()
55    .reverse()
56
57  assertNonEmpty(backupDirs)
58  
59  const mostRecentBackup = backupDirs[0]
60  console.log(`Restoring from backup: ${mostRecentBackup}`)
61  
62  const podInfo = await getSinglePod({labels: {name}, cluster_name})
63  assertDefined(podInfo)
64  const {podName, containerName} = podInfo
65  
66  await kubeCpUp({
67    podName,
68    containerName,
69    fromLocalPath: `${mbpMcSavesDir}/${mostRecentBackup}/.`,
70    toRemotePath: '/data/world'
71  })
72  
73  await eptKubeCli([cluster_name, 'delete', 'pod', podName])
74  
75  console.log('Restore complete!')
76}
77mcrestore.cliDescript = `restore world from ${mbpMcSavesDirDisplay}`
78