Idempotência

curl --request POST \
  --url "$CONNECTA_URL/messages" \
  --header "Authorization: Bearer $CONNECTA_TOKEN" \
  --header "Content-Type: application/json" \
  --header "Idempotency-Key: pedido-88213-confirmacao" \
  --data '{
    "channelId": 4,
    "number": "5511999999999",
    "body": "Seu pedido #88213 foi confirmado."
  }'

async function enviarComRetry(payload, chave, tentativas = 3) {
  for (let i = 1; i <= tentativas; i++) {
    try {
      const res = await fetch(`${process.env.CONNECTA_URL}/messages`, {
        method: 'POST',
        headers: {
          Authorization: `Bearer ${process.env.CONNECTA_TOKEN}`,
          'Content-Type': 'application/json',
          'Idempotency-Key': chave
        },
        body: JSON.stringify(payload)
      });

      if (res.ok) return res.json();
      if (res.status < 500) throw new Error(`Erro definitivo: ${res.status}`);
    } catch (err) {
      if (i === tentativas) throw err;
    }

    await new Promise((r) => setTimeout(r, 2 ** i * 500));
  }
}

// A chave vem do domínio, não de um random por tentativa.
await enviarComRetry(payload, `pedido-${pedido.id}-confirmacao`);

import os, time, requests

def enviar_com_retry(payload, chave, tentativas=3):
    for i in range(1, tentativas + 1):
        try:
            res = requests.post(
                f"{os.environ['CONNECTA_URL']}/messages",
                json=payload,
                headers={
                    "Authorization": f"Bearer {os.environ['CONNECTA_TOKEN']}",
                    "Idempotency-Key": chave,
                },
                timeout=10,
            )
            if res.ok:
                return res.json()
            if res.status_code < 500:
                res.raise_for_status()
        except requests.RequestException:
            if i == tentativas:
                raise

        time.sleep(2**i * 0.5)

enviar_com_retry(payload, f"pedido-{pedido_id}-confirmacao")