kodadot/nft-gallery

import type { FetchError } from 'ofetch'
import { $fetch } from 'ofetch'
import consola from 'consola'
import type { Indexable, OpenSeaMetadata } from '@kodadot1/hyperdata'
import { URLS } from '../utils/constants'
import { addToQueue, processQueue } from '@/utils/queueProcessor'
import { exponentialBackoff } from '@/utils/exponentialBackoff'

const NFT_STORAGE_BASE_URL = URLS.koda.nftStorage

const nftStorageApi = $fetch.create({
  baseURL: NFT_STORAGE_BASE_URL,
})

export type PinningKey = {
  expiry: string
  token: string
}

export type Metadata = OpenSeaMetadata & Indexable

type StorageApiResponse = {
  ok: boolean
  value: {
    cid: string
    size: number
    type: string
    created: Date
  }
}

export const pinJson = async (object: Metadata) => {
  const { value } = await nftStorageApi<StorageApiResponse>('/pinJson', {
    method: 'POST',
    body: object,
  }).catch((error: FetchError) => {
    throw new Error(
      `[NFT::STORAGE] Unable to PIN JSON for reasons ${error.data}`,
    )
  })
  consola.log('[NFT::STORAGE] Pin Json')
  return value.cid
}

export const getKey = async (address: string): Promise<PinningKey> => {
  const { expiry, token } = await nftStorageApi<PinningKey>(
    `getKey/${address}`,
  ).catch((error: FetchError) => {
    throw new Error(
      `[NFT::STORAGE] Unable to GET KEY for reasons ${error.data}`,
    )
  })
  return { expiry, token }
}

export const pinFileToIPFSWithRetries = (file: Blob) =>
  exponentialBackoff(() => pinFileToIPFS(file))

export const rateLimitedPinFileToIPFS = (
  file: File,
  batchSize = 4,
  gap = 300,
): Promise<string> => {
  return new Promise((resolve, reject) => {
    addToQueue(() => pinFileToIPFSWithRetries(file).then(resolve).catch(reject))
    processQueue(batchSize, gap)
  })
}

export const pinFileToIPFS = async (file: Blob): Promise<string> => {
  // DEV: this is woraround for
  // https://github.com/kodadot/workers/issues/318
  const formData = new FormData()
  formData.append('file', file, (file as any).name)

  const { value } = await nftStorageApi<StorageApiResponse>('/pinFile', {
    method: 'POST',
    body: formData, // file,
    // headers: {
    //   'Content-Type': file.type || '*/*',
    // },
  }).catch((error: FetchError) => {
    throw new Error(
      `[NFT::STORAGE] Unable to PIN File for reasons ${error.data}`,
    )
  })
  consola.log('[NFT::STORAGE] Pin File')
  return value.cid
}

export const pinDirectory = async (files: File[]): Promise<string> => {
  const formData = new FormData()
  files.forEach(file => formData.append('file', file, file.name))

  const response = await nftStorageApi('/pinFile', {
    method: 'POST',
    body: formData,
  }).catch((error: FetchError) => {
    throw new Error(
      `[NFT::STORAGE] Unable to PIN Directory for reasons ${error.data}`,
    )
  })

  return response.value.cid
}

export default nftStorageApi