Erreurs

HTTP/2 422

{
  "error": {
    "code": "validation_error",
    "message": "Validation de la requête échouée.",
    "correlation_id": "c066e5d59c02489c828973115a6be1ab",
    "details": [
      { "field": "body.amount_minor", "issue": "Input should be greater than 0" },
      { "field": "body.currency", "issue": "Input should be 'CDF' or 'USD'" }
    ]
  }
}

// La MÊME Idempotency-Key à chaque tentative : une relance
// ne crée jamais un second encaissement.
async function avecRelances(envoyer, tentatives = 4) {
  for (let n = 0; ; n++) {
    let res;
    try {
      res = await envoyer(); // re-signe à chaque appel : l'horodatage change
    } catch (coupure) {
      // Réseau coupé : la requête est peut-être arrivée. La relancer
      // avec la même clé est sans risque.
      if (n >= tentatives) throw coupure;
      await attendre(2 ** n);
      continue;
    }
    if (res.ok) return res.json();
    const corps = await res.json().catch(() => null); // un 502 de proxy n'est pas du JSON
    const code = corps?.error?.code;
    const relancable =
      res.status === 429 || res.status >= 500 || code === "idempotency_in_progress";
    if (!relancable || n >= tentatives) {
      throw new Error(`${res.status} ${code} ${corps?.error?.correlation_id}`);
    }
    await attendre(Number(res.headers.get("Retry-After")) || 2 ** n);
  }
}

const attendre = (s) => new Promise((r) => setTimeout(r, s * 1000));

# La MÊME Idempotency-Key à chaque tentative : une relance
# ne crée jamais un second encaissement.
import json, time, urllib.error

def avec_relances(envoyer, tentatives=4):
    """`envoyer` re-signe à chaque appel : l'horodatage change."""
    for n in range(tentatives + 1):
        try:
            with envoyer() as resp:
                return json.load(resp)
        except urllib.error.HTTPError as e:
            try:
                erreur = json.load(e)["error"]
            except ValueError:
                erreur = {}  # un 502 de proxy n'est pas du JSON
            relancable = (e.code == 429 or e.code >= 500
                          or erreur.get("code") == "idempotency_in_progress")
            if not relancable or n == tentatives:
                raise RuntimeError(
                    f"{e.code} {erreur.get('code')} {erreur.get('correlation_id')}"
                ) from e
            time.sleep(int(e.headers.get("Retry-After") or 2 ** n))
        except urllib.error.URLError:
            # Réseau coupé : la requête est peut-être arrivée. La relancer
            # avec la même clé est sans risque.
            if n == tentatives:
                raise
            time.sleep(2 ** n)