Errors

import { randomUUID } from "node:crypto";

async function call(url, options = {}, maxRetries = 4) {
  const headers = {
    Authorization: `Bearer ${process.env.ECONTRACT_API_KEY}`,
    ...options.headers,
  };
  // One key for every attempt of this request
  if (options.method === "POST" && !headers["Idempotency-Key"]) {
    headers["Idempotency-Key"] = randomUUID();
  }
  for (let attempt = 0; ; attempt++) {
    let res;
    try {
      res = await fetch(url, { ...options, headers });
    } catch (err) {
      if (attempt >= maxRetries) throw err;
      await new Promise((r) => setTimeout(r, 2 ** attempt * 1000));
      continue;
    }
    if (res.ok) return res;
    const body = await res.json().catch(() => ({}));
    const retryable =
      [429, 502, 503, 504].includes(res.status) || body.code === "IDEMPOTENCY_IN_PROGRESS";
    if (!retryable || attempt >= maxRetries) {
      throw new Error(`${res.status} ${body.code}: ${body.message} (request ${body.requestId ?? "-"})`);
    }
    const wait = Number(res.headers.get("Retry-After")) || 2 ** attempt;
    await new Promise((r) => setTimeout(r, wait * 1000));
  }
}

import os
import time
import uuid
import requests

def call(method, url, max_retries=4, **kwargs):
    headers = {"Authorization": f"Bearer {os.environ['ECONTRACT_API_KEY']}", **kwargs.pop("headers", {})}
    if method == "POST":
        headers.setdefault("Idempotency-Key", str(uuid.uuid4()))  # one key for every attempt
    for attempt in range(max_retries + 1):
        try:
            res = requests.request(method, url, headers=headers, timeout=60, **kwargs)
        except requests.RequestException:
            if attempt >= max_retries:
                raise
            time.sleep(2 ** attempt)
            continue
        if res.ok:
            return res
        body = res.json() if res.headers.get("content-type", "").startswith("application/json") else {}
        retryable = res.status_code in (429, 502, 503, 504) or body.get("code") == "IDEMPOTENCY_IN_PROGRESS"
        if not retryable or attempt >= max_retries:
            raise RuntimeError(f"{res.status_code} {body.get('code')}: {body.get('message')} (request {body.get('requestId')})")
        time.sleep(float(res.headers.get("Retry-After") or 2 ** attempt))