seguimos habilitando la funcion realtime
All checks were successful
build-and-deploy / filter (push) Successful in 2s
build-and-deploy / build (push) Successful in 12s
build-and-deploy / deploy (push) Successful in 26s

This commit is contained in:
2025-06-09 17:36:27 -06:00
parent 39be1a2d27
commit 6d7f95fc71
2 changed files with 23 additions and 6 deletions

View File

@@ -7,19 +7,23 @@ export function registerSse(app) {
res.set({
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
Connection: 'keep-alive'
'Connection': 'keep-alive'
});
res.flushHeaders();
res.write(':\n\n');
sseClients.push(res);
res.on('close', () => {
res.flushHeaders();
res.write('event: connected\ndata: {}\n\n'); // ← mantiene el stream vivo
sseClients.push(res);
console.log(`🟢 Cliente SSE conectado (${sseClients.length})`);
req.on('close', () => {
const idx = sseClients.indexOf(res);
if (idx !== -1) sseClients.splice(idx, 1);
res.end();
console.log(`🔌 Cliente SSE desconectado (${sseClients.length})`);
});
});
const broadcast = (data) => {
const payload = `data: ${data}\n\n`;
sseClients.forEach((client) => client.write(payload));