1import { getIpfsClient, getPinTargets, pinCid, unpinCid } from './ipfsClientAI.mts'
2import { getReqKnex } from '../serverF/dbF/dbCtxF.mts'
3import { getEnvConf } from '../serverF/envConfF.mts'
4import { assertDefined } from '../sharedF/assertsF/assertDefinedF.mts'
5import { betLog } from '../sharedF/betterConsLogF.mts'
6
7export const deriveMfsParams = (appPrefix: string) => {
8  const dbQsName = getEnvConf().dbSecrets?.db
9  assertDefined(dbQsName, {appPrefix})
10  return {mfsRoot: `/${appPrefix}-${dbQsName}-ipfsmfs`, kvKey: `ipfs_mfsroot_${dbQsName}`}
11}
12
13export const deriveMfsParamsFromQs = (qsName: string) => {
14  const appPrefix = qsName.includes('donate') ? 'donateapp' : 'gamesapp'
15  return {mfsRoot: `/${appPrefix}-${qsName}-ipfsmfs`, kvKey: `ipfs_mfsroot_${qsName}`}
16}
17
18type MfsRootParams = {
19  cid: string
20  ext: string
21  mfsRoot: string
22  kvKey: string
23}
24
25export const addToIpfsMfsRoot = async ({cid, ext, mfsRoot, kvKey}: MfsRootParams): Promise<string> => {
26  const primaryClient = getIpfsClient()
27
28  await primaryClient.files.mkdir(mfsRoot, {parents: true}).catch(() => {})
29
30  const mfsPath = `${mfsRoot}/${cid}.${ext}`
31  await primaryClient.files.cp(`/ipfs/${cid}`, mfsPath).catch(() => {})
32
33  const stat = await primaryClient.files.stat(mfsRoot)
34  const newRootCid = stat.cid.toString()
35
36  const targets = await getPinTargets()
37  for (const {host, client} of targets) {
38    if (client === primaryClient) continue
39    try {
40      await client.files.mkdir(mfsRoot, {parents: true}).catch(() => {})
41      await client.files.cp(`/ipfs/${cid}`, mfsPath).catch(() => {})
42      const secondaryStat = await client.files.stat(mfsRoot)
43      const secondaryRootCid = secondaryStat.cid.toString()
44      if (secondaryRootCid !== newRootCid) {
45        betLog('mfsReplicateCidMismatch', {host, mfsRoot, primaryCid: newRootCid, secondaryCid: secondaryRootCid})
46      }
47    } catch (err) {
48      betLog('mfsReplicateFail', {host, mfsRoot, errMsg: (err as Error).message})
49    }
50  }
51
52  const db = getReqKnex()
53  const oldRoot = await db('generic_kvs').where({key: kvKey}).first()
54
55  await pinCid(newRootCid)
56  if (oldRoot?.value && oldRoot.value !== newRootCid) {
57    await unpinCid(oldRoot.value).catch(() => {})
58  }
59
60  await db('generic_kvs')
61    .insert({key: kvKey, value: newRootCid})
62    .onConflict('key')
63    .merge({value: newRootCid, updated_at: db.fn.now()})
64
65  return newRootCid
66}
67
68