homebrewery/server/stream.api.js

import express from 'express';

import Stream from './eventStreamSource.js';

const app = express.Router();

// Create Event Stream source for pages to listen to
app.get('/api/stream/:id', (req, res)=>{
	res.writeHead(200, {
		'Content-Type'     : 'text/event-stream',
		'Cache-Control'    : 'no-cache',
		'Connection'       : 'keep-alive',
		'Content-Encoding' : 'none'
	});
	;
	Stream.subscribe(req.params.id, res, req.query?.client);
});

app.get('/api/stream/unsubscribe/:id', (req, res)=>{
	Stream.unsubscribe(req.params?.id);
	res.status(200).send();
});

export default app;