Request statuses

async function waitForResults(requestId, apiKey, { timeoutMs = 300000 } = {}) {
  const deadline = Date.now() + timeoutMs;

  while (Date.now() < deadline) {
    const res = await fetch(
      `https://app.bettercontact.rocks/api/v2/async/${requestId}`,
      { headers: { "X-API-Key": apiKey } }
    );

    if (res.status === 401) throw new Error("Invalid API key");
    if (res.status === 406) throw new Error("Unknown request_id");

    const body = await res.json();

    // Branch on `status`, not on `res.ok`.
    if (body.status === "terminated") return body;
    if (body.status === "on_hold") throw new Error("Out of credits, top up to resume");

    await new Promise((r) => setTimeout(r, 5000));
  }

  throw new Error("Timed out waiting for results");
}

import time
import requests

def wait_for_results(request_id, api_key, timeout=300):
    deadline = time.time() + timeout

    while time.time() < deadline:
        res = requests.get(
            f"https://app.bettercontact.rocks/api/v2/async/{request_id}",
            headers={"X-API-Key": api_key},
        )
        if res.status_code == 401:
            raise RuntimeError("Invalid API key")
        if res.status_code == 406:
            raise RuntimeError("Unknown request_id")

        body = res.json()

        # Branch on `status`, not on the HTTP code.
        if body["status"] == "terminated":
            return body
        if body["status"] == "on_hold":
            raise RuntimeError("Out of credits, top up to resume")

        time.sleep(5)

    raise TimeoutError("Timed out waiting for results")