Webhook 事件

{
  "id": "evt_abc123",
  "type": "order.paid",
  "created_at": 1736932500000,
  "data": {
    // 事件特定数据
  }
}

{
  "id": "evt_abc123",
  "type": "order.paid",
  "created_at": 1736932500000,
  "data": {
    "order_id": "order_def456",
    "product_id": "prod_abc123",
    "customer_email": "customer@example.com",
    "amount": "9.99",
    "currency": "USD",
    "net_amount": "9.29",
    "paid_at": 1736932500000,
    "metadata": { "user_id": "u_123" }
  }
}

{
  "id": "evt_refund123",
  "type": "order.refunded",
  "created_at": 1736932600000,
  "data": {
    "order_id": "order_def456",
    "refund_id": "refund_abc123",
    "refund_status": "PARTIAL",
    "amount": "2.50",
    "currency": "USD",
    "refunded_amount": "2.50",
    "original_amount": "9.99",
    "reason": "customer_request",
    "metadata": { "user_id": "u_123" }
  }
}

app.post('/webhooks/kyren', async (req, res) => {
  // ... 先验证签名 ...

  const event = JSON.parse(req.body.toString());

  try {
    switch (event.type) {
      case 'order.paid':
        await handleOrderPaidIdempotently(event.id, event.data);
        break;
      case 'order.refunded':
        await handleOrderRefundedIdempotently(event.id, event.data);
        break;
      case 'dispute.created':
      case 'dispute.updated':
        await handleDisputeIdempotently(event.id, event.data);
        break;
      default:
        console.log(`未处理的事件类型: ${event.type}`);
    }
    res.status(200).send('OK');
  } catch (error) {
    res.status(500).send('Retry later');
  }
});