revalidate cache

Author: jobenjada

lib/github/services/user.ts

@@ -1,6 +1,7 @@
 import { GITHUB_APP_PRIVATE_KEY, GITHUB_APP_WEBHOOK_SECRET } from "@/lib/constants";
 import { db } from "@/lib/db";
 import { getRepositoryDefaultBranch, getRepositoryReadme } from "@/lib/github/services/repo";
+import { repositoryCache } from "@/lib/repository/cache";
 import { App } from "octokit";
 
 export const sendInstallationDetails = async (
@@ -94,6 +95,7 @@ export const sendInstallationDetails = async (
                   role: "member",
                 },
               });
+              repositoryCache.revalidate({ userId: newUser.id, id: installationPrisma.id });
               console.log(`Membership upserted for user: ${newUser.login}`);
             })
           );
@@ -128,6 +130,7 @@ export const sendInstallationDetails = async (
             },
           });
           console.log(`Membership upserted for user: ${newUser.login}`);
+          repositoryCache.revalidate({ userId: newUser.id, id: installationPrisma.id });
         }
 
         if (repos) {

lib/repository/service.ts

@@ -149,6 +149,8 @@ export const fetchRepoDetails = (id: string) =>
 export const getRepositoriesForUser = (userId: string) =>
   unstable_cache(
     async (): Promise<TRepository[]> => {
+      console.log(`getRepositoriesForUser called with userId: ${userId}`);
+      console.log(`Starting database transaction`);
       try {
         const userRepositories = await db.repository.findMany({
           where: {
@@ -161,7 +163,7 @@ export const getRepositoriesForUser = (userId: string) =>
             },
           },
         });
-
+        console.log(`Database transaction completed successfully`);
         return userRepositories as TRepository[];
       } catch (error) {
         console.error(`Failed to get repositories for user: ${error}`);