f50a180ec4
- wxpay client: 添加 formatPublicKey() 自动包裹 PEM 头尾，修复裸 base64 公钥导致的 DECODER routines::unsupported 错误 - stripe webhook: 处理失败时返回 500 让 Stripe 重试 - 修正支付宝测试用例与实际代码对齐 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
34 lines
1.3 KiB
TypeScript
34 lines
1.3 KiB
TypeScript
import { NextRequest, NextResponse } from 'next/server';
|
|
import { paymentRegistry } from '@/lib/payment';
|
|
import type { PaymentType } from '@/lib/payment';
|
|
import { handlePaymentNotify } from '@/lib/order/service';
|
|
import { extractHeaders } from '@/lib/utils/api';
|
|
|
|
// 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 {
|
|
const provider = paymentRegistry.getProvider('stripe' as PaymentType);
|
|
|
|
const rawBody = Buffer.from(await request.arrayBuffer());
|
|
const headers = extractHeaders(request);
|
|
|
|
const notification = await provider.verifyNotification(rawBody, headers);
|
|
if (!notification) {
|
|
// Unknown event type — acknowledge receipt
|
|
return NextResponse.json({ received: true });
|
|
}
|
|
const success = await handlePaymentNotify(notification, provider.name);
|
|
|
|
if (!success) {
|
|
// 处理失败（充值未完成等），返回 500 让 Stripe 重试
|
|
return NextResponse.json({ error: 'Processing failed, will retry' }, { status: 500 });
|
|
}
|
|
return NextResponse.json({ received: true });
|
|
} catch (error) {
|
|
console.error('Stripe webhook error:', error);
|
|
return NextResponse.json({ error: 'Webhook processing failed' }, { status: 400 });
|
|
}
|
|
}
|