Marcos/notas-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add logging for total connected clients in SSE stream events
Despliegue Automático / desplegar (push) Successful in 41s
Details

Browse Source
This commit is contained in:
Marck64
2026-09-09 14:32:06 +02:00
parent e7da512a31
commit 541895b67e
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/controllers/syncController.js
+4
View File
@@ -55,6 +55,8 @@ const streamEvents = async (req, res) => {
// Registrar este dispositivo en el manager // Registrar este dispositivo en el manager
sseManager.addClient(userId, res); sseManager.addClient(userId, res);
console.log(`Clientes conectados para userId ${userId}: ${sseManager.clients.get(userId).length}`);
console.log(`Clientes conectados totales: ${sseManager.clients.size}`);
// Latido (Heartbeat) para mantener la conexión viva a través de firewalls // Latido (Heartbeat) para mantener la conexión viva a través de firewalls
const interval = setInterval(() => { const interval = setInterval(() => {
@@ -66,6 +68,8 @@ 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', () => {
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 totales: ${sseManager.clients.size}`);
clearInterval(interval); clearInterval(interval);
sseManager.removeClient(userId, res); sseManager.removeClient(userId, res);
res.end(); res.end();