Inicio 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 CRUDOS, no parseados
  const signature = req.headers.get("x-signature") ?? "";
  const timestamp = req.headers.get("x-timestamp") ?? "";
 
  // La firma es sobre `${timestamp}.${raw}` — NO el body solo.
  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 });
  }
 
  // El body HTTP ES el objeto data por evento (sin envelope externo
  // estilo Stripe). El tipo de evento + delivery ID + timestamp viven en cabeceras.
  const eventType = req.headers.get("x-event") ?? "";        // p. ej. "payment.settled"
  const deliveryId = req.headers.get("idempotency-key")      // refleja X-Delivery
                   ?? req.headers.get("x-delivery") ?? "";
 
  const payload = JSON.parse(raw);
  switch (eventType) {
    case "payment.settled": {
      // El payload lleva order_id, payment_intent_id, tx_hash,
      // amount_received, confirmations, settlement token + network, etc.
      // NO incluye tu `external_ref` de la order — búscalo en el lado
      // del servidor vía order_id si necesitas mapear de vuelta.
      const { order_id, tx_hash, amount_received, confirmations } = payload;
 
      // Marca idempotentemente la order como pagada. Usa deliveryId
      // (X-Delivery) como clave de dedup: es estable a través de todos
      // los reintentos de la misma entrega. Reintentamos hasta 6 veces
      // (1m / 5m / 15m / 1h / 6h) en no-2xx.
      break;
    }
    case "checkout.expired": { /* TTL de sesión transcurrido — libera inventario */ break; }
    case "payment.refund.requested": { /* muestra en cola de admin */ break; }
    default:
      // Compatibilidad hacia adelante: podemos añadir eventos. Acepta y no-op.
  }
  return new Response("ok", { status: 200 });
}