1import { create } from 'kubo-rpc-client'
2import { getEnvConf } from '../serverF/envConfF.mts'
3import { getPlainSecOpt } from '../serverF/secretsF/getPlainSecAI.mts'
4import { betLog } from '../sharedF/betterConsLogF.mts'
5import { isOcWeb } from '../sharedF/isDevPcF.mts'
6import { getActiveIpfsHostsForLan, primaryIpfsApiUrl, primaryIpfsGatewayUrl } from './ipfsPeersRegistryAI.mts'
7
8const filebaseApiUrl = 'https://api.filebase.io/v1/ipfs'
9const ocWebIpfsApiUrl = 'http://ipfs:5001'
10
11const getIpfsApiUrl = () => getEnvConf().ipfsApiUrl || (isOcWeb && ocWebIpfsApiUrl) || primaryIpfsApiUrl
12const getIpfsGatewayUrl = () => getEnvConf().ipfsGatewayUrl || primaryIpfsGatewayUrl
13
14export const getIpfsClient = () => create({url: getIpfsApiUrl()})
15
16export type PinTarget = {host: string, client: ReturnType<typeof create>}
17
18export const getFilebaseClient = () => {
19  return null // filebase down 2026-04-03 — re-enable when stable
20  const token = getPlainSecOpt('ipfs-filebase' as any)
21  if (!token) return null
22  return create({url: filebaseApiUrl, headers: {Authorization: `Bearer ${token}`}})
23}
24
25export const getPinTargets = async (): Promise<PinTarget[]> => {
26  const targets: PinTarget[] = [{host: new URL(getIpfsApiUrl()).hostname, client: getIpfsClient()}]
27  const fbClient = getFilebaseClient()
28  if (fbClient) targets.push({host: new URL(filebaseApiUrl).hostname, client: fbClient})
29  for (const {apiUrl} of await getActiveIpfsHostsForLan()) {
30    const host = new URL(apiUrl).hostname
31    if (!targets.some(t => t.host === host)) targets.push({host, client: create({url: apiUrl})})
32  }
33  return targets
34}
35
36export const uploadToIpfs = async (content: Buffer | Uint8Array): Promise<string> => {
37  const [primary, ...secondaries] = await getPinTargets()
38  const result = await primary.client.add(content, {chunker: 'size-1048576', pin: true})
39  const cid = result.cid.toString()
40
41  for (const {host, client} of secondaries) {
42    try { await client.pin.add(cid) }
43    catch (err) { betLog('pinFail', {host, cid, errMsg: (err as Error).message}) }
44  }
45
46  return cid
47}
48
49export const pinCid = async (cid: string) => {
50  for (const {host, client} of await getPinTargets()) {
51    try { await client.pin.add(cid) }
52    catch (err) { betLog('pinFail', {host, cid, errMsg: (err as Error).message}) }
53  }
54}
55
56export const unpinCid = async (cid: string) => {
57  for (const {host, client} of await getPinTargets()) {
58    try { await client.pin.rm(cid).catch(() => {}) }
59    catch {} // catch:userapproved
60  }
61}
62
63export const ipfsGatewayLink = (cid: string) => `${getIpfsGatewayUrl()}/${cid}`
64
65export const ipfsGatewayFetchUrl = (cid: string) => `${getIpfsGatewayUrl()}/${cid}`
66