Idempotency

IDEM_KEY=$(uuidgen)  # or python3 -c "import uuid; print(uuid.uuid4())"

curl -X POST https://api.causeloop.ai/v1/issues \
  -H "Authorization: Bearer $CAUSELOOP_TOKEN" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $IDEM_KEY" \
  -d '{"title": "Payment gateway timeout", "severity": "high"}'

import { v4 as uuidv4 } from 'uuid';

const idempotencyKey = uuidv4();

async function createIssue(data, retries = 3) {
  for (let attempt = 0; attempt < retries; attempt++) {
    try {
      const resp = await fetch('https://api.causeloop.ai/v1/issues', {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${accessToken}`,
          'Content-Type': 'application/json',
          'Idempotency-Key': idempotencyKey, // same key on every retry
        },
        body: JSON.stringify(data),
      });

      if (resp.ok) {
        const replayed = resp.headers.get('Idempotency-Replayed') === 'true';
        const issue = await resp.json();
        console.log(replayed ? 'Replayed response' : 'Fresh response', issue.id);
        return issue;
      }

      if (resp.status >= 500) continue; // retry on server errors
      throw new Error(`HTTP ${resp.status}`);
    } catch (err) {
      if (attempt === retries - 1) throw err;
      await new Promise(r => setTimeout(r, 1000 * 2 ** attempt));
    }
  }
}

import uuid
import time
import requests

idempotency_key = str(uuid.uuid4())

def create_issue(data: dict, retries: int = 3):
    for attempt in range(retries):
        try:
            resp = requests.post(
                'https://api.causeloop.ai/v1/issues',
                json=data,
                headers={
                    'Authorization': f'Bearer {access_token}',
                    'Idempotency-Key': idempotency_key,  # same key on every retry
                },
            )
            if resp.ok:
                replayed = resp.headers.get('Idempotency-Replayed') == 'true'
                issue = resp.json()
                print('Replayed' if replayed else 'Fresh', issue['id'])
                return issue
            if resp.status_code >= 500:
                continue
            resp.raise_for_status()
        except requests.RequestException:
            if attempt == retries - 1:
                raise
            time.sleep(2 ** attempt)