Merge pull request #49 from unmonk/v0.2

chunking adjustments to updateScheduledMatchup and getActiveMatchupsB…
unmonk · Feb 17, 2025 · a926a7d · a926a7d
2 parents f9e9507 + dc5d316
commit a926a7d
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 13 deletions.
diff --git a/convex/matchups.ts b/convex/matchups.ts
@@ -200,10 +200,10 @@ export const getActiveMatchupsByLeague = query({
   handler: async (ctx, { league }) => {
     const matchups = await ctx.db
       .query("matchups")
-      .filter((q) =>
-        q.and(q.eq(q.field("league"), league), q.eq(q.field("active"), true))
+      .withIndex("by_active_league", (q) =>
+        q.eq("league", league).eq("active", true)
       )
-      .take(50);
+      .take(250);
 
     // Get pick counts for each matchup
     const matchupsWithPicks = [];

diff --git a/convex/schedules.ts b/convex/schedules.ts
@@ -148,19 +148,21 @@ export const updateScheduledMatchup = internalMutation({
     status: v.string(),
   },
   handler: async (ctx, { gameId, league, startTime, status }) => {
+    // Use index to efficiently query matchups
     const matchups = await ctx.db
       .query("matchups")
-      .filter((q) =>
-        q.and(
-          q.eq(q.field("league"), league),
-          q.eq(q.field("active"), true),
-          q.eq(q.field("gameId"), gameId)
-        )
+      .withIndex("by_active_league", (q) =>
+        q.eq("league", league).eq("active", true)
       )
-      .take(500);
-    for (const matchup of matchups) {
-      await ctx.db.patch(matchup._id, { startTime, status });
-    }
+      .filter((q) => q.eq(q.field("gameId"), gameId))
+      .take(50);
+
+    // Batch update all matching matchups
+    await Promise.all(
+      matchups.map((matchup) =>
+        ctx.db.patch(matchup._id, { startTime, status })
+      )
+    );
   },
 });