Paginacja i limity zapytań

AFTER=""
while :; do
  PAGE=$(curl -s "https://app.ksefshop.pl/v1/invoices?limit=100${AFTER:+&starting_after=$AFTER}" \
    -H "Authorization: Bearer $KSEF_API_KEY")
  echo "$PAGE" | jq -r '.data[] | [.number, .ksef_number, .status] | @tsv'
  [ "$(echo "$PAGE" | jq -r .has_more)" = "true" ] || break
  AFTER=$(echo "$PAGE" | jq -r '.data[-1].id')
done

<?php
function all_invoices(): Generator
{
    $after = null;
    do {
        $query = http_build_query(array_filter(['limit' => 100, 'starting_after' => $after]));
        $ch = curl_init('https://app.ksefshop.pl/v1/invoices?' . $query);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('KSEF_API_KEY')],
        ]);
        $page = json_decode(curl_exec($ch), true);
        curl_close($ch);
        yield from $page['data'];
        $after = $page['data'] ? end($page['data'])['id'] : null;
    } while ($page['has_more']);
}

foreach (all_invoices() as $invoice) {
    echo $invoice['number'], ' ', $invoice['ksef_number'], PHP_EOL;
}

async function* allInvoices() {
  let after = null;
  while (true) {
    const url = new URL("https://app.ksefshop.pl/v1/invoices");
    url.searchParams.set("limit", "100");
    if (after) url.searchParams.set("starting_after", after);
    const res = await fetch(url, {
      headers: { Authorization: `Bearer ${process.env.KSEF_API_KEY}` },
    });
    const page = await res.json();
    if (!res.ok) throw new Error(`${page.error.code}: ${page.error.message}`);
    yield* page.data;
    if (!page.has_more) return;
    after = page.data.at(-1).id;
  }
}

for await (const invoice of allInvoices()) {
  console.log(invoice.number, invoice.ksef_number);
}

import os
import requests


def all_invoices():
    after = None
    while True:
        params = {"limit": 100}
        if after:
            params["starting_after"] = after
        page = requests.get(
            "https://app.ksefshop.pl/v1/invoices",
            headers={"Authorization": f"Bearer {os.environ['KSEF_API_KEY']}"},
            params=params,
            timeout=30,
        ).json()
        yield from page["data"]
        if not page["has_more"]:
            return
        after = page["data"][-1]["id"]


for invoice in all_invoices():
    print(invoice["number"], invoice["ksef_number"])