feat: cleaning session expiry

Author: indrasuthar07

backend/src/models/sessionModel.ts

@@ -7,5 +7,7 @@ const sessionSchema = new mongoose.Schema({
   createdAt: { type: Date, default: Date.now },
 });
 
+sessionSchema.index({ expiresAt: 1 });
+sessionSchema.index({ token: 1 });
 
 export const Session = mongoose.model("Session", sessionSchema);

backend/src/server.ts

@@ -10,6 +10,7 @@ import { ChatMessage } from "./models/chatMessageModel.js";
 import Room from "./models/roomModel.js"; // ✅ Import for room events
 import app from "./app.js";
 import logger from "./utils/logger.js";
+import { initializeScheduler } from "./utils/scheduler.js";
 
 dotenv.config();
 
@@ -166,6 +167,7 @@ mongoose
   .connect(MONGO_URI)
   .then(() => {
     logger.info("🗄️  MongoDB connected successfully!");
+    initializeScheduler();
     httpServer.listen(PORT, () => {
       logger.info(`🚀 Server running on port ${PORT}`);
       logger.info(`📡 Socket.io real-time chat ready`);

backend/src/utils/scheduler.ts

@@ -0,0 +1,33 @@
+import cron from "node-cron";
+import { cleanupExpiredSessions } from "./sessionCleanup.js";
+import logger from "./logger.js";
+
+export const initializeScheduler = () => {
+  const sessionCleanupCron = process.env.SESSION_CLEANUP_CRON || "0 * * * *";
+  const sessionCleanupJob = cron.schedule(sessionCleanupCron, async () => {
+    try {
+      logger.info("🔄 Running scheduled session cleanup...");
+      const result = await cleanupExpiredSessions();
+      logger.info(`✅ Session cleanup completed: ${result.deletedCount} expired session(s) removed`);
+    } catch (error: any) {
+      logger.error("Scheduled session cleanup failed:", error);
+    }
+  }, {
+    timezone: "UTC",
+  });
+  cleanupExpiredSessions()
+    .then((result) => {
+      logger.info(`✅ Initial session cleanup completed on startup: ${result.deletedCount} expired session(s) removed`);
+    })
+    .catch((error) => {
+      logger.error(" Initial session cleanup failed:", error);
+    });
+
+  logger.info("📅 Scheduled tasks initialized:");
+  logger.info(`   - Session cleanup: Cron schedule "${sessionCleanupCron}" (every hour by default)`);
+
+  return {
+    sessionCleanupJob,
+  };
+};
+

backend/src/utils/sessionCleanup.ts

@@ -0,0 +1,17 @@
+import { Session } from "../models/sessionModel.js";
+import logger from "./logger.js";
+export const cleanupExpiredSessions = async (): Promise<{ deletedCount: number }> => {
+  try {
+    const now = new Date();
+    const result = await Session.deleteMany({
+      expiresAt: { $lt: now },
+    });
+    if (result.deletedCount > 0) {
+      logger.info(`🧹 Cleaned up ${result.deletedCount} expired session(s)`);
+    }
+    return { deletedCount: result.deletedCount || 0 };
+  } catch (error: any) {
+    logger.error(" Error cleaning up expired sessions:", error);
+    throw error;
+  }
+};