请求跟踪、超时与重试

delay = min(baseDelay × 2^attempt + randomJitter, maxDelay)

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

function retryDelay(response, attempt) {
  const value = response?.headers.get("retry-after")?.trim();
  if (value) {
    const seconds = Number(value);
    if (Number.isFinite(seconds) && seconds >= 0) return seconds * 1000;
    const retryAt = Date.parse(value);
    if (Number.isFinite(retryAt)) return Math.max(0, retryAt - Date.now());
  }
  return Math.min(1000 * 2 ** attempt + Math.random() * 300, 8000);
}

async function requestWithRetry(url, options = {}, maxAttempts = 3) {
  if (!Number.isInteger(maxAttempts) || maxAttempts < 1) {
    throw new RangeError("maxAttempts must be a positive integer");
  }

  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    let response;
    try {
      response = await fetch(url, options);
    } catch (error) {
      if (options.signal?.aborted || attempt === maxAttempts - 1) throw error;
      await sleep(retryDelay(null, attempt));
      continue;
    }

    const retryable = response.status === 429 || response.status >= 500;
    if (!retryable || attempt === maxAttempts - 1) return response;

    const delay = retryDelay(response, attempt);
    await response.body?.cancel();
    await sleep(delay);
  }
}

const apiKey = process.env.APIONE_API_KEY;
if (!apiKey) throw new Error("Set APIONE_API_KEY first");
const response = await requestWithRetry("https://api.apione.ai/v1/models", {
  headers: { Authorization: `Bearer ${apiKey}` },
  signal: AbortSignal.timeout(30_000),
});
const requestIds = Object.fromEntries(
  ["X-Request-ID", "X-Maxx-Trace-Id", "X-Maxx-Request-ID"]
    .map(name => [name, response.headers.get(name)])
    .filter(([, value]) => value)
);
console.log(response.status, requestIds);
if (!response.ok) {
  throw new Error(`HTTP ${response.status}: ${await response.text()}`);
}