selenite/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix online users

Browse Source
This commit is contained in:
sky
2026-02-18 11:51:07 -05:00
parent ded4990eb4
commit 3a2b6b63dc
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
index.js
View File

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