Rate Limits & Quotas

async function callWithRetry(requestFn, maxRetries = 5) {
  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    try {
      const response = await requestFn();

      if (response.status === 429) {
        const retryAfter = parseInt(response.headers.get("Retry-After") || "1", 10);
        // Exponential backoff: 1s, 2s, 4s, 8s, 16s, plus random jitter
        const jitter = Math.random() * 1000; // up to 1 extra second
        const delay = Math.min(retryAfter * 1000, (2 ** attempt) * 1000) + jitter;

        console.warn(`Rate limited. Retrying in ${Math.round(delay / 1000)}s (attempt ${attempt + 1}/${maxRetries})`);
        await new Promise(resolve => setTimeout(resolve, delay));
        continue;
      }

      return response;
    } catch (err) {
      if (attempt === maxRetries) throw err;
    }
  }
}

// Usage
const response = await callWithRetry(() =>
  fetch("https://api-partner.onecluster.co/api/v1/payments/transfer", {
    method: "POST",
    headers: {
      "Authorization": `ApiKey ${process.env.UBN_API_KEY}`,
      "Content-Type": "application/json"
    },
    body: JSON.stringify(payload)
  })
);

import time
import random
import requests

def call_with_retry(request_fn, max_retries=5):
    for attempt in range(max_retries + 1):
        response = request_fn()

        if response.status_code == 429:
            retry_after = int(response.headers.get("Retry-After", 1))
            jitter = random.uniform(0, 1)  # up to 1 extra second
            delay = min(retry_after, 2 ** attempt) + jitter

            print(f"Rate limited. Retrying in {delay:.1f}s (attempt {attempt + 1}/{max_retries})")
            time.sleep(delay)
            continue

        return response

    raise Exception("Max retries exceeded")

# Usage
import os

def make_transfer():
    return requests.post(
        "https://api-partner.onecluster.co/api/v1/payments/transfer",
        headers={
            "Authorization": f"ApiKey {os.environ['UBN_API_KEY']}",
            "Content-Type": "application/json"
        },
        json=payload
    )

response = call_with_retry(make_transfer)