feat: webhook analytics tab

Author: arcoraven

apps/dashboard/src/@/api/analytics.ts

@@ -13,6 +13,8 @@ import type {
   UserOpStats,
   WalletStats,
   WalletUserStats,
+  WebhookLatencyStats,
+  WebhookRequestStats,
   WebhookSummaryStats,
 } from "@/types/analytics";
 import { getAuthToken } from "./auth-token";
@@ -426,44 +428,56 @@ export async function getEngineCloudMethodUsage(
   return json.data as EngineCloudStats[];
 }
 
-export async function getWebhookMetrics(params: {
-  teamId: string;
-  projectId: string;
-  webhookId: string;
-  period?: "day" | "week" | "month" | "year" | "all";
-  from?: Date;
-  to?: Date;
-}): Promise<{ data: WebhookSummaryStats[] } | { error: string }> {
-  const searchParams = new URLSearchParams();
-
-  // Required params
-  searchParams.append("teamId", params.teamId);
-  searchParams.append("projectId", params.projectId);
+export async function getWebhookSummary(
+  params: AnalyticsQueryParams & { webhookId: string },
+): Promise<{ data: WebhookSummaryStats[] } | { error: string }> {
+  const searchParams = buildSearchParams(params);
   searchParams.append("webhookId", params.webhookId);
 
-  // Optional params
-  if (params.period) {
-    searchParams.append("period", params.period);
-  }
-  if (params.from) {
-    searchParams.append("from", params.from.toISOString());
+  const res = await fetchAnalytics(
+    `v2/webhook/summary?${searchParams.toString()}`,
+  );
+  if (!res.ok) {
+    const reason = await res.text();
+    return { error: reason };
   }
-  if (params.to) {
-    searchParams.append("to", params.to.toISOString());
+
+  return (await res.json()) as { data: WebhookSummaryStats[] };
+}
+
+export async function getWebhookRequests(
+  params: AnalyticsQueryParams & { webhookId?: string },
+): Promise<{ data: WebhookRequestStats[] } | { error: string }> {
+  const searchParams = buildSearchParams(params);
+  if (params.webhookId) {
+    searchParams.append("webhookId", params.webhookId);
   }
 
   const res = await fetchAnalytics(
-    `v2/webhook/summary?${searchParams.toString()}`,
-    {
-      method: "GET",
-    },
+    `v2/webhook/requests?${searchParams.toString()}`,
   );
+  if (!res.ok) {
+    const reason = await res.text();
+    return { error: reason };
+  }
 
+  return (await res.json()) as { data: WebhookRequestStats[] };
+}
+
+export async function getWebhookLatency(
+  params: AnalyticsQueryParams & { webhookId?: string },
+): Promise<{ data: WebhookLatencyStats[] } | { error: string }> {
+  const searchParams = buildSearchParams(params);
+  if (params.webhookId) {
+    searchParams.append("webhookId", params.webhookId);
+  }
+  const res = await fetchAnalytics(
+    `v2/webhook/latency?${searchParams.toString()}`,
+  );
   if (!res.ok) {
-    const reason = await res?.text();
+    const reason = await res.text();
     return { error: reason };
   }
-  return (await res.json()) as {
-    data: WebhookSummaryStats[];
-  };
+
+  return (await res.json()) as { data: WebhookLatencyStats[] };
 }

apps/dashboard/src/@/api/webhook-metrics.ts

@@ -72,14 +72,29 @@ export interface UniversalBridgeWalletStats {
   developerFeeUsdCents: number;
 }
 
+export interface WebhookRequestStats {
+  date: string;
+  webhookId: string;
+  httpStatusCode: number;
+  totalRequests: number;
+}
+
+export interface WebhookLatencyStats {
+  date: string;
+  webhookId: string;
+  p50LatencyMs: number;
+  p90LatencyMs: number;
+  p99LatencyMs: number;
+}
+
 export interface WebhookSummaryStats {
   webhookId: string;
   totalRequests: number;
   successRequests: number;
   errorRequests: number;
   successRate: number;
   avgLatencyMs: number;
-  errorBreakdown: Record<string, unknown>;
+  errorBreakdown: Record<string, number>;
 }
 
 export interface AnalyticsQueryParams {

apps/dashboard/src/@/types/analytics.ts

@@ -0,0 +1,27 @@
+"use server";
+
+import { getWebhookSummary } from "@/api/analytics";
+import type { WebhookSummaryStats } from "@/types/analytics";
+
+export async function getWebhookSummaryAction(params: {
+  teamId: string;
+  projectId: string;
+  webhookId: string;
+  period?: "day" | "week" | "month" | "year" | "all";
+  from?: Date;
+  to?: Date;
+}): Promise<WebhookSummaryStats | null> {
+  try {
+    const result = await getWebhookSummary(params);
+
+    if ("error" in result) {
+      console.error("Failed to fetch webhook summary:", result.error);
+      return null;
+    }
+
+    return result.data[0] ?? null;
+  } catch (error) {
+    console.error("Unexpected error fetching webhook summary:", error);
+    return null;
+  }
+}