perf: stuck streams resolve perf

Author: NamesMT

apps/backend-convex/convex/crons.ts

@@ -23,7 +23,7 @@ crons.daily(
 
 crons.interval(
   'resolve stuck stream messages',
-  { hours: 1 },
+  { minutes: 10 },
   internal.messages.resolveStuckStreamMessages,
 )
 

apps/backend-convex/convex/messages.ts

@@ -138,9 +138,10 @@ export const resolveStuckStreamMessages = internalMutation({
   handler: async (ctx) => {
     const messages = await ctx.db
       .query('messages')
-      .filter(q => q.eq(q.field('isStreaming'), true))
       // Get streams that are older than 15 minutes
-      .filter(q => q.lt(q.field('timestamp'), Date.now() - 15 * 60 * 1000))
+      .withIndex('by_timestamp', q =>
+        q.lte('timestamp', Date.now() - 15 * 60 * 1000))
+      .filter(q => q.eq(q.field('isStreaming'), true))
       .collect()
 
     if (!messages.length)

apps/backend-convex/convex/schema.ts

@@ -29,6 +29,7 @@ const aiChatTables = {
   })
     .index('by_thread', ['threadId'])
     .index('by_thread_and_timestamp', ['threadId', 'timestamp'])
+    .index('by_timestamp', ['timestamp'])
     .index('by_stream_id', ['streamId']),
 }