Errors

async function call(path, opts = {}) {
  const res = await fetch(`https://api.0xinsider.com/api/v1${path}`, {
    headers: { Authorization: `Bearer ${process.env.OXINSIDER_API_KEY}` },
    ...opts,
  });
  const body = await res.json();
  if (res.ok) return body;

  const { code, message, param, reason } = body.error;
  const retryAfter = res.headers.get("retry-after");
  const scheduleInstead = reason === "pick_not_released" || reason === "monthly_quota_exceeded";
  if (code === "request_timeout" && !retryAfter) {
    throw new Error("0xinsider timed out a mutation; check its state before repeating it");
  }
  if (retryAfter && !scheduleInstead) {
    await new Promise(r => setTimeout(r, Number(retryAfter) * 1000));
    return call(path, opts);
  }
  if (reason === "cursor_expired") {
    throw new Error("cursor expired: restart from the first page");
  }
  if (code === "subscription_required") {
    throw new Error("Pro subscription required");
  }
  throw new Error(`${code}: ${message}${param ? ` (param=${param})` : ""}`);
}

import os, time, requests

BASE = "https://api.0xinsider.com/api/v1"
H = {"Authorization": f"Bearer {os.environ['OXINSIDER_API_KEY']}"}

def call(path, **params):
    r = requests.get(f"{BASE}{path}", headers=H, params=params)
    body = r.json()
    if r.ok:
        return body

    err = body["error"]
    retry_after = r.headers.get("Retry-After")
    schedule_instead = err.get("reason") in ("pick_not_released", "monthly_quota_exceeded")
    if retry_after and not schedule_instead:
        time.sleep(int(retry_after))
        return call(path, **params)
    if err.get("reason") == "cursor_expired":
        raise RuntimeError("cursor expired: restart from the first page")
    if err["code"] == "subscription_required":
        raise RuntimeError("Pro subscription required")
    raise RuntimeError(f"{err['code']}: {err['message']}")