penx/apps/web/pages/api/ipfs-upload.ts

import { create } from 'kubo-rpc-client'
import { NextApiRequest, NextApiResponse, PageConfig } from 'next'
import NextCors from 'nextjs-cors'

export const config: PageConfig = {
  api: {
    bodyParser: false,
  },
}

export default async function handler(
  req: NextApiRequest,
  res: NextApiResponse,
) {
  await NextCors(req, res, {
    methods: ['GET', 'HEAD', 'PUT', 'PATCH', 'POST', 'DELETE'],
    origin: '*',
    optionsSuccessStatus: 200,
  })
  if (req.method !== 'POST') {
    return res.status(405).json({ error: 'Only POST method is allowed' })
  }

  const pin = req.query?.pin === 'true' ? true : false

  // Create a buffer to store the incoming data
  const chunks: Buffer[] = []

  // Read the incoming stream
  req.on('data', (chunk) => {
    chunks.push(Buffer.from(chunk))
  })

  req.on('end', async () => {
    // Combine all chunks into a single buffer
    // TODO: handle any
    const buffer = Buffer.concat(chunks as any)

    const client = create(new URL('http://43.154.135.183:5001'))
    const { cid } = await client.add({ content: buffer }, { pin })

    res.json({
      cid: cid.toString(),
      url: `https://ipfs-gateway.spaceprotocol.xyz/ipfs/${cid.toString()}`,
    })
  })

  req.on('error', (err) => {
    console.error('Error reading request body:', err)
    res.status(500).json({ error: 'Internal Server Error' })
  })
}