Monitor Webhook Delivery Failures in Real Time

// lib/webhook-dispatcher.ts
import { logit } from "@/lib/logit";

export async function dispatchWebhook(customerId: string, endpointUrl: string, eventType: string, payload: object) {
  let statusCode: number | null = null;

  try {
    const res = await fetch(endpointUrl, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify(payload),
      signal: AbortSignal.timeout(10_000),
    });

    statusCode = res.status;
    if (!res.ok) throw new Error(`HTTP ${res.status}`);
  } catch (err) {
    const error = err instanceof Error ? err.message : String(err);

    await logit.now("webhook-failures", {
      event: "Webhook delivery failed",
      description: `${eventType} to ${new URL(endpointUrl).hostname} — ${error}`,
      icon: "📡",
      notify: false,
      tags: {
        customerId,
        eventType,
        statusCode: statusCode?.toString() ?? "timeout",
      },
      metadata: { customerId, endpointUrl, eventType, statusCode, error },
    });

    throw err;  // re-throw so your retry queue picks it up
  }
}