Delivery guarantees

# List the failed deliveries of the last 24 hours.
SINCE=$(date -u -v-24H +%Y-%m-%dT%H:%M:%SZ 2>/dev/null || date -u -d '24 hours ago' +%Y-%m-%dT%H:%M:%SZ)
curl -sS -G "https://api.isnap.ai/v1/webhooks/wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6/deliveries" \
  -H "Authorization: Bearer $ISNAP_API_KEY" \
  --data-urlencode "status=failed" \
  --data-urlencode "since=$SINCE" \
  --data-urlencode "limit=100"

# Replay one of them.
curl -sS -X POST \
  "https://api.isnap.ai/v1/webhooks/wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6/deliveries/whd_8Vc3Tq6Lx9Hn2Kb5Wm7Zd4Ry1/replay" \
  -H "Authorization: Bearer $ISNAP_API_KEY"

import { APIError, ISnapClient } from '@isnap/sdk'

const client = new ISnapClient({ apiKey: process.env.ISNAP_API_KEY ?? '', maxRetries: 2 })
const webhookId = 'wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6'
const since = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString()

// Newest first: the first record seen for an event is its latest delivery.
const latest = new Map<string, { id: string; status: string }>()
for await (const delivery of client.webhooks.deliveries(webhookId, { since, limit: 100 })) {
  if (delivery.event_id && !latest.has(delivery.event_id)) latest.set(delivery.event_id, delivery)
}

for (const delivery of latest.values()) {
  if (delivery.status !== 'failed') continue
  try {
    const replay = await client.webhooks.replay(webhookId, delivery.id)
    console.log(`replayed ${delivery.id} as ${replay.delivery_id}`)
  } catch (err) {
    // The record was deleted at the end of its retention: nothing to replay.
    if (err instanceof APIError && err.code === 'not_found') continue
    throw err
  }
}

import os
import time
from datetime import datetime, timedelta, timezone

import requests

API = "https://api.isnap.ai"
HEADERS = {"Authorization": f"Bearer {os.environ['ISNAP_API_KEY']}"}
WEBHOOK_ID = "wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6"


def get(path, params):
    """A read. Retries a 429 after Retry-After seconds, and a 500 or a 503 up to 2 times."""
    failures = 0
    while True:
        response = requests.get(f"{API}{path}", headers=HEADERS, params=params, timeout=30)
        if response.status_code == 429:
            time.sleep(int(response.headers.get("Retry-After", "60")))
            continue
        if response.status_code in (500, 503) and failures < 2:
            failures += 1
            time.sleep(2**failures)
            continue
        response.raise_for_status()
        return response.json()["data"]


since = (datetime.now(timezone.utc) - timedelta(hours=24)).strftime("%Y-%m-%dT%H:%M:%SZ")
params = {"since": since, "limit": 100}

# Newest first: the first record seen for an event is its latest delivery.
latest = {}
while True:
    page = get(f"/v1/webhooks/{WEBHOOK_ID}/deliveries", params)
    for delivery in page["items"]:
        latest.setdefault(delivery["event_id"], delivery)
    if not page["has_more"]:
        break
    params["cursor"] = page["next_cursor"]

for delivery in latest.values():
    if delivery["status"] != "failed":
        continue
    url = f"{API}/v1/webhooks/{WEBHOOK_ID}/deliveries/{delivery['id']}/replay"
    for attempt in range(3):
        response = requests.post(url, headers=HEADERS, timeout=30)
        # 503 replay_enqueue_failed: the replay was not queued. Call again, up to 2 times.
        if response.status_code != 503 or attempt == 2:
            break
        time.sleep(2 ** (attempt + 1))
    if response.status_code == 404:
        continue  # The record was deleted at the end of its retention: nothing to replay.
    response.raise_for_status()
    print("replayed", delivery["id"], "as", response.json()["data"]["delivery_id"])

curl -sS -X POST \
  "https://api.isnap.ai/v1/webhooks/wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6/rotate-secret" \
  -H "Authorization: Bearer $ISNAP_API_KEY"

import { ISnapClient } from '@isnap/sdk'

const client = new ISnapClient({ apiKey: process.env.ISNAP_API_KEY ?? '', maxRetries: 2 })

// maxRetries: 0, because a retry after a lost response would rotate the secret a second time.
const rotation = await client.webhooks.rotateSecret('wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6', { maxRetries: 0 })
console.log(`previous secret can be removed after ${rotation.old_secret_expires_at}`)
// Store rotation.secret in your secret manager now: no other call returns it.

import os

import requests

API = "https://api.isnap.ai"
HEADERS = {"Authorization": f"Bearer {os.environ['ISNAP_API_KEY']}"}

response = requests.post(
    f"{API}/v1/webhooks/wh_3Kp8Rn9Fh2Lm5Qx7Vw1Yz4Bc6/rotate-secret",
    headers=HEADERS,
    timeout=30,
)
response.raise_for_status()
rotation = response.json()["data"]
print("previous secret can be removed after", rotation["old_secret_expires_at"])
# Store rotation["secret"] in your secret manager now: no other call returns it.