Twitter webhook deliveries & retry history

curl https://xquik.com/api/v1/webhooks/15/deliveries \
  -H "x-api-key: xq_YOUR_KEY_HERE" \
  | jq '[.deliveries[] | {
    delivery_id: .id,
    stream_event_id: .streamEventId,
    status,
    attempts,
    receiver_status: (.lastStatusCode // null),
    last_error: (.lastError // null),
    queued_at: .createdAt,
    delivered_at: (.deliveredAt // null),
    action: (
      if .status == "exhausted" then "page"
      elif .status == "failed" and .attempts >= 3 then "warn"
      else "track"
      end
    )
  }]'

const response = await fetch(
  "https://xquik.com/api/v1/webhooks/15/deliveries",
  {
    headers: { "x-api-key": "xq_YOUR_KEY_HERE" },
  }
);
const data = await response.json();
const deliveryTriage = data.deliveries.map((delivery) => ({
  delivery_id: delivery.id,
  stream_event_id: delivery.streamEventId,
  status: delivery.status,
  attempts: delivery.attempts,
  receiver_status: delivery.lastStatusCode ?? null,
  last_error: delivery.lastError ?? null,
  queued_at: delivery.createdAt,
  delivered_at: delivery.deliveredAt ?? null,
  action:
    delivery.status === "exhausted"
      ? "page"
      : delivery.status === "failed" && delivery.attempts >= 3
        ? "warn"
        : "track",
}));
const retryCandidates = deliveryTriage.filter((row) => row.action !== "track");

import requests

response = requests.get(
    "https://xquik.com/api/v1/webhooks/15/deliveries",
    headers={"x-api-key": "xq_YOUR_KEY_HERE"},
)
data = response.json()
delivery_triage = [
    {
        "delivery_id": delivery["id"],
        "stream_event_id": delivery["streamEventId"],
        "status": delivery["status"],
        "attempts": delivery["attempts"],
        "receiver_status": delivery.get("lastStatusCode"),
        "last_error": delivery.get("lastError"),
        "queued_at": delivery["createdAt"],
        "delivered_at": delivery.get("deliveredAt"),
        "action": "page"
        if delivery["status"] == "exhausted"
        else "warn"
        if delivery["status"] == "failed" and delivery["attempts"] >= 3
        else "track",
    }
    for delivery in data["deliveries"]
]
retry_candidates = [
    row for row in delivery_triage if row["action"] != "track"
]

package main

import (
  "encoding/json"
  "log"
  "net/http"
)

type Delivery struct {
  ID             string  `json:"id"`
  StreamEventID  string  `json:"streamEventId"`
  Status         string  `json:"status"`
  Attempts       int     `json:"attempts"`
  LastStatusCode *int    `json:"lastStatusCode"`
  LastError      *string `json:"lastError"`
  CreatedAt      string  `json:"createdAt"`
  DeliveredAt    *string `json:"deliveredAt"`
}

type DeliveriesResponse struct {
  Deliveries []Delivery `json:"deliveries"`
}

type DeliveryTriage struct {
  DeliveryID     string  `json:"delivery_id"`
  StreamEventID  string  `json:"stream_event_id"`
  Status         string  `json:"status"`
  Attempts       int     `json:"attempts"`
  ReceiverStatus *int    `json:"receiver_status"`
  LastError      *string `json:"last_error"`
  QueuedAt       string  `json:"queued_at"`
  DeliveredAt    *string `json:"delivered_at"`
  Action         string  `json:"action"`
}

func actionForDelivery(delivery Delivery) string {
  if delivery.Status == "exhausted" {
    return "page"
  }
  if delivery.Status == "failed" && delivery.Attempts >= 3 {
    return "warn"
  }
  return "track"
}

func main() {
  req, err := http.NewRequest("GET", "https://xquik.com/api/v1/webhooks/15/deliveries", nil)
  if err != nil {
    log.Fatal(err)
  }
  req.Header.Set("x-api-key", "xq_YOUR_KEY_HERE")

  resp, err := http.DefaultClient.Do(req)
  if err != nil {
    log.Fatal(err)
  }
  defer resp.Body.Close()

  var data DeliveriesResponse
  if err := json.NewDecoder(resp.Body).Decode(&data); err != nil {
    log.Fatal(err)
  }

  deliveryTriage := make([]DeliveryTriage, 0, len(data.Deliveries))
  for _, delivery := range data.Deliveries {
    row := DeliveryTriage{
      DeliveryID:     delivery.ID,
      StreamEventID:  delivery.StreamEventID,
      Status:         delivery.Status,
      Attempts:       delivery.Attempts,
      ReceiverStatus: delivery.LastStatusCode,
      LastError:      delivery.LastError,
      QueuedAt:       delivery.CreatedAt,
      DeliveredAt:    delivery.DeliveredAt,
      Action:         actionForDelivery(delivery),
    }
    deliveryTriage = append(deliveryTriage, row)
  }

  retryCandidates := make([]DeliveryTriage, 0)
  for _, row := range deliveryTriage {
    if row.Action != "track" {
      retryCandidates = append(retryCandidates, row)
    }
  }
  _ = retryCandidates
}