Ошибки

import { randomUUID } from "node:crypto";

const API_BASE = "https://api.skystream.su/app/v1";
const MAX_ATTEMPTS = 5;

const sleep = (seconds) => new Promise((resolve) => setTimeout(resolve, seconds * 1000));

export class ApiError extends Error {
  constructor(status, error) {
    super(error.message);
    this.status = status;
    this.type = error.type;
    this.code = error.code;
    this.param = error.param;
    this.requestId = error.request_id;
  }
}

/** Повторять ли запрос после такой ошибки. */
function retryable(error, method) {
  if (error.type === "rate_limit") return true;
  // Первый запрос с этим ключом ещё выполняется: дождаться его ответа.
  if (error.code === "idempotency_key_in_progress") return true;
  if (error.type !== "internal") return false;
  // internal_error изменяющего запроса сохранён под ключом: повтор вернёт его же.
  // Проверьте чтением, выполнилось ли действие.
  return method === "GET" || error.code !== "internal_error";
}

export async function api(method, path, body) {
  const idempotencyKey = method === "GET" ? null : randomUUID();

  for (let attempt = 1; ; attempt++) {
    const last = attempt === MAX_ATTEMPTS;
    let response;
    try {
      response = await fetch(`${API_BASE}${path}`, {
        method,
        headers: {
          Authorization: `Bearer ${process.env.API_KEY}`,
          ...(idempotencyKey && { "Idempotency-Key": idempotencyKey }),
          ...(body && { "Content-Type": "application/json" }),
        },
        body: body && JSON.stringify(body),
      });
    } catch (networkError) {
      // Ответа нет: запрос мог выполниться. С тем же ключом повтор безопасен.
      if (last) throw networkError;
      await sleep(2 ** attempt);
      continue;
    }

    if (response.ok) return response.json();

    const { error } = await response.json();
    if (last || !retryable(error, method)) throw new ApiError(response.status, error);
    await sleep(Number(response.headers.get("Retry-After")) || 2 ** attempt);
  }
}

try {
  const order = await api("POST", "/orders/views", { channel: "example_channel", views: 1000 });
  console.log(`Заказ ${order.id}: списано ${order.price.amount / 100} ₽`);
} catch (error) {
  if (!(error instanceof ApiError)) throw error;
  switch (error.code) {
    case "insufficient_funds":
    case "daily_spend_limit_exceeded":
      // Деньги не списаны. Повтор не поможет: нужно пополнить счёт или поднять потолок.
      break;
    case "quantity_out_of_range":
      // Пределы количества — в GET /prices.
      break;
    default:
      // Неизвестный код — по классу error.type. request_id — для поддержки.
      console.error(`${error.code}: ${error.message} (${error.requestId})`);
  }
}