Paginação

async function* paginar(caminho, params = {}) {
  let page = 1;

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

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

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

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

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

import os, requests

def paginar(caminho, **params):
    page = 1

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

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

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

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

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

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

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

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