How to retry API calls without posting twice

import { randomUUID } from "node:crypto";

const api = "https://api.buzztake.com/v1";
const auth = { Authorization: `Bearer ${process.env.BUZZTAKE_API_KEY}` };
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

// Runs one action and returns it once it stops running. Safe to call again with the same key.
async function runAction(accountId, body, key = randomUUID()) {
  const headers = { ...auth, "Content-Type": "application/json", "Idempotency-Key": key };
  let action;
  for (let attempt = 1; !action; attempt++) {
    let res;
    try {
      res = await fetch(`${api}/accounts/${accountId}/actions`, {
        method: "POST",
        headers,
        body: JSON.stringify({ ...body, wait: 60 }),
        signal: AbortSignal.timeout(130_000),
      });
    } catch (error) {
      if (attempt === 5) throw error;
      await sleep(2 ** attempt * 1000); // No answer: send the same request and key again.
      continue;
    }
    if (res.status === 429 || res.status === 503) {
      if (attempt === 5) throw new Error(`${res.status} after 5 attempts`);
      await sleep(Number(res.headers.get("retry-after") ?? 2 ** attempt) * 1000);
      continue;
    }
    if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`); // Fix the request.
    action = await res.json();
  }
  while (action.status === "queued" || action.status === "running") {
    const res = await fetch(`${api}/actions/${action.id}?wait=60`, {
      headers: auth,
      signal: AbortSignal.timeout(130_000),
    });
    if (res.status === 429) {
      await sleep(Number(res.headers.get("retry-after") ?? 60) * 1000);
      continue;
    }
    if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
    action = await res.json();
  }
  return action; // succeeded, failed, canceled or needs_input
}

const action = await runAction(
  process.env.ACCOUNT_ID,
  { type: "post", text: "Dark mode is live." },
  "post-row-1842",
);
console.log(action.status, action.result?.url ?? action.error?.code ?? "");

import os
import time
import uuid
import requests

API = "https://api.buzztake.com/v1"
AUTH = {"Authorization": f"Bearer {os.environ['BUZZTAKE_API_KEY']}"}


def run_action(account_id, body, key=None):
    """Runs one action and returns it once it stops running. Safe to call again with the same key."""
    headers = {**AUTH, "Idempotency-Key": key or str(uuid.uuid4())}
    action = None
    for attempt in range(1, 6):
        try:
            resp = requests.post(
                f"{API}/accounts/{account_id}/actions",
                headers=headers,
                json={**body, "wait": 60},
                timeout=130,
            )
        except requests.RequestException:
            if attempt == 5:
                raise
            time.sleep(2 ** attempt)  # No answer: send the same request and key again.
            continue
        if resp.status_code in (429, 503):
            if attempt == 5:
                raise SystemExit(f"{resp.status_code} after 5 attempts")
            time.sleep(int(resp.headers.get("Retry-After", 2 ** attempt)))
            continue
        if not resp.ok:
            raise SystemExit(f"{resp.status_code}: {resp.text}")  # Fix the request.
        action = resp.json()
        break
    while action["status"] in ("queued", "running"):
        resp = requests.get(
            f"{API}/actions/{action['id']}", params={"wait": 60}, headers=AUTH, timeout=130
        )
        if resp.status_code == 429:
            time.sleep(int(resp.headers.get("Retry-After", 60)))
            continue
        if not resp.ok:
            raise SystemExit(f"{resp.status_code}: {resp.text}")
        action = resp.json()
    return action  # succeeded, failed, canceled or needs_input


action = run_action(os.environ["ACCOUNT_ID"], {"type": "post", "text": "Dark mode is live."}, "post-row-1842")
print(action["status"], (action.get("result") or {}).get("url") or (action.get("error") or {}).get("code"))