/
githubmirror
/
ai-legion
Обзор
Документация
Войти
/
githubmirror
/
ai-legion
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
src/web-socket-server.ts
24 строки
684 B
foolishsailor
add basic socket server that streams all messagebus content to a websocket (#24)
16 апр 2023, 18:06
Не верифицирован
16 апр 2023, 18:06
6ff180e
Код
Авторство
О чём код?
import WebSocket from "ws"; import { MessageBus } from "./message-bus"; export const webSocketServer = (messageBus: MessageBus, port: number) => { const wss = new WebSocket.Server({ port }); messageBus.subscribe((message) => { wss.clients.forEach((client: WebSocket) => { if (client.readyState === WebSocket.OPEN) { client.send(JSON.stringify(message)); } }); }); wss.on("connection", (ws: WebSocket) => { console.log("WebSocket client connected"); ws.on("message", (message: string) => { console.log("Received: %s", message); }); ws.on("close", () => { console.log("WebSocket client disconnected"); }); }); };