kuba/fm-dx-webserver
1
0
Fork 0
mirror of https://github.com/KubaPro010/fm-dx-webserver.git synced 2026-07-31 01:09:18 +02:00
Code Issues Activity

count xrd users and also count the fm-dx users as secondary

Browse Source
This commit is contained in:
kuba
2026-04-04 22:19:00 +02:00
parent e0753c2479
commit c0ad53563e
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/xrd_server.js
+14 -7
View File
@@ -2,6 +2,14 @@ const storage = require('./storage');
const WebSocket = require('ws'); const WebSocket = require('ws');
const xrd = new WebSocket.Server({ noServer: true }); const xrd = new WebSocket.Server({ noServer: true });
let currentUsers = 0;
function send_to_xrd(data) {
xrd.clients.forEach((client) => {
if (client.readyState === WebSocket.OPEN) client.send(data);
});
}
xrd.on('connection', (ws, request) => { xrd.on('connection', (ws, request) => {
const { initialData } = require('./datahandler'); const { initialData } = require('./datahandler');
const { isAdminAuthenticated } = request.session || {}; const { isAdminAuthenticated } = request.session || {};
@@ -10,7 +18,8 @@ xrd.on('connection', (ws, request) => {
return; return;
} }
ws.send(`o${initialData.users},0\n`); currentUsers++;
send_to_xrd(`o${currentUsers},${initialData.users}\n`);
ws.send(`T${initialData.freq * 1000}\n`); ws.send(`T${initialData.freq * 1000}\n`);
ws.send(`G${initialData.eq}${initialData.ims}\n`); ws.send(`G${initialData.eq}${initialData.ims}\n`);
ws.send(`Z${initialData.ant}\n`); ws.send(`Z${initialData.ant}\n`);
@@ -20,14 +29,12 @@ xrd.on('connection', (ws, request) => {
ws.send(`OK\n`); ws.send(`OK\n`);
ws.on('message', (message) => storage.ctl_output.write(`${message}\n`)); ws.on('message', (message) => storage.ctl_output.write(`${message}\n`));
ws.on('close', (code, reason) => {
currentUsers--;
send_to_xrd(`o${currentUsers},${initialData.users}\n`);
});
}); });
storage.websocket_delegation.set("/xrd", xrd); storage.websocket_delegation.set("/xrd", xrd);
function send_to_xrd(data) {
xrd.clients.forEach((client) => {
if (client.readyState === WebSocket.OPEN) client.send(data);
});
}
module.exports = send_to_xrd; module.exports = send_to_xrd;