Creating Node.js WebSocket Server

npm install ws
npm install --save-dev @types/ws

import { WebSocketServer } from "ws";
const wss = new WebSocketServer({ port: 8080 });
wss.on("connection", (ws, req) => {
  ws.on("message", (data, isBinary) => ws.send(data, { binary: isBinary }));
});

for (const client of wss.clients) {
  if (client.readyState === 1) client.send(payload);
}

wss.on("connection", (ws, req) => {
  const ip = req.headers["x-forwarded-for"] ?? req.socket.remoteAddress;
  const ua = req.headers["user-agent"];
  const url = new URL(req.url, `http://${req.headers.host}`);
});

import http from "node:http";
import express from "express";
import { WebSocketServer } from "ws";
const app = express();
const server = http.createServer(app);
const wss = new WebSocketServer({ server, path: "/ws" });
server.listen(3000);

const chat = new WebSocketServer({ noServer: true });
const feed = new WebSocketServer({ noServer: true });
server.on("upgrade", (req, sock, head) => {
  const { pathname } = new URL(req.url, "http://x");
  const target = pathname === "/chat" ? chat : pathname === "/feed" ? feed : null;
  if (!target) return sock.destroy();
  target.handleUpgrade(req, sock, head, (ws) => target.emit("connection", ws, req));
});

function broadcast(msg, filter = () => true) {
  const data = typeof msg === "string" ? msg : JSON.stringify(msg);
  for (const c of wss.clients) {
    if (c.readyState === 1 && filter(c)) c.send(data);
  }
}