fix(core): Run delete query directly for sessions

vendure-ecommerce · Jan 14, 2025 · 0cd2a2b · 0cd2a2b
1 parent 55883df
commit 0cd2a2b
Showing 1 changed file with 4 additions and 9 deletions.
diff --git a/packages/core/src/service/services/session.service.ts b/packages/core/src/service/services/session.service.ts
@@ -322,18 +322,13 @@ export class SessionService implements EntitySubscriberInterface {
      */
     async cleanupExpiredSessions(ctx: RequestContext): Promise<void> {
         const now = new Date();
-        const sessions = await this.connection
+
+        await this.connection
             .getRepository(ctx, Session)
             .createQueryBuilder('session')
-            .select('session.id')
             .where('session.expires <= :now', { now })
-            .getMany();
-
-        await this.connection.getRepository(ctx, Session).remove(sessions, { chunk: 500 });
-
-        for (const session of sessions) {
-            await this.withTimeout(this.sessionCacheStrategy.delete(session.token));
-        }
+            .delete()
+            .execute();
     }
 
     /**