Limites de requisição

async function fetchRespectingLimit(url, options, maxAttempts = 5) {
  for (let attempt = 1; attempt <= maxAttempts; attempt++) {
    const res = await fetch(url, options);

    // ritmo proativo: desacelera antes de estourar
    const remaining = Number(res.headers.get("RateLimit-Remaining") ?? 100);
    if (remaining < 10) await new Promise((r) => setTimeout(r, 1000));

    if (res.status !== 429) return res;

    const retryAfter = Number(res.headers.get("Retry-After") ?? 1);
    const jitter = Math.random() * 500;
    await new Promise((r) => setTimeout(r, retryAfter * 1000 + jitter));
  }
  throw new Error("Limite de requisições: tentativas esgotadas");
}

import os
import random
import time
import requests

def fetch_respecting_limit(url, max_attempts=5, **kwargs):
    for _ in range(max_attempts):
        res = requests.get(url, timeout=15, **kwargs)

        # ritmo proativo: desacelera antes de estourar
        if int(res.headers.get("RateLimit-Remaining", "100")) < 10:
            time.sleep(1)

        if res.status_code != 429:
            return res

        retry_after = int(res.headers.get("Retry-After", "1"))
        time.sleep(retry_after + random.random() * 0.5)

    raise RuntimeError("Limite de requisições: tentativas esgotadas")

<?php
function fetchRespectingLimit(string $url, int $maxAttempts = 5): array
{
    for ($attempt = 1; $attempt <= $maxAttempts; $attempt++) {
        $headers = [];
        $ch = curl_init($url);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('NYXPAG_API_KEY')],
            CURLOPT_HEADERFUNCTION => function ($c, $line) use (&$headers) {
                $parts = explode(':', $line, 2);
                if (count($parts) === 2) $headers[strtolower(trim($parts[0]))] = trim($parts[1]);
                return strlen($line);
            },
        ]);
        $body = curl_exec($ch);
        $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if ($status !== 429) return [$status, json_decode($body, true)];

        sleep((int) ($headers['retry-after'] ?? 1));
    }
    throw new RuntimeException('Limite de requisições: tentativas esgotadas');
}

# espera o Retry-After no 429
for i in 1 2 3 4 5; do
  CODE=$(curl -s -D /tmp/h -o /tmp/b -w "%{http_code}" \
    -H "Authorization: Bearer $NYXPAG_API_KEY" \
    https://api.nyxpag.com.br/v1/balance)
  [ "$CODE" != "429" ] && break
  sleep "$(grep -i '^retry-after:' /tmp/h | tr -d '\r' | awk '{print $2}')"
done
cat /tmp/b