Bắt đầu nhanh

import { createHmac, timingSafeEqual } from "node:crypto";
 
const WEBHOOK_SECRET = process.env.INFRAIO_WEBHOOK_SECRET!; // whsec_…
 
export async function POST(req: Request) {
  const raw = await req.text();                    // bytes RAW, chưa parse
  const signature = req.headers.get("x-signature") ?? "";
  const timestamp = req.headers.get("x-timestamp") ?? "";
 
  // Chữ ký được tính trên `${timestamp}.${raw}` — KHÔNG phải body một mình.
  const expected = "sha256=" + createHmac("sha256", WEBHOOK_SECRET)
    .update(`${timestamp}.${raw}`)
    .digest("hex");
 
  const a = Buffer.from(signature);
  const b = Buffer.from(expected);
  if (a.length !== b.length || !timingSafeEqual(a, b)) {
    return new Response("bad signature", { status: 400 });
  }
 
  // HTTP body CHÍNH LÀ object data của event đó (không có envelope ngoài
  // kiểu Stripe). Event type + delivery ID + timestamp nằm ở header.
  const eventType = req.headers.get("x-event") ?? "";        // ví dụ "payment.settled"
  const deliveryId = req.headers.get("idempotency-key")      // đồng nghĩa với X-Delivery
                   ?? req.headers.get("x-delivery") ?? "";
 
  const payload = JSON.parse(raw);
  switch (eventType) {
    case "payment.settled": {
      // Payload mang order_id, payment_intent_id, tx_hash,
      // amount_received, confirmations, settlement token + network, v.v.
      // KHÔNG bao gồm `external_ref` từ order — bạn tra cứu phía server
      // qua order_id nếu cần ánh xạ ngược.
      const { order_id, tx_hash, amount_received, confirmations } = payload;
 
      // Đánh dấu order đã thanh toán theo cách idempotent. Dùng deliveryId
      // (X-Delivery) làm khóa dedup — nó ổn định qua mọi lần retry của
      // cùng một delivery. Chúng tôi retry tối đa 6 lần (1m / 5m / 15m /
      // 1h / 6h) khi không nhận 2xx.
      break;
    }
    case "checkout.expired": { /* session TTL hết — giải phóng tồn kho */ break; }
    case "payment.refund.requested": { /* hiển thị trong queue admin */ break; }
    default:
      // Forward-compat: chúng tôi có thể thêm event. Chấp nhận và no-op.
  }
  return new Response("ok", { status: 200 });
}