Merge branch 'dev' into clickhouse-sync-fixes

Author: BilalG1

apps/backend/src/app/api/latest/integrations/stripe/webhooks/route.tsx

@@ -40,6 +40,15 @@ const subscriptionChangedEvents = [
   "payment_intent.canceled",
 ] as const satisfies Stripe.Event.Type[];
 
+const ignoredEvents = [
+  "account.updated",
+  "account.application.authorized",
+  "capability.updated",
+  "charge.failed",
+  "balance.available",
+  "customer.updated",
+] as const satisfies Stripe.Event.Type[];
+
 const isSubscriptionChangedEvent = (event: Stripe.Event): event is Stripe.Event & { type: (typeof subscriptionChangedEvents)[number] } => {
   return subscriptionChangedEvents.includes(event.type as any);
 };
@@ -399,6 +408,10 @@ async function processStripeWebhookEvent(event: Stripe.Event): Promise<void> {
       });
     }
   }
+  else if (typedIncludes(ignoredEvents, event.type)) {
+    // These events are received but don't require processing
+    return;
+  }
   else {
     throw new StackAssertionError("Unknown stripe webhook type received: " + event.type, { event });
   }

apps/backend/src/app/api/latest/internal/external-db-sync/poller/route.ts

@@ -214,6 +214,7 @@ export const GET = createSmartRouteHandler({
             await upstash.batchJSON(batchPayload);
             await deleteOutgoingRequests(requests.map((request) => request.id));
             processSpan.setAttribute("stack.external-db-sync.processed-count", requests.length);
+            console.log(`[Poller] Processed requests: ${requests.length}`);
             return requests.length;
           } catch (error) {
             processSpan.setAttribute("stack.external-db-sync.iteration-error", true);

apps/backend/src/app/api/latest/internal/external-db-sync/sequencer/route.ts

@@ -137,6 +137,9 @@ async function backfillSequenceIds(batchSize: number): Promise<boolean> {
     }
 
     span.setAttribute("stack.external-db-sync.did-update", didUpdate);
+    if (didUpdate) {
+      console.log(`[Sequencer] Backfilled sequence IDs: USR=${projectUserTenants.length}, CC=${contactChannelTenants.length}, DR=${deletedRowTenants.length}`);
+    }
 
     return didUpdate;
   });
@@ -211,6 +214,7 @@ export const GET = createSmartRouteHandler({
           try {
             const didUpdate = await backfillSequenceIds(batchSize);
             iterationSpan.setAttribute("stack.external-db-sync.did-update", didUpdate);
+            console.log(`[Sequencer] Backfilled ${didUpdate ? "some" : "no"} sequence IDs`);
           } catch (error) {
             iterationSpan.setAttribute("stack.external-db-sync.iteration-error", true);
             captureError(

apps/backend/src/route-handlers/smart-route-handler.tsx

@@ -105,16 +105,18 @@ export function handleApiRequest(handler: (req: NextRequest, options: any, reque
           // request duration warning
           const allowedLongRequestPaths = [
             "/api/latest/internal/email-queue-step",
-            "/api/v1/internal/analytics/query",
             "/api/latest/internal/analytics/query",
             "/health/email",
-            "/api/v1/internal/metrics",
             "/api/latest/internal/metrics",
             "/api/latest/internal/external-db-sync/poller",
             "/api/latest/internal/external-db-sync/sequencer",
             "/api/latest/internal/external-db-sync/sync-engine",
           ];
-          const warnAfterSeconds = allowedLongRequestPaths.includes(req.nextUrl.pathname) ? 240 : 12;
+          const allAllowedLongRequestPaths = [
+            ...allowedLongRequestPaths,
+            ...allowedLongRequestPaths.map(path => path.replace(/^\/api\/latest\//, "/api/v1/")),
+          ];
+          const warnAfterSeconds = allAllowedLongRequestPaths.includes(req.nextUrl.pathname) ? 240 : 12;
           runAsynchronously(async () => {
             await wait(warnAfterSeconds * 1000);
             if (!hasRequestFinished) {