added more crons

prisma/schema.prisma

@@ -106,14 +106,14 @@ model AuthSession {
   id        String   @id @unique @default(uuid()) @db.Uuid
   userId    BigInt
   token     String   @unique
-  expiresAt DateTime
   ipAddress String?
   userAgent String?
   browser   String?
   os        String?
   device    String?
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
+  expiresAt DateTime
   user      user     @relation(fields: [userId], references: [userid])
 }
 

utils/cronJobs.ts

@@ -5,6 +5,9 @@ import { runRoleSyncCron } from "@/utils/crons/update-roles";
 import { runBirthdayCron } from "@/utils/crons/birthday";
 import { runActivityReset } from "@/utils/crons/resetActivity";
 import { runMilestoneCron } from "@/utils/crons/milestones";
+import { runSessionCron } from "./crons/authSessions";
+import { runOAuthCron } from "./crons/authState";
+import { runPendingVerificationCron } from "./crons/pVerification";
 
 let initialized = false;
 
@@ -53,6 +56,30 @@ export async function initCronJobs() {
       }
     });
 
+    cron.schedule("*/30 * * * *", async () => {
+      try {
+        await runSessionCron();
+      } catch (err) {
+        console.error("[CRON][AUTH]", err);
+      }
+    });
+
+    cron.schedule("*/5 * * * *", async () => {
+      try {
+        await runOAuthCron();
+      } catch (err) {
+        console.error("[CRON][OAUTH]", err);
+      }
+    });
+
+    cron.schedule("*/5 * * * *", async () => {
+      try {
+        await runPendingVerificationCron();
+      } catch (err) {
+        console.error("[CRON][OAUTH]", err);
+      }
+    });
+
     console.log("[STARTUP] All crons scheduled.");
   } catch (err) {
     console.error(

utils/crons/authSessions.ts

@@ -0,0 +1,16 @@
+import prisma from "@/utils/database";
+
+export async function runSessionCron() {
+  const result = await prisma.authSession.deleteMany({
+    where: {
+      expiresAt: {
+        lte: new Date(),
+      },
+    },
+  });
+
+  return {
+    success: true,
+    deleted: result.count,
+  };
+}

utils/crons/authState.ts

@@ -0,0 +1,16 @@
+import prisma from "@/utils/database";
+
+export async function runOAuthCron() {
+  const result = await prisma.oAuthState.deleteMany({
+    where: {
+      expiresAt: {
+        lte: new Date(),
+      },
+    },
+  });
+
+  return {
+    success: true,
+    deleted: result.count,
+  };
+}

utils/crons/pVerification.ts

@@ -0,0 +1,16 @@
+import prisma from "@/utils/database";
+
+export async function runPendingVerificationCron() {
+  const result = await prisma.pendingVerification.deleteMany({
+    where: {
+      expiresAt: {
+        lte: new Date(),
+      },
+    },
+  });
+
+  return {
+    success: true,
+    deleted: result.count,
+  };
+}