Errors

import os
import time
import uuid
import requests

def error_of(resp):
    # Gateway errors can arrive without the JSON envelope.
    try:
        return resp.json()["error"]
    except (ValueError, KeyError, TypeError):
        return {"code": f"http_{resp.status_code}", "message": resp.text[:200], "request_id": None}

def post_with_retry(path, body, max_attempts=5):
    idem_key = str(uuid.uuid4())  # one key for all attempts of this request
    for attempt in range(max_attempts):
        resp = requests.post(
            f"https://api.evalezy.com/v1{path}",
            headers={
                "X-API-Key": os.environ["EVALEZY_API_KEY"],
                "Idempotency-Key": idem_key,
            },
            json=body,
            timeout=60,
        )
        retryable = resp.status_code == 429 or resp.status_code >= 500 or (
            resp.status_code == 409
            and error_of(resp)["code"] == "request_in_progress"
        )
        if not retryable:
            break
        wait = int(resp.headers.get("Retry-After", 2 ** attempt))
        time.sleep(wait)
    if resp.status_code >= 400:
        err = error_of(resp)
        raise RuntimeError(f"{err['code']}: {err['message']} (request_id {err['request_id']})")
    return resp.json()

import { randomUUID } from "node:crypto";

// Gateway errors can arrive without the JSON envelope.
async function errorOf(resp) {
  const text = await resp.clone().text();
  try {
    return JSON.parse(text).error ?? { code: `http_${resp.status}`, message: text.slice(0, 200) };
  } catch {
    return { code: `http_${resp.status}`, message: text.slice(0, 200), request_id: null };
  }
}

export async function postWithRetry(path, body, maxAttempts = 5) {
  const idemKey = randomUUID(); // one key for all attempts of this request
  let resp;
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    resp = await fetch(`https://api.evalezy.com/v1${path}`, {
      method: "POST",
      headers: {
        "X-API-Key": process.env.EVALEZY_API_KEY,
        "Idempotency-Key": idemKey,
        "Content-Type": "application/json",
      },
      body: JSON.stringify(body),
    });
    let retryable = resp.status === 429 || resp.status >= 500;
    if (resp.status === 409) {
      retryable = (await errorOf(resp)).code === "request_in_progress";
    }
    if (!retryable) break;
    const wait = Number(resp.headers.get("Retry-After") ?? 2 ** attempt);
    await new Promise((r) => setTimeout(r, wait * 1000));
  }
  if (!resp.ok) {
    const { code, message, request_id } = await errorOf(resp);
    throw new Error(`${code}: ${message} (request_id ${request_id})`);
  }
  return resp.json();
}