Add logging for SSE connection and disconnection events, and notify user of changes
Despliegue Automático / desplegar (push) Successful in 47s
Despliegue Automático / desplegar (push) Successful in 47s
This commit is contained in:
@@ -49,6 +49,8 @@ const streamEvents = async (req, res) => {
|
|||||||
res.setHeader('Cache-Control', 'no-cache');
|
res.setHeader('Cache-Control', 'no-cache');
|
||||||
res.setHeader('Connection', 'keep-alive');
|
res.setHeader('Connection', 'keep-alive');
|
||||||
res.flushHeaders(); // Enviar cabeceras inmediatamente
|
res.flushHeaders(); // Enviar cabeceras inmediatamente
|
||||||
|
|
||||||
|
console.log(`Cliente SSE conectado para userId: ${userId}`);
|
||||||
|
|
||||||
// Registrar este dispositivo en el manager
|
// Registrar este dispositivo en el manager
|
||||||
sseManager.addClient(userId, res);
|
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
|
// 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}`);
|
||||||
clearInterval(interval);
|
clearInterval(interval);
|
||||||
sseManager.removeClient(userId, res);
|
sseManager.removeClient(userId, res);
|
||||||
res.end();
|
res.end();
|
||||||
|
|||||||
@@ -220,6 +220,7 @@ class SyncService {
|
|||||||
if(incomingNotes && incomingNotes.length > 0 ||
|
if(incomingNotes && incomingNotes.length > 0 ||
|
||||||
incomingCategories && incomingCategories.length > 0
|
incomingCategories && incomingCategories.length > 0
|
||||||
) {
|
) {
|
||||||
|
console.log(`Notificando cambios para userId: ${userId}`);
|
||||||
sseManager.notifyUser(userId);
|
sseManager.notifyUser(userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user