Início rápido

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 BRUTOS, não parseados
  const signature = req.headers.get("x-signature") ?? "";
  const timestamp = req.headers.get("x-timestamp") ?? "";
 
  // A assinatura é sobre `${timestamp}.${raw}` — NÃO só sobre o body.
  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 });
  }
 
  // O corpo HTTP É o objeto de dados do evento (sem envelope externo
  // estilo Stripe). O tipo do evento + ID da entrega + timestamp ficam
  // nos headers.
  const eventType = req.headers.get("x-event") ?? "";        // ex.: "payment.settled"
  const deliveryId = req.headers.get("idempotency-key")      // espelha X-Delivery
                   ?? req.headers.get("x-delivery") ?? "";
 
  const payload = JSON.parse(raw);
  switch (eventType) {
    case "payment.settled": {
      // O payload traz order_id, payment_intent_id, tx_hash,
      // amount_received, confirmations, token de liquidação + rede, etc.
      // NÃO inclui o seu `external_ref` do order — busque do lado do
      // servidor via order_id se precisar fazer o mapeamento de volta.
      const { order_id, tx_hash, amount_received, confirmations } = payload;
 
      // Marque o pedido como pago de forma idempotente. Use deliveryId
      // (X-Delivery) como chave de dedup — é estável em todas as
      // retentativas da mesma entrega. A gente faz até 6 retentativas
      // (1m / 5m / 15m / 1h / 6h) em respostas que não forem 2xx.
      break;
    }
    case "checkout.expired": { /* TTL da sessão venceu — libere estoque */ break; }
    case "payment.refund.requested": { /* surface na fila de admin */ break; }
    default:
      // Compatibilidade futura: podemos adicionar eventos. Aceite e no-op.
  }
  return new Response("ok", { status: 200 });
}