diff --git a/src/controllers/syncController.js b/src/controllers/syncController.js index 8fac363..4e2a266 100644 --- a/src/controllers/syncController.js +++ b/src/controllers/syncController.js @@ -67,11 +67,11 @@ const streamEvents = async (req, res) => { // Cuando el cliente (móvil/PC) cierre la app, limpiar la memoria req.on('close', () => { + clearInterval(interval); + sseManager.removeClient(userId, res); console.log(`Cliente SSE desconectado para userId: ${userId}`); console.log(`Clientes conectados para userId ${userId}: ${sseManager.clients.get(userId)?.length || 0}`); console.log(`Clientes conectados totales: ${sseManager.clients.size}`); - clearInterval(interval); - sseManager.removeClient(userId, res); res.end(); });