From cb2f5732ebdbdaa3f262dcb7660d88dbe49a142e Mon Sep 17 00:00:00 2001
From: devbeni <ballobeni08@gmail.com>
Date: Fri, 19 Sep 2025 19:45:58 +0200
Subject: [PATCH] feat: add cleanup for expired sessions on server start and
 during queue evaluation

---
 app/api/socketio/route.js | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/app/api/socketio/route.js b/app/api/socketio/route.js
index cf19177..0430ee8 100644
--- a/app/api/socketio/route.js
+++ b/app/api/socketio/route.js
@@ -102,6 +102,7 @@ async function evaluateQueue(eventId, io) {
       
       // Clean up expired sessions from database
       if (expiredSessions.length > 0) {
+        console.log(`Cleaning up ${expiredSessions.length} expired sessions for event ${eventId}`);
         await connection.execute(
           'DELETE FROM active_sessions WHERE event_id = ? AND expires_at < NOW()',
           [eventId]
@@ -163,6 +164,18 @@ export async function GET(req) {
 
     global.io = io
 
+    // Clean up all expired sessions on server start
+    const connection = await getDbConnection()
+    if (connection) {
+      try {
+        const [result] = await connection.execute('DELETE FROM active_sessions WHERE expires_at < NOW()')
+        console.log(`Server startup: Cleaned ${result.affectedRows} expired sessions`)
+        await connection.end()
+      } catch (error) {
+        console.error('Cleanup error on startup:', error)
+      }
+    }
+
     // Periodikus token ellenőrzés minden 5 másodpercben
     setInterval(async () => {
       for (const eventId of Object.keys(events)) {