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();
     return { error: reason };
   }
-  return (await res.json()) as {
-    data: WebhookSummaryStats[];
-  };
+
+  return (await res.json()) as { data: WebhookLatencyStats[] };
 }

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

@@ -1,6 +1,6 @@
 "use server";
 
-import { getWebhookMetrics } from "@/api/analytics";
+import { getWebhookSummary } from "@/api/analytics";
 import type { WebhookSummaryStats } from "@/types/analytics";
 
 export async function getWebhookMetricsAction(params: {
@@ -11,6 +11,11 @@ export async function getWebhookMetricsAction(params: {
   from?: Date;
   to?: Date;
 }): Promise<WebhookSummaryStats | null> {
-  const metrics = await getWebhookMetrics(params);
-  return metrics[0] || null;
+  const result = await getWebhookSummary(params);
+
+  if ("error" in result) {
+    return null;
+  }
+
+  return result.data[0] || null;
 }

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

@@ -72,6 +72,21 @@ 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;