Create src/ws/adminWs.js

src/ws/adminWs.js

@@ -0,0 +1,24 @@
+import { WebSocketServer } from "ws";
+import jwt from "jsonwebtoken";
+
+const clients = new Set();
+
+export function initAdminWS(server) {
+  const wss = new WebSocketServer({ server, path: "/ws/admin" });
+
+  wss.on("connection", (ws, req) => {
+    const token = new URL(req.url, "http://x").searchParams.get("token");
+    try {
+      jwt.verify(token, process.env.JWT_SECRET);
+      clients.add(ws);
+    } catch {
+      ws.close();
+    }
+    ws.on("close", () => clients.delete(ws));
+  });
+}
+
+export function emitAdminAlert(data) {
+  const msg = JSON.stringify(data);
+  clients.forEach((ws) => ws.send(msg));
+}