From a45a150ef33c34819c5e55ebe49a2aab73c131c2 Mon Sep 17 00:00:00 2001
From: RajuGangitla <gangitlaraju8520@gmail.com>
Date: Mon, 14 Oct 2024 22:03:38 +0530
Subject: [PATCH] leaderboard

---
 lib/points/service.ts | 72 ++++++++++++++++++++++++-------------------
 1 file changed, 41 insertions(+), 31 deletions(-)

diff --git a/lib/points/service.ts b/lib/points/service.ts
index d028052..1c0585f 100644
--- a/lib/points/service.ts
+++ b/lib/points/service.ts
@@ -4,7 +4,7 @@ import { DatabaseError } from "@/types/errors";
 import { TPointTransactionWithUser } from "@/types/pointTransaction";
 import { TRepository } from "@/types/repository";
 import { Prisma } from "@prisma/client";
-import { unstable_cache } from "next/cache";
+import { revalidateTag, unstable_cache } from "next/cache";
 
 import { DEFAULT_CACHE_REVALIDATION_INTERVAL, ITEMS_PER_PAGE } from "../constants";
 import { validateInputs } from "../utils/validate";
@@ -38,6 +38,7 @@ export const assignUserPoints = async (
         repositoryId,
       },
     });
+    await revalidateTag('leaderboard'); // Revalidate the leaderboard cache
     return pointsUpdated;
   } catch (error) {
     throw error;
@@ -190,36 +191,45 @@ export interface LeaderboardEntry {
   totalPoints: number;
 }
 
-export const getAllUserPointsList = async (): Promise<LeaderboardEntry[]> => {
-  try {
-    // Fetch users (id, login, avatarUrl) without point transactions initially
-    const users = await db.user.findMany({
-      select: {
-        id: true,
-        login: true,
-        avatarUrl: true,
-      },
-    });
 
-    // Fetch total points and rank for each user in parallel using Promise.all
-    const leaderboard = await Promise.all(
-      users.map(async (user) => {
-        const { totalPoints } = await getTotalPointsAndGlobalRank(user.id); // Fetch total points for the user
-        return {
-          userId: user.id,
-          login: user.login,
-          avatarUrl: user.avatarUrl,
-          totalPoints, // Assign fetched total points
-        };
-      })
-    );
-
-    // Sort the leaderboard by totalPoints in descending order
-    return leaderboard.sort((a, b) => b.totalPoints - a.totalPoints);
+export const getAllUserPointsList = async (): Promise<LeaderboardEntry[]> => {
+  return await unstable_cache(
+    async () => {
+      try {
+        // Fetch users (id, login, avatarUrl) without point transactions initially
+        const users = await db.user.findMany({
+          select: {
+            id: true,
+            login: true,
+            avatarUrl: true,
+          },
+        });
+
+        // Fetch total points and rank for each user in parallel using Promise.all
+        const leaderboard = await Promise.all(
+          users.map(async (user) => {
+            const { totalPoints } = await getTotalPointsAndGlobalRank(user.id); // Fetch total points for the user
+            return {
+              userId: user.id,
+              login: user.login,
+              avatarUrl: user.avatarUrl,
+              totalPoints, // Assign fetched total points
+            };
+          })
+        );
+
+        // Sort the leaderboard by totalPoints in descending order
+        return leaderboard.sort((a, b) => b.totalPoints - a.totalPoints);
 
-  } catch (error) {
-    console.error("Error fetching leaderboard:", error);
-    throw new Error("Failed to fetch leaderboard");
-  }
+      } catch (error) {
+        console.error("Error fetching leaderboard:", error);
+        throw new Error("Failed to fetch leaderboard");
+      }
+    },
+    [`getAllUserPointsList`], // Cache key
+    {
+      tags: ['leaderboard'], // Cache tag for easier invalidation if needed
+      revalidate: DEFAULT_CACHE_REVALIDATION_INTERVAL, // Set cache revalidation interval
+    }
+  )();
 };
-