分页

PAGE=1
LIMIT=100

while : ; do
  RESP=$(curl -s "https://api.saq.processamento.com/v1/user/transactions?dateFrom=2025-11-01&page=$PAGE&limit=$LIMIT" \
    -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json")

  echo "$RESP" | jq -c '.data[]'

  HAS_NEXT=$(echo "$RESP" | jq -r '.hasNextPage')
  [ "$HAS_NEXT" != "true" ] && break
  PAGE=$((PAGE+1))
done

async function* iterateTransactions(filters: Record<string, string>) {
  let page = 1;
  const limit = 100;
  while (true) {
    const params = new URLSearchParams({ ...filters, page: String(page), limit: String(limit) });
    const res = await fetch(`https://api.saq.processamento.com/v1/user/transactions?${params}`, {
      headers: {
        Authorization: `Bearer ${process.env.SAQ_TOKEN}`,
        'Content-Type': 'application/json',
      },
    });
    const { data, hasNextPage } = await res.json();
    for (const tx of data) yield tx;
    if (!hasNextPage) return;
    page++;
  }
}

for await (const tx of iterateTransactions({ dateFrom: '2025-11-01' })) {
  await process(tx);
}

def iterate_transactions(**filters):
    page = 1
    limit = 100
    while True:
        res = requests.get(
            'https://api.saq.processamento.com/v1/user/transactions',
            params={**filters, 'page': page, 'limit': limit},
            headers={
                'Authorization': f'Bearer {os.environ["SAQ_TOKEN"]}',
                'Content-Type': 'application/json',
            },
        )
        body = res.json()
        for tx in body['data']:
            yield tx
        if not body.get('hasNextPage'):
            return
        page += 1

func IterateTransactions(filters url.Values, fn func(tx Transaction) error) error {
    page := 1
    for {
        filters.Set("page", strconv.Itoa(page))
        filters.Set("limit", "100")

        req, _ := http.NewRequest("GET",
            "https://api.saq.processamento.com/v1/user/transactions?"+filters.Encode(), nil)
        req.Header.Set("Authorization", "Bearer "+os.Getenv("SAQ_TOKEN"))
        req.Header.Set("Content-Type", "application/json")

        res, err := http.DefaultClient.Do(req)
        if err != nil { return err }

        var body struct {
            Data        []Transaction `json:"data"`
            HasNextPage bool          `json:"hasNextPage"`
        }
        if err := json.NewDecoder(res.Body).Decode(&body); err != nil {
            res.Body.Close()
            return err
        }
        res.Body.Close()

        for _, tx := range body.Data {
            if err := fn(tx); err != nil { return err }
        }
        if !body.HasNextPage { return nil }
        page++
    }
}