f.weber/homebrewery
0
0
Fork 0
mirror of https://github.com/naturalcrit/homebrewery.git synced 2026-11-04 22:38:43 +00:00
Code Wiki Activity

Limit sendUpdate event listener

Browse Source
This commit is contained in:
G.Ambatte
2026-10-06 19:04:56 +13:00
parent c5e9e2f8e1
commit 22a68c2ec6
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/app.js
+8 -4
View File
@@ -195,6 +195,7 @@ export default async function createApp(vite) {
}); });
// Create Event Stream source for pages to listen to // Create Event Stream source for pages to listen to
let initStreamListener = false;
app.get('/stream', (req, res)=>{ app.get('/stream', (req, res)=>{
res.writeHead(200, { res.writeHead(200, {
'Content-Type' : 'text/event-stream', 'Content-Type' : 'text/event-stream',
@@ -203,10 +204,13 @@ export default async function createApp(vite) {
'Content-Encoding' : 'none' 'Content-Encoding' : 'none'
}); });
Stream.on('sendUpdate', (event, data)=>{ if(!initStreamListener){
if(isLocalEnvironment) { console.log('Event:', event, '\nData:', data); } initStreamListener = true;
res.write(`data: ${JSON.stringify({ ...data, eventType: event })}\n\n`); Stream.on('sendUpdate', (event, data)=>{
}); if(isLocalEnvironment) { console.log('Event:', event, '\nData:', data); }
res.write(`data: ${JSON.stringify({ ...data, eventType: event })}\n\n`);
});
}
}); });
// After Stream starts, send initStream event // After Stream starts, send initStream event