perf(billing): skip the redundant cursor lookup when the caller already has it

The export loop holds the previous page's rows in memory, so its next
cursor's createdAt is already known — getUserUsageLogs was still
re-resolving it via an extra DB round trip every page regardless.
Added an optional cursorCreatedAt to skip that lookup when provided;
the list route's existing callers are unaffected since they don't
pass it. Verified live: zero cursor-lookup queries fired across a
3,500-row / 4-page export that previously issued one per page.

Author: waleedlatif1

apps/sim/app/api/users/me/usage-logs/export/route.test.ts

@@ -173,7 +173,10 @@ describe('GET /api/users/me/usage-logs/export', () => {
     expect(mockGetUserUsageLogs).toHaveBeenNthCalledWith(
       2,
       'user-1',
-      expect.objectContaining({ cursor: 'log-1' })
+      expect.objectContaining({
+        cursor: 'log-1',
+        cursorCreatedAt: new Date('2026-07-01T00:00:00.000Z'),
+      })
     )
     expect(csv.split('\n')).toHaveLength(3)
   })

apps/sim/app/api/users/me/usage-logs/export/route.ts

@@ -43,6 +43,7 @@ export const GET = withRouteHandler(async (request: NextRequest) => {
 
   const rows: Awaited<ReturnType<typeof getUserUsageLogs>>['logs'] = []
   let cursor: string | undefined
+  let cursorCreatedAt: Date | undefined
   let truncated = false
   while (rows.length < EXPORT_SAFETY_CAP) {
     const page = await getUserUsageLogs(auth.userId, {
@@ -52,12 +53,15 @@ export const GET = withRouteHandler(async (request: NextRequest) => {
       endDate: dateRange.endDate,
       limit: Math.min(EXPORT_PAGE_SIZE, EXPORT_SAFETY_CAP - rows.length),
       cursor,
+      cursorCreatedAt,
       includeSummary: false,
     })
     rows.push(...page.logs)
     if (!page.pagination.hasMore) break
     truncated = rows.length >= EXPORT_SAFETY_CAP
     cursor = page.pagination.nextCursor
+    const lastRow = page.logs[page.logs.length - 1]
+    cursorCreatedAt = lastRow ? new Date(lastRow.createdAt) : undefined
   }
 
   if (truncated) {

apps/sim/lib/billing/core/usage-log.ts

@@ -533,6 +533,12 @@ export interface GetUsageLogsOptions {
   limit?: number
   /** Cursor for pagination (log ID) */
   cursor?: string
+  /**
+   * The cursor row's `createdAt`, when the caller already has it (e.g. a
+   * multi-page export loop holding the previous page's rows in memory).
+   * Skips the row lookup that would otherwise resolve it from `cursor`.
+   */
+  cursorCreatedAt?: Date
   /**
    * Whether to compute the full-filter `summary` aggregate (default `true`).
    * A cursor-paginated caller collecting every page (e.g. a CSV export) only
@@ -591,6 +597,7 @@ export async function getUserUsageLogs(
     endDate,
     limit = 50,
     cursor,
+    cursorCreatedAt,
     includeSummary = true,
   } = options
 
@@ -614,20 +621,24 @@ export async function getUserUsageLogs(
     }
 
     if (cursor) {
-      // Cursor resolution stays on the primary: the page itself reads a
-      // load-balanced replica, and a laggier sibling replica missing the cursor
-      // row would silently restart pagination from page 1.
-      const cursorLog = await db
-        .select({ createdAt: usageLog.createdAt })
-        .from(usageLog)
-        .where(eq(usageLog.id, cursor))
-        .limit(1)
+      let resolvedCursorCreatedAt = cursorCreatedAt
+
+      if (!resolvedCursorCreatedAt) {
+        // Cursor resolution stays on the primary: the page itself reads a
+        // load-balanced replica, and a laggier sibling replica missing the
+        // cursor row would silently restart pagination from page 1.
+        const cursorLog = await db
+          .select({ createdAt: usageLog.createdAt })
+          .from(usageLog)
+          .where(eq(usageLog.id, cursor))
+          .limit(1)
+        resolvedCursorCreatedAt = cursorLog[0]?.createdAt
+      }
 
-      if (cursorLog.length > 0) {
-        const cursorCreatedAt = cursorLog[0].createdAt
+      if (resolvedCursorCreatedAt) {
         const cursorCondition = or(
-          lt(usageLog.createdAt, cursorCreatedAt),
-          and(eq(usageLog.createdAt, cursorCreatedAt), lt(usageLog.id, cursor))
+          lt(usageLog.createdAt, resolvedCursorCreatedAt),
+          and(eq(usageLog.createdAt, resolvedCursorCreatedAt), lt(usageLog.id, cursor))
         )
         if (cursorCondition) conditions.push(cursorCondition)
       }