Mantenerse al día

// Tu sistema avisa que cambió el precio de una variante
app.post("/webhooks/variante", async (req, res) => {
  const v = req.body; // la variante, como la manda tu sistema
  await observar([
    {
      entity: "variant",
      external_id: v.id,
      operation: "upsert",
      revision: v.updated_at_ms, // opcional: un número que sólo crece
      document: aCrossUp(v),     // tu función de mapeo
    },
  ]);
  res.sendStatus(200);
});

// Tu sistema no avisa, pero deja pedir lo modificado
let desde = await leerMarca(); // la última vez que preguntaste
setInterval(async () => {
  const ahora = new Date();
  const cambios = await tuSistema.variantesModificadasDesde(desde);
  for (const lote of chunk(cambios, 500)) {
    await observar(lote.map((v) => ({
      entity: "variant",
      external_id: v.id,
      operation: v.borrada ? "delete" : "upsert",
      document: v.borrada ? undefined : aCrossUp(v),
    })));
  }
  desde = ahora;
  await guardarMarca(ahora);
}, 5 * 60_000);

const OBS = `${BASE}/internal/v1/connections/${CONNECTION_ID}/observations`;

async function observar(observations: unknown[]) {
  const r = await fetch(OBS, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.CCT_KEY}`, // secreta: sólo en tu servidor
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ observations }),
  });
  const { results } = await r.json();
  return results; // uno por posición: accepted, unchanged, stale o quarantined
}