Daily updates

# A variant's price changed and a product was deleted
curl -X POST https://salespilot.crossup.ai/internal/v1/connections/cn_4Kq9Xz/observations \
  -H "Authorization: Bearer cct_your_key" \
  -H "Content-Type: application/json" \
  -d '{
    "observations": [
      {
        "entity": "variant",
        "external_id": "V-100-M",
        "operation": "upsert",
        "revision": 18,
        "document": {
          "item_id": "1001",
          "sku": "TSH-BLK-M",
          "title": { "en": "Black T-shirt M" },
          "price": { "amount": "4.90", "currency": "USD" }
        }
      },
      { "entity": "item", "external_id": "1003", "operation": "delete" }
    ]
  }'
# → 200 { "results": [ { "index": 0, "status": "accepted" }, { "index": 1, "status": "accepted" } ] }

const BASE = "https://salespilot.crossup.ai";
const CONNECTION_ID = "cn_4Kq9Xz"; // your connection
const OBS = `${BASE}/internal/v1/connections/${CONNECTION_ID}/observations`;

// Call it every time something changes in your system
async function observe(observations: unknown[]) {
  const r = await fetch(OBS, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.CCT_KEY}`, // secret: only on your server
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ observations }),
  });
  const { results } = await r.json();
  return results; // one per position: accepted, unchanged, stale or quarantined
}