Rate limit

import { EngineApiClient, EngineApiError } from '@engineapi/sdk';

async function emitirComRetry(
  client: EngineApiClient,
  params: any,
  maxRetries = 3
) {
  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    try {
      return await client.nfe.emitir(params);
    } catch (error) {
      if (error instanceof EngineApiError && error.isRateLimited) {
        if (attempt === maxRetries) throw error;

        const waitMs = Math.pow(2, attempt) * 1000; // 1s, 2s, 4s
        console.log(`Rate limited. Retry em ${waitMs}ms...`);
        await new Promise(r => setTimeout(r, waitMs));
      } else {
        throw error; // Não é rate limit, propaga o erro
      }
    }
  }
}

import time
import httpx

def emitir_com_retry(engine, dados, max_retries=3):
    for attempt in range(max_retries + 1):
        try:
            return engine.emitir_nfe(dados)
        except httpx.HTTPStatusError as e:
            if e.response.status_code == 429:
                if attempt == max_retries:
                    raise
                wait = 2 ** attempt
                print(f"Rate limited. Retry em {wait}s...")
                time.sleep(wait)
            else:
                raise

function emitirComRetry(EngineAPI $engine, array $dados, int $maxRetries = 3): array
{
    for ($attempt = 0; $attempt <= $maxRetries; $attempt++) {
        try {
            return $engine->emitirNfe($dados);
        } catch (ClientException $e) {
            if ($e->getResponse()->getStatusCode() === 429) {
                if ($attempt === $maxRetries) throw $e;
                $wait = pow(2, $attempt);
                echo "Rate limited. Retry em {$wait}s...\n";
                sleep($wait);
            } else {
                throw $e;
            }
        }
    }
}