notifier.ts
No OneTemporary
Actions

Size

595 B

Referenced Files

None

Subscribers

None

notifier.ts
View Options

	import { WebSocketServer, WebSocket } from "ws";

	export function make_notifier(port: number) {
	const server = new WebSocketServer({
	port,
	});

	let sockets: WebSocket[] = [];
	server.on("connection", function (socket) {
	sockets.push(socket);

	// When a socket closes, or disconnects, remove it from the array.
	socket.on("close", function () {
	sockets = sockets.filter((s) => s !== socket);
	});
	});

	console.log(
	"build notifier listening on websocket at port " + port.toString()
	);
	return function notify(message: string) {
	sockets.forEach((s) => s.send(message));
	};
	}