Webhook e sincronizzazione

{
  "id": "evt_9f2c…:sub_a1b2…:prd_7788",
  "subscriptionId": "sub_a1b2…",
  "notificationType": "PRODUCT_UPDATE",
  "utcCreatedAt": "2026-09-15T10:12:00.000Z",
  "data": { "productId": "prd_7788", "optionId": "opt_1122" }
}

import express from "express";

const app = express();
app.use(express.json());
const seen = new Set(); // in produzione: tabella con chiave primaria = id della notifica

const api = (path) =>
  fetch(process.env.TAKO_API_URL + path, {
    headers: { Authorization: "Bearer " + process.env.TAKO_API_KEY },
  }).then((r) => (r.status === 404 ? null : r.json()));

app.post("/webhooks/tako", (req, res) => {
  if (req.get("authorization") !== "Bearer " + process.env.RECEIVER_SECRET) {
    return res.sendStatus(401);
  }
  const n = req.body;
  if (seen.has(n.id)) return res.sendStatus(200); // retry di Tako: già elaborata
  seen.add(n.id);
  res.sendStatus(202); // rispondi entro 5 s, poi elabora
  setImmediate(() => handle(n).catch((e) => { seen.delete(n.id); console.error(e); }));
});

async function handle({ notificationType, data }) {
  switch (notificationType) {
    case "PRODUCT_UPDATE": {
      const product = await api("/api/v1/products/" + data.productId);
      if (!product || product.status === "INACTIVE") return catalog.deactivate(data.productId);
      // options[] con units[], resourceRequirements[], availabilityPeriods[], pricingPeriods[]
      return catalog.replace(product);
    }
    case "AVAILABILITY_UPDATE": {
      // localDateStart/End sono date nel fuso del prodotto: allarga di un giorno per lato
      const from = shiftDays(data.localDateStart, -1) + "T00:00:00Z";
      const to = shiftDays(data.localDateEnd, 1) + "T23:59:59Z";
      const slots = await api(
        "/api/v1/availability?optionId=" + data.optionId + "&from=" + from + "&to=" + to,
      );
      return calendar.replace(data.optionId, from, to, slots);
    }
    case "BOOKING_UPDATE": {
      const booking = await api("/api/v1/bookings/" + data.id);
      return bookings.upsert(booking); // status, unitItems, pricingSnapshot, customer
    }
  }
}