Sincronização inicial

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

# 2 · Enviar uma página de produtos (até 500)
curl -X POST https://salespilot.crossup.ai/internal/v1/connections/cn_4Kq9Xz/snapshots/snp_7Tn2Wd/pages \
  -H "Authorization: Bearer cct_sua_chave" \
  -H "Content-Type: application/json" \
  -d '{
    "observations": [
      { "entity": "item", "external_id": "1001", "operation": "upsert",
        "document": { "title": { "pt": "Camiseta preta" }, "published": true } },
      { "entity": "item", "external_id": "1002", "operation": "upsert",
        "document": { "title": { "pt": "Boné azul" }, "published": true } }
    ]
  }'
# → 200 { "results": [ { "index": 0, "status": "accepted" }, { "index": 1, "status": "accepted" } ] }

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

# O mesmo 1 · 2 · 3 para cada entidade, nesta ordem:
# taxonomy_node, item, variant, availability e, no final, order.

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

// Primeiro o catálogo; os pedidos históricos, no 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(dados[entity], 500)) { // dados: o que você exportou; chunk: corta de 500 em 500
    const { results } = await (await post(`${runs}/${run_id}/pages`, { observations: page })).json();
    revisar(results);                             // um por posição: veja abaixo
  }
  await post(`${runs}/${run_id}/close`);
}