Request logs (dubinc#3719)

Co-authored-by: Steven Tey <stevensteel97@gmail.com>

Author: devkiran

apps/web/app/(ee)/api/appsflyer/webhook/route.ts

@@ -1,3 +1,4 @@
+import { captureWebhookLog } from "@/lib/api-logs/capture-webhook-log";
 import { trackLead } from "@/lib/api/conversions/track-lead";
 import { trackSale } from "@/lib/api/conversions/track-sale";
 import { isLocalDev } from "@/lib/api/environment";
@@ -10,7 +11,9 @@ import { isIpInRange } from "@/lib/middleware/utils/is-ip-in-range";
 import { trackLeadRequestSchema } from "@/lib/zod/schemas/leads";
 import { trackSaleRequestSchema } from "@/lib/zod/schemas/sales";
 import { prisma } from "@dub/prisma";
+import { Project } from "@dub/prisma/client";
 import { APPSFLYER_INTEGRATION_ID, getSearchParams } from "@dub/utils";
+import { waitUntil } from "@vercel/functions";
 import { NextResponse } from "next/server";
 import * as z from "zod/v4";
 
@@ -22,6 +25,14 @@ const querySchema = z.object({
 
 // GET /api/appsflyer/webhook – listen to Postback events from AppsFlyer
 export const GET = withAxiom(async (req) => {
+  const startTime = Date.now();
+  let response = "OK";
+  let queryParams: Record<string, string> | null = null;
+  let workspace: Pick<
+    Project,
+    "id" | "stripeConnectId" | "webhookEnabled"
+  > | null = null;
+
   try {
     if (!isLocalDev) {
       const ip = await getIP();
@@ -37,7 +48,7 @@ export const GET = withAxiom(async (req) => {
       }
     }
 
-    const queryParams = getSearchParams(req.url);
+    queryParams = getSearchParams(req.url);
 
     const { appId, partnerEventId } = querySchema.parse(queryParams);
 
@@ -72,6 +83,8 @@ export const GET = withAxiom(async (req) => {
       });
     }
 
+    workspace = installation.project;
+
     // Track lead event
     if (partnerEventId === "lead") {
       const {
@@ -93,15 +106,15 @@ export const GET = withAxiom(async (req) => {
         eventQuantity: undefined,
         mode: undefined,
         metadata: null,
-        workspace: installation.project,
+        workspace,
         rawBody: queryParams,
       });
 
-      return NextResponse.json("Lead event tracked successfully.");
+      response = "Lead event tracked successfully.";
     }
 
     // Track sale event
-    if (partnerEventId === "sale") {
+    else if (partnerEventId === "sale") {
       const amountInCents = appsflyerAmountToDubCents(queryParams.amount);
       const { eventName, customerExternalId, amount, currency, invoiceId } =
         trackSaleRequestSchema.parse({
@@ -118,16 +131,46 @@ export const GET = withAxiom(async (req) => {
         invoiceId,
         leadEventName: undefined,
         metadata: null,
-        workspace: installation.project,
+        workspace,
         rawBody: queryParams,
       });
 
-      return NextResponse.json("Sale event tracked successfully.");
+      response = "Sale event tracked successfully.";
     }
 
-    return NextResponse.json("OK");
+    waitUntil(
+      captureWebhookLog({
+        workspaceId: workspace.id,
+        method: req.method,
+        path: "/api/appsflyer/webhook",
+        statusCode: 200,
+        duration: Date.now() - startTime,
+        requestBody: queryParams,
+        responseBody: response,
+        userAgent: req.headers.get("user-agent"),
+      }),
+    );
+
+    return NextResponse.json(response);
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    const errorResponse = handleAndReturnErrorResponse(error);
+
+    if (workspace) {
+      waitUntil(
+        captureWebhookLog({
+          workspaceId: workspace.id,
+          method: req.method,
+          path: "/api/appsflyer/webhook",
+          statusCode: errorResponse.status,
+          duration: Date.now() - startTime,
+          requestBody: queryParams,
+          responseBody: errorResponse,
+          userAgent: req.headers.get("user-agent"),
+        }),
+      );
+    }
+
+    return errorResponse;
   }
 });
 

apps/web/app/(ee)/api/stripe/integration/webhook/account-application-deauthorized.ts

@@ -11,7 +11,9 @@ export async function accountApplicationDeauthorized(
   const stripeAccountId = event.account;
 
   if (mode === "test") {
-    return `Stripe Connect account ${stripeAccountId} deauthorized in test mode. Skipping...`;
+    return {
+      response: `Stripe Connect account ${stripeAccountId} deauthorized in test mode. Skipping...`,
+    };
   }
 
   const workspace = await prisma.project.findUnique({
@@ -24,7 +26,9 @@ export async function accountApplicationDeauthorized(
   });
 
   if (!workspace) {
-    return `Stripe Connect account ${stripeAccountId} deauthorized.`;
+    return {
+      response: `Workspace not found for Stripe account ${stripeAccountId}, skipping...`,
+    };
   }
 
   await prisma.project.update({
@@ -46,5 +50,8 @@ export async function accountApplicationDeauthorized(
     },
   });
 
-  return `Stripe Connect account ${stripeAccountId} deauthorized for workspace ${workspace.id}`;
+  return {
+    response: `Stripe Connect account ${stripeAccountId} deauthorized for workspace ${workspace.id}`,
+    workspaceId: workspace.id,
+  };
 }

apps/web/app/(ee)/api/stripe/integration/webhook/charge-refunded.ts

@@ -31,7 +31,9 @@ export async function chargeRefunded(event: Stripe.Event, mode: StripeMode) {
     invoicePayments.data.length > 0 ? invoicePayments.data[0] : null;
 
   if (!invoicePayment || !invoicePayment.invoice) {
-    return `Charge ${charge.id} has no invoice, skipping...`;
+    return {
+      response: `Charge ${charge.id} has no invoice, skipping...`,
+    };
   }
 
   const workspace = await prisma.project.findUnique({
@@ -45,11 +47,18 @@ export async function chargeRefunded(event: Stripe.Event, mode: StripeMode) {
   });
 
   if (!workspace) {
-    return `Workspace not found for stripe account ${stripeAccountId}`;
+    return {
+      response: `Workspace not found for Stripe account ${stripeAccountId}, skipping...`,
+    };
   }
 
+  const workspaceId = workspace.id;
+
   if (!workspace.programs.length) {
-    return `Workspace ${workspace.id} for stripe account ${stripeAccountId} has no programs, skipping...`;
+    return {
+      response: `Workspace ${workspaceId} for stripe account ${stripeAccountId} has no programs, skipping...`,
+      workspaceId,
+    };
   }
 
   const commission = await prisma.commission.findUnique({
@@ -71,11 +80,17 @@ export async function chargeRefunded(event: Stripe.Event, mode: StripeMode) {
   });
 
   if (!commission) {
-    return `Commission not found for invoice ${invoicePayment.invoice}`;
+    return {
+      response: `Commission not found for invoice ${invoicePayment.invoice}`,
+      workspaceId,
+    };
   }
 
   if (commission.status === "paid") {
-    return `Commission ${commission.id} is already paid, skipping...`;
+    return {
+      response: `Commission ${commission.id} is already paid, skipping...`,
+      workspaceId,
+    };
   }
 
   // if the commission is processed and has a payout, we need to update the payout total
@@ -122,5 +137,8 @@ export async function chargeRefunded(event: Stripe.Event, mode: StripeMode) {
     newStatus: "refunded",
   });
 
-  return `Commission ${commission.id} updated to status "refunded"`;
+  return {
+    response: `Commission ${commission.id} updated to status "refunded"`,
+    workspaceId,
+  };
 }

apps/web/app/(ee)/api/stripe/integration/webhook/checkout-session-completed.ts

@@ -27,9 +27,9 @@ import { Customer, Project } from "@dub/prisma/client";
 import { COUNTRIES_TO_CONTINENTS, nanoid, pick } from "@dub/utils";
 import { waitUntil } from "@vercel/functions";
 import type Stripe from "stripe";
+import { getCheckoutSessionProductId } from "./utils/get-checkout-session-product-id";
 import { getConnectedCustomer } from "./utils/get-connected-customer";
 import { getPromotionCode } from "./utils/get-promotion-code";
-import { getCheckoutSessionProductId } from "./utils/get-checkout-session-product-id";
 import { updateCustomerWithStripeCustomerId } from "./utils/update-customer-with-stripe-customer-id";
 
 // Handle event "checkout.session.completed"
@@ -70,7 +70,9 @@ export async function checkoutSessionCompleted(
   });
 
   if (!workspace) {
-    return `Workspace with stripeConnectId ${stripeAccountId} not found, skipping...`;
+    return {
+      response: `Workspace not found for Stripe account ${stripeAccountId}, skipping...`,
+    };
   }
 
   /*
@@ -85,7 +87,10 @@ export async function checkoutSessionCompleted(
     clickEvent = await getClickEvent({ clickId: dubClickId });
 
     if (!clickEvent) {
-      return `Click event with dub_id ${dubClickId} not found, skipping...`;
+      return {
+        response: `Click event with dub_id ${dubClickId} not found, skipping...`,
+        workspaceId: workspace.id,
+      };
     }
 
     existingCustomer = await prisma.customer.findFirst({
@@ -199,10 +204,16 @@ export async function checkoutSessionCompleted(
           if (promoCodeResponse) {
             ({ linkId, customer, clickEvent, leadEvent } = promoCodeResponse);
           } else {
-            return `Failed to attribute via promotion code ${promotionCodeId}, skipping...`;
+            return {
+              response: `Failed to attribute via promotion code ${promotionCodeId}, skipping...`,
+              workspaceId: workspace.id,
+            };
           }
         } else {
-          return `dubCustomerExternalId was provided but customer with dubCustomerExternalId ${dubCustomerExternalId} not found on Dub, skipping...`;
+          return {
+            response: `dubCustomerExternalId was provided but customer with dubCustomerExternalId ${dubCustomerExternalId} not found on Dub, skipping...`,
+            workspaceId: workspace.id,
+          };
         }
       }
     } else {
@@ -247,7 +258,10 @@ export async function checkoutSessionCompleted(
             stripeCustomerId,
           });
           if (!customer) {
-            return `dubCustomerExternalId was found on the connected customer ${stripeCustomerId} but customer with dubCustomerExternalId ${dubCustomerExternalId} not found on Dub, skipping...`;
+            return {
+              response: `dubCustomerExternalId was found on the connected customer ${stripeCustomerId} but customer with dubCustomerExternalId ${dubCustomerExternalId} not found on Dub, skipping...`,
+              workspaceId: workspace.id,
+            };
           }
         } else if (promotionCodeId) {
           const promoCodeResponse = await attributeViaPromoCode({
@@ -260,10 +274,16 @@ export async function checkoutSessionCompleted(
           if (promoCodeResponse) {
             ({ linkId, customer, clickEvent, leadEvent } = promoCodeResponse);
           } else {
-            return `Failed to attribute via promotion code ${promotionCodeId}, skipping...`;
+            return {
+              response: `Failed to attribute via promotion code ${promotionCodeId}, skipping...`,
+              workspaceId: workspace.id,
+            };
           }
         } else {
-          return `dubCustomerExternalId not found in Stripe checkout session metadata (nor is it available on the connected customer ${stripeCustomerId}), client_reference_id is not a dub_id, and promotion code is not provided, skipping...`;
+          return {
+            response: `dubCustomerExternalId not found in Stripe checkout session metadata (nor is it available on the connected customer ${stripeCustomerId}), client_reference_id is not a dub_id, and promotion code is not provided, skipping...`,
+            workspaceId: workspace.id,
+          };
         }
       }
     }
@@ -272,7 +292,10 @@ export async function checkoutSessionCompleted(
     if (!leadEvent) {
       const leadEventData = await getLeadEvent({ customerId: customer.id });
       if (!leadEventData) {
-        return `No lead event found for customer ${customer.id}, skipping...`;
+        return {
+          response: `No lead event found for customer ${customer.id}, skipping...`,
+          workspaceId: workspace.id,
+        };
       }
       leadEvent = {
         ...leadEventData,
@@ -281,23 +304,35 @@ export async function checkoutSessionCompleted(
       linkId = leadEvent.link_id;
     }
   } else {
-    return "No stripeCustomerId or dubCustomerExternalId found in Stripe checkout session metadata, skipping...";
+    return {
+      response: `No stripeCustomerId or dubCustomerExternalId found in Stripe checkout session metadata, skipping...`,
+      workspaceId: workspace.id,
+    };
   }
 
   let chargeAmountTotal =
     (charge.amount_total ?? 0) - (charge.total_details?.amount_tax ?? 0);
 
   // should never be below 0, but just in case
   if (chargeAmountTotal <= 0) {
-    return `Checkout session completed for Stripe customer ${stripeCustomerId} but amount is 0, skipping...`;
+    return {
+      response: `Checkout session completed for Stripe customer ${stripeCustomerId} but amount is 0, skipping...`,
+      workspaceId: workspace.id,
+    };
   }
 
   if (charge.mode === "setup") {
-    return `Checkout session completed for Stripe customer ${stripeCustomerId} but mode is "setup", skipping...`;
+    return {
+      response: `Checkout session completed for Stripe customer ${stripeCustomerId} but mode is "setup", skipping...`,
+      workspaceId: workspace.id,
+    };
   }
 
   if (charge.payment_status !== "paid") {
-    return `Checkout session completed for Stripe customer ${stripeCustomerId} but payment_status is not "paid", skipping...`;
+    return {
+      response: `Checkout session completed for Stripe customer ${stripeCustomerId} but payment_status is not "paid", skipping...`,
+      workspaceId: workspace.id,
+    };
   }
 
   if (invoiceId) {
@@ -326,7 +361,10 @@ export async function checkoutSessionCompleted(
         "[Stripe Webhook] Skipping already processed invoice.",
         invoiceId,
       );
-      return `Invoice with ID ${invoiceId} already processed, skipping...`;
+      return {
+        response: `Invoice with ID ${invoiceId} already processed, skipping...`,
+        workspaceId: workspace.id,
+      };
     }
   }
 
@@ -549,7 +587,10 @@ export async function checkoutSessionCompleted(
     ]),
   );
 
-  return `Checkout session completed for customer with external ID ${dubCustomerExternalId} and invoice ID ${invoiceId}`;
+  return {
+    response: `Checkout session completed for customer with external ID ${dubCustomerExternalId} and invoice ID ${invoiceId}`,
+    workspaceId: workspace.id,
+  };
 }
 
 async function attributeViaPromoCode({