36 lines
1.2 KiB
TypeScript
36 lines
1.2 KiB
TypeScript
|
import { NextRequest, NextResponse } from 'next/server';
|
||
|
|
import { initPaymentProviders, paymentRegistry } from '@/lib/payment';
|
||
|
|
import type { PaymentType } from '@/lib/payment';
|
||
|
|
import { handlePaymentNotify } from '@/lib/order/service';
|
||
|
|
|
||
|
|
// Stripe needs raw body - ensure Next.js doesn't parse it
|
||
|
|
export const dynamic = 'force-dynamic';
|
||
|
|
|
||
|
|
export async function POST(request: NextRequest): Promise<NextResponse> {
|
||
|
|
try {
|
||
|
|
initPaymentProviders();
|
||
|
|
const provider = paymentRegistry.getProvider('stripe' as PaymentType);
|
||
|
|
|
||
|
|
const rawBody = Buffer.from(await request.arrayBuffer());
|
||
|
|
const headers: Record<string, string> = {};
|
||
|
|
request.headers.forEach((value, key) => {
|
||
|
|
headers[key.toLowerCase()] = value;
|
||
|
|
});
|
||
|
|
|
||
|
|
const notification = await provider.verifyNotification(rawBody, headers);
|
||
|
|
if (!notification) {
|
||
|
|
// Unknown event type — acknowledge receipt
|
||
|
|
return NextResponse.json({ received: true });
|
||
|
|
}
|
||
|
|
await handlePaymentNotify(notification, provider.name);
|
||
|
|
|
||
|
|
return NextResponse.json({ received: true });
|
||
|
|
} catch (error) {
|
||
|
|
console.error('Stripe webhook error:', error);
|
||
|
|
return NextResponse.json(
|
||
|
|
{ error: 'Webhook processing failed' },
|
||
|
|
{ status: 400 },
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|