nucleo000/radiusNucleo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix
All checks were successful
build-and-deploy / build (push) Successful in 9s
Details
build-and-deploy / deploy (push) Successful in 15s
Details

Browse Source
This commit is contained in:
josedario87
2025-09-26 20:57:10 -06:00
parent aad02ed556
commit c5a1c6aaf0
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
node-api/src/sse.js
View File

@@ -6,7 +6,10 @@ const requests = [];
export function registerSse(req, res, initialStatus = {}) { export function registerSse(req, res, initialStatus = {}) {
res.setHeader('Content-Type', 'text/event-stream'); res.setHeader('Content-Type', 'text/event-stream');
res.setHeader('Cache-Control', 'no-cache'); res.setHeader('Cache-Control', 'no-cache');
res.setHeader('Cache-Control', 'no-transform');
res.setHeader('Connection', 'keep-alive'); res.setHeader('Connection', 'keep-alive');
// Disable proxy buffering in Nginx
res.setHeader('X-Accel-Buffering', 'no');
res.flushHeaders?.(); res.flushHeaders?.();
res.write(`event: hello\n`); res.write(`event: hello\n`);
res.write(`data: {"ok":true}\n\n`); res.write(`data: {"ok":true}\n\n`);
@@ -15,7 +18,15 @@ export function registerSse(req, res, initialStatus = {}) {
res.write(`data: ${JSON.stringify(initialStatus)}\n\n`); res.write(`data: ${JSON.stringify(initialStatus)}\n\n`);
} }
sseClients.add(res); sseClients.add(res);
req.on('close', () => sseClients.delete(res)); // Heartbeat to keep proxies/load balancers from timing out idle SSE
// Send a comment line every 20s
const hb = setInterval(() => {
try { res.write(`: ping\n\n`); } catch { /* ignore */ }
}, 20000);
req.on('close', () => {
clearInterval(hb);
sseClients.delete(res);
});
} }
export function pushRequest(rec) { export function pushRequest(rec) {
@@ -45,4 +56,3 @@ export function clearRequests() {
export function getRecentRequests() { export function getRecentRequests() {
return requests.slice(-MAX_REQUESTS); return requests.slice(-MAX_REQUESTS);
} }