Errors and rate limits

async function cativaFetch(url, options = {}, maxRetries = 5) {
  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    const res = await fetch(url, {
      ...options,
      headers: {
        Authorization: `Bearer ${process.env.CATIVA_API_KEY}`,
        ...options.headers
      }
    });

    // Success or non-retriable error: return immediately.
    const retriable = res.status === 429 || res.status >= 500;
    if (res.ok || !retriable || attempt === maxRetries) {
      return res;
    }

    // Honor Retry-After (seconds). If absent, exponential backoff with jitter.
    const retryAfter = Number(res.headers.get('retry-after'));
    const backoffMs = Number.isFinite(retryAfter) && retryAfter > 0
      ? retryAfter * 1000
      : Math.min(2 ** attempt * 500, 30_000) + Math.random() * 250;

    await new Promise(r => setTimeout(r, backoffMs));
  }
}

import os
import time
import random
import requests

def cativa_request(method, url, max_retries=5, **kwargs):
    headers = kwargs.pop("headers", {})
    headers["Authorization"] = f"Bearer {os.environ['CATIVA_API_KEY']}"

    for attempt in range(max_retries + 1):
        res = requests.request(method, url, headers=headers, **kwargs)

        retriable = res.status_code == 429 or res.status_code >= 500
        if res.ok or not retriable or attempt == max_retries:
            return res

        # Honor Retry-After (seconds). If absent, exponential backoff with jitter.
        retry_after = res.headers.get("Retry-After")
        if retry_after and retry_after.isdigit():
            delay = int(retry_after)
        else:
            delay = min(2 ** attempt * 0.5, 30) + random.uniform(0, 0.25)

        time.sleep(delay)