import express from "express";
import { verificarFirma } from "./firmas.js";

const app = express();

app.post(
  "/webhooks/alara",
  express.raw({ type: "application/json" }),
  async (req, res) => {
    // 1. Verifica la firma sobre el cuerpo crudo
    if (!verificarFirma(req.body, req.headers, process.env.ALARA_WEBHOOK_SECRET)) {
      return res.status(401).end();
    }

    const evento = JSON.parse(req.body.toString("utf8"));
    const idEvento = req.headers["alara-webhook-id"];

    // 2. Descarta duplicados
    if (await yaProcesado(idEvento)) {
      return res.status(200).end();
    }

    // 3. Encola y responde de inmediato
    await encolar(idEvento, evento);
    res.status(200).end();

    // 4. El procesamiento ocurre en un worker aparte
  },
);