Sincronización inicial

# 1 · Abrir el run de productos
curl -X POST https://salespilot.crossup.ai/internal/v1/connections/cn_4Kq9Xz/snapshots \
  -H "Authorization: Bearer cct_tu_clave" \
  -H "Content-Type: application/json" \
  -d '{ "entity": "item" }'
# → 201 { "run_id": "snp_7Tn2Wd" }

# 2 · Mandar una página de productos (hasta 500)
curl -X POST https://salespilot.crossup.ai/internal/v1/connections/cn_4Kq9Xz/snapshots/snp_7Tn2Wd/pages \
  -H "Authorization: Bearer cct_tu_clave" \
  -H "Content-Type: application/json" \
  -d '{
    "observations": [
      { "entity": "item", "external_id": "1001", "operation": "upsert",
        "document": { "title": { "es": "Remera negra" }, "published": true } },
      { "entity": "item", "external_id": "1002", "operation": "upsert",
        "document": { "title": { "es": "Gorra azul" }, "published": true } }
    ]
  }'
# → 200 { "results": [ { "index": 0, "status": "accepted" }, { "index": 1, "status": "accepted" } ] }

# 3 · Cerrar el run
curl -X POST https://salespilot.crossup.ai/internal/v1/connections/cn_4Kq9Xz/snapshots/snp_7Tn2Wd/close \
  -H "Authorization: Bearer cct_tu_clave"
# → 200 { "received": 2, "deleted": 0, "quarantined": 0 }

# El mismo 1 · 2 · 3 para cada entidad, en orden:
# taxonomy_node, item, variant, availability y, al final, order.

const BASE = "https://salespilot.crossup.ai";
const CONNECTION_ID = "cn_4Kq9Xz"; // tu conexión
const runs = `${BASE}/internal/v1/connections/${CONNECTION_ID}/snapshots`;
const headers = {
  Authorization: `Bearer ${process.env.CCT_KEY}`, // secreta: sólo en tu servidor
  "Content-Type": "application/json",
};
const post = (url: string, body?: unknown) =>
  fetch(url, { method: "POST", headers, body: body === undefined ? undefined : JSON.stringify(body) });

// Primero el catálogo; las órdenes históricas, al final
for (const entity of ["taxonomy_node", "item", "variant", "availability", "order"]) {
  const { run_id } = await (await post(runs, { entity })).json();
  for (const page of chunk(datos[entity], 500)) { // datos: lo que exportaste; chunk: corta de a 500
    const { results } = await (await post(`${runs}/${run_id}/pages`, { observations: page })).json();
    revisar(results);                             // uno por posición: ver abajo
  }
  await post(`${runs}/${run_id}/close`);
}