Pagination

async function* paginate(path, params = {}) {
  let page = 1;

  for (;;) {
    const query = new URLSearchParams({ ...params, page, perPage: 100 });
    const res = await fetch(`${process.env.CONNECTA_URL}${path}?${query}`, {
      headers: { Authorization: `Bearer ${process.env.CONNECTA_TOKEN}` }
    });

    if (!res.ok) throw new Error(`${res.status} on ${path}`);

    const { data, meta } = await res.json();
    yield* data;

    if (!meta.hasMore) return;
    page += 1;
  }
}

for await (const contact of paginate('/contacts', { search: 'silva' })) {
  console.log(contact.id, contact.name);
}

import os, requests

def paginate(path, **params):
    page = 1

    while True:
        res = requests.get(
            f"{os.environ['CONNECTA_URL']}{path}",
            params={**params, "page": page, "perPage": 100},
            headers={"Authorization": f"Bearer {os.environ['CONNECTA_TOKEN']}"},
        )
        res.raise_for_status()

        body = res.json()
        yield from body["data"]

        if not body["meta"]["hasMore"]:
            return
        page += 1

for contact in paginate("/contacts", search="silva"):
    print(contact["id"], contact["name"])

function paginate(string $path, array $params = []): iterable
{
    $page = 1;

    while (true) {
        $query = http_build_query($params + ['page' => $page, 'perPage' => 100]);
        $ch = curl_init(getenv('CONNECTA_URL') . $path . '?' . $query);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('CONNECTA_TOKEN')],
        ]);

        $body = json_decode(curl_exec($ch), true);
        yield from $body['data'];

        if (!$body['meta']['hasMore']) {
            return;
        }
        $page++;
    }
}