diff --git a/index.js b/index.js index 0af252c..f2beeb8 100755 --- a/index.js +++ b/index.js @@ -68,6 +68,7 @@ app.use(express.text()); // }, 1000) import WebSocket, { WebSocketServer } from "ws"; const wss = new WebSocketServer({ noServer: true }); +let onlineUsers; // let openSockets = 0; wss.on("connection", function connection(ws, req, res) { // ws.send(`online=${wss.clients.size}`); @@ -79,6 +80,7 @@ wss.on("connection", function connection(ws, req, res) { server.on("message", async function message(data) { let message = Buffer.from(data).toString(); if (message.startsWith("online")) { + onlineUsers = message.split("=")[1]; ws.send(message); } else if (message.startsWith("annc")) { ws.send(message); @@ -198,7 +200,7 @@ app.use("/metrics", async(req, res) => { }); returnData+="#HELP online_users The total number of people online.\n"; returnData+="#TYPE online_users gauge\n" - returnData+=`online_users ${wss.clients.size}\n` + returnData+=`online_users ${onlineUsers}\n` res.setHeader("Content-Type", "text/plain; version=0.0.4") res.send(returnData); return;