invoiceId dedupe key between stripe and /track/sale

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

@@ -1,5 +1,9 @@
 import { convertCurrency } from "@/lib/analytics/convert-currency";
 import { isFirstConversion } from "@/lib/analytics/is-first-conversion";
+import {
+  invoiceDedupeKey,
+  legacyStripeInvoiceDedupeKey,
+} from "@/lib/api/conversions/invoice-idempotency";
 import { createId } from "@/lib/api/create-id";
 import { getOrCreateCustomer } from "@/lib/api/customers/get-or-create-customer";
 import { includeTags } from "@/lib/api/links/include-tags";
@@ -334,9 +338,24 @@ export async function checkoutSessionCompleted({
   }
 
   if (invoiceId) {
+    const legacyRecord = await redis.get(
+      legacyStripeInvoiceDedupeKey(invoiceId),
+    );
+
+    if (legacyRecord) {
+      console.info(
+        "[checkout.session.completed] Skipping already processed invoice (legacy key).",
+        invoiceId,
+      );
+
+      return {
+        response: `Invoice with ID ${invoiceId} already processed, skipping...`,
+      };
+    }
+
     // Skip if invoice id is already processed
     const ok = await redis.set(
-      `trackSale:stripe:invoiceId:${invoiceId}`, // here we assume that Stripe's invoice ID is unique across all customers
+      invoiceDedupeKey(workspace.id, invoiceId),
       {
         timestamp: new Date().toISOString(),
         dubCustomerExternalId,

apps/web/app/(ee)/api/stripe/integration/webhook/invoice-paid.ts

@@ -1,5 +1,9 @@
 import { convertCurrency } from "@/lib/analytics/convert-currency";
 import { isFirstConversion } from "@/lib/analytics/is-first-conversion";
+import {
+  invoiceDedupeKey,
+  legacyStripeInvoiceDedupeKey,
+} from "@/lib/api/conversions/invoice-idempotency";
 import { includeTags } from "@/lib/api/links/include-tags";
 import { syncPartnerLinksStats } from "@/lib/api/partners/sync-partner-links-stats";
 import { executeWorkflows } from "@/lib/api/workflows/execute-workflows";
@@ -135,9 +139,21 @@ export async function invoicePaid({
       ? invoice.total_excluding_tax
       : invoice.amount_paid;
 
+  const legacyRecord = await redis.get(legacyStripeInvoiceDedupeKey(invoiceId));
+
+  if (legacyRecord) {
+    console.info(
+      "[invoice.paid] Skipping already processed invoice (legacy key).",
+      invoiceId,
+    );
+    return {
+      response: `Invoice with ID ${invoiceId} already processed, skipping...`,
+    };
+  }
+
   // Skip if invoice id is already processed
   const ok = await redis.set(
-    `trackSale:stripe:invoiceId:${invoiceId}`, // here we assume that Stripe's invoice ID is unique across all customers
+    invoiceDedupeKey(workspace.id, invoiceId),
     {
       timestamp: new Date().toISOString(),
       dubCustomerExternalId: customer.externalId,

apps/web/lib/api/conversions/invoice-idempotency.ts

@@ -0,0 +1,9 @@
+// TODO: remove after 2026-08-10 (10 days after rollout) once the transition
+// window has elapsed and no keys written under the old Stripe-only format
+// remain (they carry a 7-day TTL).
+
+export const invoiceDedupeKey = (workspaceId: string, invoiceId: string) =>
+  `trackSale:${workspaceId}:invoiceId:${invoiceId}`;
+
+export const legacyStripeInvoiceDedupeKey = (invoiceId: string) =>
+  `trackSale:stripe:invoiceId:${invoiceId}`;

apps/web/lib/api/conversions/track-sale.ts

@@ -32,6 +32,10 @@ import * as z from "zod/v4";
 import { createId } from "../create-id";
 import { syncPartnerLinksStats } from "../partners/sync-partner-links-stats";
 import { executeWorkflows } from "../workflows/execute-workflows";
+import {
+  invoiceDedupeKey,
+  legacyStripeInvoiceDedupeKey,
+} from "./invoice-idempotency";
 
 type TrackSaleParams = z.input<typeof trackSaleRequestSchema> & {
   workspace: Pick<WorkspaceProps, "id" | "stripeConnectId" | "webhookEnabled">;
@@ -61,11 +65,26 @@ export const trackSale = async ({
 
   // Return idempotent response if invoiceId is already processed
   if (invoiceId) {
-    const cachedResponse = await redis.get(
-      `trackSale:${workspace.id}:invoiceId:${invoiceId}`,
-    );
+    const [cachedResponse, legacyRecord] = await redis.mget([
+      invoiceDedupeKey(workspace.id, invoiceId),
+      legacyStripeInvoiceDedupeKey(invoiceId),
+    ]);
+
     if (cachedResponse) {
-      return cachedResponse;
+      const parsedCachedResponse =
+        trackSaleResponseSchema.safeParse(cachedResponse);
+
+      if (parsedCachedResponse.success) {
+        return parsedCachedResponse.data;
+      }
+    }
+
+    if (cachedResponse || legacyRecord) {
+      return {
+        eventName,
+        customer: null,
+        sale: null,
+      };
     }
   }
 
@@ -707,13 +726,9 @@ const _trackSale = async ({
 
   if (invoiceId) {
     waitUntil(
-      redis.set(
-        `trackSale:${workspace.id}:invoiceId:${invoiceId}`,
-        trackSaleResponse,
-        {
-          ex: 60 * 60 * 24 * 7, // cache for 1 week
-        },
-      ),
+      redis.set(invoiceDedupeKey(workspace.id, invoiceId), trackSaleResponse, {
+        ex: 60 * 60 * 24 * 7, // cache for 1 week
+      }),
     );
   }