Delivery, retries and replay

# List the dead deliveries on an endpoint
curl "https://api.surfais.com/v1/webhook-endpoints/$ENDPOINT_ID/deliveries?status=dead" \
  -H "Authorization: Bearer $SURFAIS_API_KEY"

# Replay one of them
curl -X POST "https://api.surfais.com/v1/webhook-deliveries/$DELIVERY_ID/replay" \
  -H "Authorization: Bearer $SURFAIS_API_KEY"

import os
import sys
import time

import requests

BASE_URL = "https://api.surfais.com/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['SURFAIS_API_KEY']}"}


def call(method, path, params=None):
    """Send one request. Wait and try again on 429 rate_limited."""
    while True:
        response = requests.request(method, BASE_URL + path, headers=HEADERS, params=params, timeout=30)
        if response.status_code == 429 and response.json()["error"]["code"] == "rate_limited":
            time.sleep(int(response.headers.get("Retry-After", "1")))
            continue
        return response


def dead_deliveries(endpoint_id):
    params = {"status": "dead"}
    while True:
        response = call("GET", f"/webhook-endpoints/{endpoint_id}/deliveries", params)
        response.raise_for_status()
        page = response.json()
        yield from page["data"]
        if not page["pagination"]["has_more"]:
            return
        # Continue with the cursor alone. It carries the status filter.
        params = {"cursor": page["pagination"]["next_cursor"]}


def replay(delivery_id):
    response = call("POST", f"/webhook-deliveries/{delivery_id}/replay")
    if response.status_code == 202:
        return "replayed"
    if response.status_code == 409:
        return response.json()["error"]["code"]  # delivery_in_flight or link_revoked
    response.raise_for_status()
    return f"unexpected status {response.status_code}"


if __name__ == "__main__":
    # Collect first, then replay: a replayed delivery leaves the dead list.
    for delivery in list(dead_deliveries(sys.argv[1])):
        print(delivery["id"], delivery["event_id"], delivery["last_error"], "->", replay(delivery["id"]))

const BASE_URL = "https://api.surfais.com/v1";
const HEADERS = { Authorization: `Bearer ${process.env.SURFAIS_API_KEY}` };

// Send one request. Wait and try again on 429 rate_limited.
async function call(method, path) {
  for (;;) {
    const response = await fetch(BASE_URL + path, { method, headers: HEADERS });
    const body = await response.json();
    if (response.status === 429 && body.error.code === "rate_limited") {
      const seconds = Number(response.headers.get("Retry-After") ?? "1");
      await new Promise((resolve) => setTimeout(resolve, seconds * 1000));
      continue;
    }
    return { status: response.status, body };
  }
}

async function deadDeliveries(endpointId) {
  const deliveries = [];
  let query = "?status=dead";
  for (;;) {
    const { status, body } = await call("GET", `/webhook-endpoints/${endpointId}/deliveries${query}`);
    if (status !== 200) throw new Error(`${status} ${body.error.code} (request ${body.request_id})`);
    deliveries.push(...body.data);
    if (!body.pagination.has_more) return deliveries;
    // Continue with the cursor alone. It carries the status filter.
    query = `?cursor=${encodeURIComponent(body.pagination.next_cursor)}`;
  }
}

async function replay(deliveryId) {
  const { status, body } = await call("POST", `/webhook-deliveries/${deliveryId}/replay`);
  if (status === 202) return "replayed";
  if (status === 409) return body.error.code; // delivery_in_flight or link_revoked
  throw new Error(`${status} ${body.error.code} (request ${body.request_id})`);
}

// Collect first, then replay: a replayed delivery leaves the dead list.
for (const delivery of await deadDeliveries(process.argv[2])) {
  console.log(delivery.id, delivery.event_id, delivery.last_error, "->", await replay(delivery.id));
}