Add session-cleanup cronjob

Author: CarboxyDev

apps/backend/package.json

@@ -25,6 +25,7 @@
     "@nestjs/common": "^11.1.6",
     "@nestjs/core": "^11.1.6",
     "@nestjs/platform-express": "^11.1.6",
+    "@nestjs/schedule": "^6.0.1",
     "@nestjs/swagger": "^11.2.0",
     "@nestjs/throttler": "^6.4.0",
     "@prisma/client": "6.17.1",

apps/backend/prisma/migrations/20251019211416_faster_session_lookup/migration.sql

@@ -0,0 +1,2 @@
+-- CreateIndex
+CREATE INDEX "sessions_expiresAt_idx" ON "sessions"("expiresAt");

apps/backend/prisma/schema.prisma

@@ -52,6 +52,7 @@ model Session {
   user User @relation(fields: [userId], references: [id], onDelete: Cascade)
 
   @@index([userId])
+  @@index([expiresAt])
   @@map("sessions")
 }
 

apps/backend/src/app.module.ts

@@ -1,5 +1,6 @@
 import { MiddlewareConsumer, Module, NestModule } from '@nestjs/common';
 import { APP_GUARD } from '@nestjs/core';
+import { ScheduleModule } from '@nestjs/schedule';
 import { ThrottlerGuard, ThrottlerModule } from '@nestjs/throttler';
 
 import { AppController } from '@/app.controller';
@@ -8,6 +9,7 @@ import { AuthModule } from '@/auth/auth.module';
 import { LoggerModule } from '@/common/logger.module';
 import { LoggerMiddleware } from '@/common/middleware/logger.middleware';
 import { RequestIdMiddleware } from '@/common/middleware/request-id.middleware';
+import { SessionCleanupTask } from '@/common/tasks/session-cleanup.task';
 import { PrismaModule } from '@/database/prisma/prisma.module';
 import { UsersModule } from '@/modules/users/users.module';
 
@@ -20,6 +22,7 @@ import { UsersModule } from '@/modules/users/users.module';
         limit: 30,
       },
     ]),
+    ScheduleModule.forRoot(),
     LoggerModule,
     PrismaModule,
     AuthModule,
@@ -28,6 +31,7 @@ import { UsersModule } from '@/modules/users/users.module';
   controllers: [AppController],
   providers: [
     AppService,
+    SessionCleanupTask,
     {
       provide: APP_GUARD,
       useClass: ThrottlerGuard,

apps/backend/src/common/tasks/session-cleanup.task.ts

@@ -0,0 +1,39 @@
+import { Injectable } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+
+import { LoggerService } from '@/common/logger.service';
+import { PrismaService } from '@/database/prisma/prisma.service';
+
+@Injectable()
+export class SessionCleanupTask {
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly logger: LoggerService
+  ) {
+    this.logger.setContext('SessionCleanupTask');
+  }
+
+  @Cron(CronExpression.EVERY_DAY_AT_3AM)
+  async cleanupExpiredSessions() {
+    this.logger.info('Starting expired session cleanup');
+
+    try {
+      const result = await this.prisma.session.deleteMany({
+        where: {
+          expiresAt: {
+            lt: new Date(),
+          },
+        },
+      });
+
+      this.logger.info('Expired sessions cleaned up successfully', {
+        deletedCount: result.count,
+      });
+    } catch (error) {
+      this.logger.error(
+        'Failed to cleanup expired sessions',
+        error instanceof Error ? error : new Error(String(error))
+      );
+    }
+  }
+}