Clean up SSE client on disconnect: log client disconnection and update connected clients count
Despliegue Automático / desplegar (push) Successful in 35s
Despliegue Automático / desplegar (push) Successful in 35s
This commit is contained in:
@@ -67,11 +67,11 @@ const streamEvents = async (req, res) => {
|
|||||||
|
|
||||||
// Cuando el cliente (móvil/PC) cierre la app, limpiar la memoria
|
// Cuando el cliente (móvil/PC) cierre la app, limpiar la memoria
|
||||||
req.on('close', () => {
|
req.on('close', () => {
|
||||||
|
clearInterval(interval);
|
||||||
|
sseManager.removeClient(userId, res);
|
||||||
console.log(`Cliente SSE desconectado para userId: ${userId}`);
|
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 para userId ${userId}: ${sseManager.clients.get(userId)?.length || 0}`);
|
||||||
console.log(`Clientes conectados totales: ${sseManager.clients.size}`);
|
console.log(`Clientes conectados totales: ${sseManager.clients.size}`);
|
||||||
clearInterval(interval);
|
|
||||||
sseManager.removeClient(userId, res);
|
|
||||||
res.end();
|
res.end();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user