Error Handling

import time
import uuid
import requests

BASE_URL = "https://api.heydollr.app"

def execute_with_retry(session_id, payment_account_id, currency, headers, max_retries=3):
    reference_id = str(uuid.uuid4())  # generate ONCE, reuse on retry
    delay = 1

    for attempt in range(max_retries):
        try:
            response = requests.post(
                f"{BASE_URL}/v1/executions/collection",
                headers=headers,
                json={
                    "session_id":         session_id,
                    "payment_account_id": payment_account_id,
                    "currency":           currency,
                    "reference_id":       reference_id,
                },
                timeout=30,
            )
            if response.status_code < 500:
                return response.json()
        except requests.RequestException:
            pass

        # Before retrying, check if the transaction already landed
        status = requests.get(
            f"{BASE_URL}/v1/status/collection/{reference_id}",
            headers=headers,
        )
        if status.ok and status.json().get("status") in ("COMPLETED", "PROCESSING"):
            return status.json()

        time.sleep(delay)
        delay *= 2  # exponential backoff

    raise Exception(f"Execution failed after {max_retries} attempts")

import { randomUUID } from "crypto";

const BASE_URL = "https://api.heydollr.app";

async function executeWithRetry(sessionId, paymentAccountId, currency, token, maxRetries = 3) {
  const referenceId = randomUUID(); // generate ONCE, reuse on retry
  let delay = 1000;

  for (let attempt = 0; attempt < maxRetries; attempt++) {
    try {
      const res = await fetch(`${BASE_URL}/v1/executions/collection`, {
        method: "POST",
        headers: { Authorization: `Bearer ${token}`, "Content-Type": "application/json" },
        body: JSON.stringify({
          session_id:         sessionId,
          payment_account_id: paymentAccountId,
          currency,
          reference_id:       referenceId,
        }),
      });
      if (res.status < 500) return res.json();
    } catch (_) {}

    // Before retrying, check if the transaction already landed
    const status = await fetch(`${BASE_URL}/v1/status/collection/${referenceId}`, {
      headers: { Authorization: `Bearer ${token}` },
    }).then(r => r.json()).catch(() => null);

    if (status?.status === "COMPLETED" || status?.status === "PROCESSING") {
      return status;
    }

    await new Promise(r => setTimeout(r, delay));
    delay *= 2; // exponential backoff
  }

  throw new Error(`Execution failed after ${maxRetries} attempts`);
}