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 == "failed" then "fix_receiver"
      elif .status == "exhausted" then "resume_webhook"
      elif .status == "pending" then "wait"
      else "done"
      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 deliveryActions = {
  delivered: "done",
  exhausted: "resume_webhook",
  failed: "fix_receiver",
  pending: "wait",
};
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: deliveryActions[delivery.status],
}));
const failedDeliveries = deliveryTriage.filter((row) => row.action === "fix_receiver");

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_actions = {
    "delivered": "done",
    "exhausted": "resume_webhook",
    "failed": "fix_receiver",
    "pending": "wait",
}
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": delivery_actions[delivery["status"]],
    }
    for delivery in data["deliveries"]
]
failed_deliveries = [
    row for row in delivery_triage if row["action"] == "fix_receiver"
]

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 {
  switch delivery.Status {
  case "failed":
    return "fix_receiver"
  case "exhausted":
    return "resume_webhook"
  case "pending":
    return "wait"
  }
  return "done"
}

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)
  }

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