diff --git a/src/controllers/syncController.js b/src/controllers/syncController.js index a16973c..e1be6a7 100644 --- a/src/controllers/syncController.js +++ b/src/controllers/syncController.js @@ -49,6 +49,8 @@ const streamEvents = async (req, res) => { res.setHeader('Cache-Control', 'no-cache'); res.setHeader('Connection', 'keep-alive'); res.flushHeaders(); // Enviar cabeceras inmediatamente + + console.log(`Cliente SSE conectado para userId: ${userId}`); // Registrar este dispositivo en el manager sseManager.addClient(userId, res); @@ -58,6 +60,7 @@ const streamEvents = async (req, res) => { // Cuando el cliente (móvil/PC) cierre la app, limpiar la memoria req.on('close', () => { + console.log(`Cliente SSE desconectado para userId: ${userId}`); clearInterval(interval); sseManager.removeClient(userId, res); res.end(); diff --git a/src/services/syncService.js b/src/services/syncService.js index 50bab2a..946cb21 100644 --- a/src/services/syncService.js +++ b/src/services/syncService.js @@ -220,6 +220,7 @@ class SyncService { if(incomingNotes && incomingNotes.length > 0 || incomingCategories && incomingCategories.length > 0 ) { + console.log(`Notificando cambios para userId: ${userId}`); sseManager.notifyUser(userId); }