Idempotency

import { randomUUID } from "node:crypto";

async function createOrder(order) {
  order.idempotencyKey ??= randomUUID(); // persisted with the order before the first attempt
  for (let attempt = 1; ; attempt++) {
    try {
      const res = await fetch("https://partner.sapamoto.kz/v1/orders", {
        method: "POST",
        headers: {
          Authorization: `Bearer ${process.env.SAPA_KEY}`,
          "Content-Type": "application/json",
          "Idempotency-Key": order.idempotencyKey,
        },
        body: JSON.stringify(order.payload),
        signal: AbortSignal.timeout(10_000),
      });
      if (res.status === 409 && (await res.clone().json()).code === "idempotency_in_progress") throw new Error("retry");
      if (res.status >= 500) throw new Error(`HTTP ${res.status}`);
      return res; // 2xx or a business error — do not retry
    } catch (e) {
      if (attempt === 5) throw e;
      await new Promise((r) => setTimeout(r, 2 ** attempt * 250));
    }
  }
}

import time, uuid, requests

def create_order(order):
    order.setdefault("idempotency_key", str(uuid.uuid4()))  # persisted before the first attempt
    for attempt in range(1, 6):
        try:
            res = requests.post(
                "https://partner.sapamoto.kz/v1/orders",
                headers={"Authorization": f"Bearer {KEY}", "Idempotency-Key": order["idempotency_key"]},
                json=order["payload"],
                timeout=10,
            )
            retry = res.status_code >= 500 or (res.status_code == 409 and res.json()["code"] == "idempotency_in_progress")
            if not retry:
                return res
        except requests.RequestException:
            pass
        time.sleep(2 ** attempt * 0.25)
    raise RuntimeError("Sapa Moto is unavailable")