Pagination

import time, requests

def fetch_all(path, params, api_key, connector_token):
    headers = {
        "Authorization": f"Bearer {api_key}",
        "X-Connector-Token": connector_token,
    }
    params = {**params, "page_size": 200}
    cursor, records = None, []

    while True:
        if cursor:
            params["cursor"] = cursor
        r = requests.get(f"https://api.bindbee.dev{path}",
                         params=params, headers=headers, timeout=30)

        if r.status_code == 429:
            # Wait, then retry the same cursor - don't advance
            time.sleep(float(r.headers.get("Retry-After", 1)))
            continue

        r.raise_for_status()
        body = r.json()
        records.extend(body["items"])
        cursor = body.get("cursor")
        if not cursor:
            return records

async function fetchAll(path, params, apiKey, connectorToken) {
  const records = [];
  let cursor = null;

  while (true) {
    const qs = new URLSearchParams({ ...params, page_size: "200" });
    if (cursor) qs.set("cursor", cursor);

    const res = await fetch(`https://api.bindbee.dev${path}?${qs}`, {
      headers: {
        Authorization: `Bearer ${apiKey}`,
        "X-Connector-Token": connectorToken,
      },
      signal: AbortSignal.timeout(30_000),
    });

    if (res.status === 429) {
      // Wait, then retry the same cursor - don't advance
      const wait = Number(res.headers.get("Retry-After") ?? 1);
      await new Promise((r) => setTimeout(r, wait * 1000));
      continue;
    }
    if (!res.ok) throw new Error(`${res.status}`);

    const body = await res.json();
    records.push(...body.items);
    cursor = body.cursor;
    if (!cursor) return records;
  }
}