From cdaecafcbb448175d329afc16675c628bf18a37f Mon Sep 17 00:00:00 2001
From: Marck64 <marcos.lapuente@gmail.com>
Date: Wed, 9 Sep 2026 13:47:45 +0200
Subject: [PATCH] Add logging for SSE connection and disconnection events, and
 notify user of changes

---
 src/controllers/syncController.js | 3 +++
 src/services/syncService.js       | 1 +
 2 files changed, 4 insertions(+)

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);
     }