| import { put } from '@vercel/blob'; |
| import { NextResponse } from 'next/server'; |
| import { z } from 'zod'; |
|
|
| import { auth } from '@/app/(auth)/auth'; |
|
|
| |
| const FileSchema = z.object({ |
| file: z |
| .instanceof(Blob) |
| .refine((file) => file.size <= 5 * 1024 * 1024, { |
| message: 'File size should be less than 5MB', |
| }) |
| |
| .refine((file) => ['image/jpeg', 'image/png'].includes(file.type), { |
| message: 'File type should be JPEG or PNG', |
| }), |
| }); |
|
|
| export async function POST(request: Request) { |
| const session = await auth(); |
|
|
| if (!session) { |
| return NextResponse.json({ error: 'Unauthorized' }, { status: 401 }); |
| } |
|
|
| if (request.body === null) { |
| return new Response('Request body is empty', { status: 400 }); |
| } |
|
|
| try { |
| const formData = await request.formData(); |
| const file = formData.get('file') as Blob; |
|
|
| if (!file) { |
| return NextResponse.json({ error: 'No file uploaded' }, { status: 400 }); |
| } |
|
|
| const validatedFile = FileSchema.safeParse({ file }); |
|
|
| if (!validatedFile.success) { |
| const errorMessage = validatedFile.error.errors |
| .map((error) => error.message) |
| .join(', '); |
|
|
| return NextResponse.json({ error: errorMessage }, { status: 400 }); |
| } |
|
|
| |
| const filename = (formData.get('file') as File).name; |
| const fileBuffer = await file.arrayBuffer(); |
|
|
| try { |
| const data = await put(`${filename}`, fileBuffer, { |
| access: 'public', |
| }); |
|
|
| return NextResponse.json(data); |
| } catch (error) { |
| return NextResponse.json({ error: 'Upload failed' }, { status: 500 }); |
| } |
| } catch (error) { |
| return NextResponse.json( |
| { error: 'Failed to process request' }, |
| { status: 500 }, |
| ); |
| } |
| } |
|
|