Next.jsでCloudFlareR2の画像アップロード(FormData,pages/api)

import type { NextApiRequest, NextApiResponse } from 'next';
import { S3Client, PutObjectCommand } from '@aws-sdk/client-s3';
const { IncomingForm } = require('formidable') as any; // formidableはTSに対応していないライブラリ 
import fs from 'fs';

import { UPLOAD_PATH, BUCKET_NAME } from '../../const/constants';

const s3Client = new S3Client({
  credentials: {
    accessKeyId: process.env.CLOUDFLARE_ACCESS_KEY_ID!,
    secretAccessKey: process.env.CLOUDFLARE_SECRET_ACCESS_KEY!
  },
  endpoint: process.env.CLOUDFLARE_R2_ENDPOINT!,
  region: 'auto'
});

export const config = {
    api: {
      bodyParser: false
    }
};

export default function handler(req: NextApiRequest, res: NextApiResponse) {
    if (req.method !== 'POST') {
        res.setHeader('Allow', ['POST']);
        res.status(405).end(`Method ${req.method} Not Allowed`);
        return;
    }

    const form = new IncomingForm();

    new Promise((resolve, reject) => {
        form.parse(req, (err: any, fields: any, files: any) => {
            if (err) reject(err);
            resolve({ fields, files });
        });
    })
    .then((data: any) => handleUpload(data.fields, data.files, res))
    .catch(error => {
        console.error('Formidable error:', error);
        res.status(500).json({ error: 'Form processing error' });
    });
}



async function handleUpload(fields: any, files: any, res: NextApiResponse) {
    const fileName = fields.fileName[0];
    const contentType = fields.contentType[0];
    const file = files.file[0];

    try {
        const fileStream = fs.createReadStream(file.filepath);

        const uploadCommand = new PutObjectCommand({
            Bucket: BUCKET_NAME,
            Key: UPLOAD_PATH + fileName,
            Body: fileStream,
            ContentType: file.mimetype
        });

        await s3Client.send(uploadCommand);

        res.status(200).json({ message: 'File uploaded successfully' });
    } catch (error) {
        console.error('Error in uploadR2:', error);
        res.status(500).json({ error: 'Internal server error' });
    }
}

Body exceeded 1mb limit

module.exports = {
  api: {
    bodyParser: {
      sizeLimit: '10mb', // 10MBまでのボディサイズを許可
    },
  },
};