Paginación y sincronización incremental

{
  "data": [
    {
      "object": "lead",
      "id": "3f2b8c1e-9a4d-4e6f-b7a8-1c2d3e4f5a6b",
      "type": "person",
      "full_name": "Maria Lopez",
      "business_name": null,
      "job_title": "Operations Manager",
      "work_email": "maria.lopez@example.com",
      "personal_email": null,
      "work_phone": "+13055550142",
      "personal_phone": null,
      "company_name": "Acme Corp",
      "city": "Miami",
      "country": "United States",
      "status": "new",
      "source": "api",
      "tags": [
        "typeform",
        "spring-promo"
      ],
      "instagram_profile": null,
      "linkedin_profile_url": null,
      "website": null,
      "external_id": "crm-88412",
      "created_at": "2026-10-19T14:32:10.000Z",
      "updated_at": "2026-10-19T14:32:10.000Z"
    }
  ],
  "has_more": true,
  "next_cursor": "eyJ0IjoiMjAyNi0xMC0xOVQxNDozMjoxMC4wMDBaIiwiaSI6IjNmMmI4YzFlLTlhNGQtNGU2Zi1iN2E4LTFjMmQzZTRmNWE2YiJ9"
}

const BASE = 'https://app.spacekru.com/api/public/v1';
const headers = { Authorization: `Bearer ${process.env.SPACEKRU_API_KEY}` };

// Lists EVERY record of a resource ('leads', 'deals', 'quotes', 'orders', 'products', 'bookings'…).
async function listAll(resource, params = {}) {
  const all = [];
  let cursor = null;
  do {
    const query = new URLSearchParams({ limit: '100', ...params });
    if (cursor) query.set('cursor', cursor);
    const res = await fetch(`${BASE}/${resource}?${query}`, { headers });
    const page = await res.json();
    if (!res.ok) throw new Error(`${page.error.code}: ${page.error.message}`);
    all.push(...page.data);
    cursor = page.has_more ? page.next_cursor : null;
  } while (cursor);
  return all;
}

const leads = await listAll('leads', { updated_since: '2026-10-01T00:00:00Z' });
console.log(`${leads.length} leads changed since October 1`);

import os

import requests

BASE = "https://app.spacekru.com/api/public/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['SPACEKRU_API_KEY']}"}


def list_all(resource, **params):
    """Lists EVERY record of a resource ('leads', 'deals', 'quotes', 'orders', 'products', 'bookings'...)."""
    records, cursor = [], None
    while True:
        query = {"limit": 100, **params}
        if cursor:
            query["cursor"] = cursor
        r = requests.get(f"{BASE}/{resource}", headers=HEADERS, params=query, timeout=30)
        page = r.json()
        if not r.ok:
            raise RuntimeError(f"{page['error']['code']}: {page['error']['message']}")
        records.extend(page["data"])
        if not page["has_more"]:
            return records
        cursor = page["next_cursor"]


leads = list_all("leads", updated_since="2026-10-01T00:00:00Z")
print(f"{len(leads)} leads changed since October 1")

// Run it on a schedule (e.g. every night). `state` is wherever you keep the
// last run time: a database row, a file, a key-value store.
const startedAt = new Date().toISOString();              // 1. note the start time FIRST
const since = state.lastSync ?? '1970-01-01T00:00:00Z';

for (const resource of ['leads', 'deals', 'quotes', 'orders', 'products', 'bookings']) {
  const changed = await listAll(resource, { updated_since: since }); // 2. only what changed
  for (const record of changed) await db.upsert(resource, record.id, record); // 3. upsert by id
}

state.lastSync = startedAt;                              // 4. next run starts where this one began

curl "https://app.spacekru.com/api/public/v1/deals?status=won&updated_since=2026-10-01T00%3A00%3A00Z&limit=100" \
  -H "Authorization: Bearer $SPACEKRU_API_KEY"

const res = await fetch('https://app.spacekru.com/api/public/v1/deals?status=won&updated_since=2026-10-01T00%3A00%3A00Z&limit=100', {
  headers: {
    Authorization: `Bearer ${process.env.SPACEKRU_API_KEY}`,
  },
});
const body = await res.json();
if (!res.ok) {
  // Branch on body.error.code; quote body.error.request_id to support.
  throw new Error(`${body.error.code}: ${body.error.message} (request ${body.error.request_id})`);
}
console.log(body);

import os

import requests

r = requests.get(
    "https://app.spacekru.com/api/public/v1/deals?status=won&updated_since=2026-10-01T00%3A00%3A00Z&limit=100",
    headers={
        "Authorization": f"Bearer {os.environ['SPACEKRU_API_KEY']}",
    },
    timeout=30,
)
body = r.json()
if not r.ok:
    # Branch on body["error"]["code"]; quote body["error"]["request_id"] to support.
    raise RuntimeError(f"{body['error']['code']}: {body['error']['message']} (request {body['error']['request_id']})")
print(body)