Feat/leaderboard

src/modules/leaderboard/leaderboard.refresh.job.spec.ts

@@ -0,0 +1,33 @@
+import { LeaderboardRefreshJob } from './leaderboard.refresh.job';
+
+describe('LeaderboardRefreshJob', () => {
+  it('clears leaderboards and calls bulkUpdateScores with users from prisma', async () => {
+    const mockLeaderboardService: any = {
+      clearLeaderboard: jest.fn().mockResolvedValue(undefined),
+      bulkUpdateScores: jest.fn().mockResolvedValue(undefined),
+    };
+
+    const mockPrisma: any = {
+      user: {
+        findMany: jest.fn().mockResolvedValue([
+          { id: 'u1', reputation: 10 },
+          { id: 'u2', reputation: 20 },
+        ]),
+      },
+    };
+
+    const job = new LeaderboardRefreshJob(mockLeaderboardService, mockPrisma);
+
+    // call refresh
+    await job.refreshLeaderboard();
+
+    expect(mockLeaderboardService.clearLeaderboard).toHaveBeenCalledWith('global');
+    expect(mockLeaderboardService.clearLeaderboard).toHaveBeenCalledWith('weekly');
+    expect(mockLeaderboardService.bulkUpdateScores).toHaveBeenCalledWith(
+      [
+        { id: 'u1', reputation: 10 },
+        { id: 'u2', reputation: 20 },
+      ],
+    );
+  });
+});

src/modules/leaderboard/leaderboard.refresh.job.ts

@@ -28,10 +28,8 @@ export class LeaderboardRefreshJob {
     await this.leaderboardService.clearLeaderboard('global');
     await this.leaderboardService.clearLeaderboard('weekly');
 
-    // Rebuild rankings from real data
-    for (const user of users) {
-      await this.leaderboardService.updateScore(user.id, user.reputation);
-    }
+    // Rebuild rankings from real data using batched pipelining
+    await this.leaderboardService.bulkUpdateScores(users);
 
     this.logger.log(`Leaderboard refreshed with ${users.length} users.`);
   }

src/modules/leaderboard/leaderboard.service.ts

@@ -14,17 +14,27 @@ export class LeaderboardService {
         userId: string,
         score: number,
     ): Promise<void> {
-        await this.redis.zadd(
-            LEADERBOARD_KEYS.GLOBAL,
-            score,
-            userId,
-        );
+        // Use a pipeline to reduce round trips for two ZADD operations
+        const pipeline = this.redis.pipeline();
+        pipeline.zadd(LEADERBOARD_KEYS.GLOBAL, score, userId);
+        pipeline.zadd(LEADERBOARD_KEYS.WEEKLY, score, userId);
+        await pipeline.exec();
+    }
 
-        await this.redis.zadd(
-            LEADERBOARD_KEYS.WEEKLY,
-            score,
-            userId,
-        );
+    // Bulk update scores using pipelining in chunks to avoid many roundtrips
+    async bulkUpdateScores(
+        users: { id: string; reputation: number }[],
+        chunkSize = 500,
+    ): Promise<void> {
+        for (let i = 0; i < users.length; i += chunkSize) {
+            const chunk = users.slice(i, i + chunkSize);
+            const pipeline = this.redis.pipeline();
+            for (const u of chunk) {
+                pipeline.zadd(LEADERBOARD_KEYS.GLOBAL, u.reputation, u.id);
+                pipeline.zadd(LEADERBOARD_KEYS.WEEKLY, u.reputation, u.id);
+            }
+            await pipeline.exec();
+        }
     }
 
     // 🔹 Get leaderboard