Idempotency

curl --request POST \
  --url "$CONNECTA_URL/messages" \
  --header "Authorization: Bearer $CONNECTA_TOKEN" \
  --header "Content-Type: application/json" \
  --header "Idempotency-Key: order-88213-confirmation" \
  --data '{
    "channelId": 4,
    "number": "5511999999999",
    "body": "Your order #88213 has been confirmed."
  }'

async function sendWithRetry(payload, key, attempts = 3) {
  for (let i = 1; i <= attempts; 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': key
        },
        body: JSON.stringify(payload)
      });

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

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

// The key comes from the domain, not from a random value per attempt.
await sendWithRetry(payload, `order-${order.id}-confirmation`);

import os, time, requests

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

        time.sleep(2**i * 0.5)

send_with_retry(payload, f"order-{order_id}-confirmation")