1import { backupIpfsContent } from './ipfsBackupAI.mts'
2import { restoreIpfsContent } from './ipfsRestoreAI.mts'
3import { findAndFixOrphanedCids } from './checkIpfsPinsAI.mts'
4import { getIpfsBackupDir } from './ipfsBackupDirF.mts'
5import { betLog } from '../sharedF/betterConsLogF.mts'
6import { mkDirUnlessExist } from '../serverF/libFs/mkdirpF.mts'
7import { live2SpawnThrow } from '../serverF/childProcF/live2SpawnF.mts'
8import { dbCtx } from '../serverF/dbF/dbCtxF.mts'
9
10export const ipfsbackup = async ({db, qsName}: {db: any, qsName: string}) => {
11  const rows = await db('generic_kvs').where('key', 'like', 'ipfs_mfsroot_%').select('key', 'value')
12  const rootCids = rows.filter((r: any) => r.value).map((r: any) => ({label: r.key, cid: r.value}))
13
14  if (rootCids.length === 0) {
15    betLog('ipfsBackupNoData', {qsName})
16    return
17  }
18
19  return await backupIpfsContent({rootCids})
20}
21ipfsbackup.cliDescript = 'download all ipfs content to ~/ptdisk/ipfsbackups/<label>/'
22
23export const ipfsrestore = async ({db, qsName}: {db: any, qsName: string}) => {
24  const label = `ipfs_mfsroot_${qsName}`
25  return await restoreIpfsContent({label, db})
26}
27ipfsrestore.cliDescript = 'restore ipfs content from ~/ptdisk/ipfsbackups/<label>/'
28
29export const ipfsdir = async ({qsName}: {qsName: string}) => {
30  const label = `ipfs_mfsroot_${qsName}`
31  const dirPath = getIpfsBackupDir({label})
32  await mkDirUnlessExist(dirPath)
33  await live2SpawnThrow({cmd: `open ${dirPath}`})
34  betLog({dirPath})
35}
36ipfsdir.noWrapDbConn = true
37ipfsdir.cliDescript = 'open ~/ptdisk/ipfsbackups/<label>/ in Finder'
38
39export const fixmfs = async ({db, qsName}: {db: any, qsName: string}) => {
40  dbCtx.enterWith({db, dbKys: null})
41  return await findAndFixOrphanedCids({db, qsName})
42}
43fixmfs.cliDescript = 'find IPFS media not in MFS root and pin + add them'
44