Tratar cobrança na sua integração

const API = process.env.ZYNZAP_API_BASE_URL ?? "https://api.zynzap.com.br/v1";

class ZynzapError extends Error {
  constructor(status, error) {
    super(`${error.code} ${error.reason ?? ""}: ${error.message}`);
    Object.assign(this, { status, ...error });
  }
}

async function post(path, body) {
  const response = await fetch(`${API}${path}`, {
    method: "POST",
    headers: { Authorization: `Bearer ${process.env.ZYNZAP_API_KEY}`, "Content-Type": "application/json" },
    body: JSON.stringify(body),
  });
  const data = await response.json();
  if (!response.ok) throw new ZynzapError(response.status, data.error);
  return data;
}

/** Cota e executa uma operação paga. `maxMicrobrl`: teto aceito (ex.: 200000 = R$ 0,20). */
export async function quoteAndRun(method, request, { maxMicrobrl = 1_000_000 } = {}) {
  for (let attempt = 0; attempt < 2; attempt++) {
    const quote = await post("/billing/quotes", { method, request });
    if (BigInt(quote.maxMicrobrl) > BigInt(maxMicrobrl)) throw new Error(`Custo acima do teto: ${quote.maxMicrobrl}`);
    if (quote.dueCents > 0) throw new Error(`Saldo insuficiente: faltam ${quote.dueCents} centavos`);
    try {
      return await post(`/rpc/${method}`, { request, billing: { quoteId: quote.quoteId } });
    } catch (error) {
      if (error.reason === "BILLING_QUOTE_EXPIRED" && attempt === 0) continue; // cota de novo uma vez
      throw error; // inclui OUTCOME_UNCERTAIN: confira o estado antes de repetir
    }
  }
}

// Uso:
// await quoteAndRun("SendMessage", { session_id: "...", to_jid: "5511987654321", text: "Olá!" }, { maxMicrobrl: 200_000 });