1
0
mirror of https://github.com/KubaPro010/fm-dx-webserver.git synced 2026-02-26 22:13:53 +01:00

minor fixes, code cleanup, accesibility features

This commit is contained in:
NoobishSVK
2024-02-16 00:26:40 +01:00
parent 5f45a069df
commit a2c73c396b
12 changed files with 108 additions and 80 deletions

View File

@@ -379,5 +379,5 @@ function showOnlineUsers(currentUsers) {
} }
module.exports = { module.exports = {
handleData, showOnlineUsers, dataToSend handleData, showOnlineUsers, dataToSend, initialData
}; };

View File

@@ -25,13 +25,13 @@ function send(request) {
{ {
if (!serverConfig.identification.token) if (!serverConfig.identification.token)
{ {
logInfo("Succesfully registered in FM-DX Server Map."); logInfo("Registered to FM-DX Server Map successfully.");
serverConfig.identification.token = data.token; serverConfig.identification.token = data.token;
configSave(); configSave();
} }
else else
{ {
logInfo("Succesfully updated FM-DX Server Map."); logInfo("FM-DX Server Map update successful.");
} }
} }
else else

View File

@@ -27,8 +27,7 @@ const fmdxList = require('./fmdx_list');
const consoleCmd = require('./console'); const consoleCmd = require('./console');
const audioStream = require('./stream/index.js'); const audioStream = require('./stream/index.js');
const { parseAudioDevice } = require('./stream/parser.js'); const { parseAudioDevice } = require('./stream/parser.js');
const configPath = path.join(__dirname, 'config.json'); const { configName, serverConfig, configUpdate, configSave } = require('./server_config');
const { serverConfig, configUpdate, configSave } = require('./server_config')
const { logDebug, logError, logInfo, logWarn } = consoleCmd; const { logDebug, logError, logInfo, logWarn } = consoleCmd;
@@ -109,6 +108,33 @@ function connectToXdrd() {
} else if (line.startsWith('OK')) { } else if (line.startsWith('OK')) {
authFlags.authMsg = true; authFlags.authMsg = true;
logInfo('Authentication with xdrd successful.'); logInfo('Authentication with xdrd successful.');
} else if (line.startsWith('G')) {
switch (line) {
case 'G11':
dataHandler.initialData.eq = 1;
dataHandler.dataToSend.eq = 1;
dataHandler.initialData.ims = 1;
dataHandler.dataToSend.ims = 1;
break;
case 'G01':
dataHandler.initialData.eq = 0;
dataHandler.dataToSend.eq = 0;
dataHandler.initialData.ims = 1;
dataHandler.dataToSend.ims = 1;
break;
case 'G10':
dataHandler.initialData.eq = 1;
dataHandler.dataToSend.eq = 1;
dataHandler.initialData.ims = 0;
dataHandler.dataToSend.ims = 0;
break;
case 'G00':
dataHandler.initialData.eq = 0;
dataHandler.initialData.ims = 0;
dataHandler.dataToSend.eq = 0;
dataHandler.dataToSend.ims = 0;
break;
}
} }
if (authFlags.authMsg && authFlags.firstClient) { if (authFlags.authMsg && authFlags.firstClient) {
@@ -155,9 +181,11 @@ function connectToXdrd() {
client.on('close', () => { client.on('close', () => {
logWarn('Disconnected from xdrd. Attempting to reconnect.'); logWarn('Disconnected from xdrd. Attempting to reconnect.');
setTimeout(function () { if(serverConfig.autoShutdown === false) {
connectToXdrd(); setTimeout(function () {
}, 2000) connectToXdrd();
}, 2000)
}
}); });
client.on('error', (err) => { client.on('error', (err) => {
@@ -235,7 +263,7 @@ app.set('view engine', 'ejs'); // Set EJS as the template engine
app.set('views', path.join(__dirname, '/web')) app.set('views', path.join(__dirname, '/web'))
app.get('/', (req, res) => { app.get('/', (req, res) => {
if (!fs.existsSync("config.json")) { if (!fs.existsSync(configName + '.json')) {
parseAudioDevice((result) => { parseAudioDevice((result) => {
res.render('setup', { res.render('setup', {
isAdminAuthenticated: true, isAdminAuthenticated: true,
@@ -282,17 +310,17 @@ app.get('/logout', (req, res) => {
app.post('/saveData', (req, res) => { app.post('/saveData', (req, res) => {
const data = req.body; const data = req.body;
let firstSetup; let firstSetup;
if(req.session.isAdminAuthenticated || !fs.existsSync('config.json')) { if(req.session.isAdminAuthenticated || !fs.existsSync(configName + '.json')) {
configUpdate(data); configUpdate(data);
fmdxList.update(); fmdxList.update();
if(!fs.existsSync('config.json')) { if(!fs.existsSync(configName + '.json')) {
firstSetup = true; firstSetup = true;
} }
/* TODO: Refactor to server_config.js */ /* TODO: Refactor to server_config.js */
// Save data to a JSON file // Save data to a JSON file
fs.writeFile('config.json', JSON.stringify(serverConfig, null, 2), (err) => { fs.writeFile(configName + '.json', JSON.stringify(serverConfig, null, 2), (err) => {
if (err) { if (err) {
logError(err); logError(err);
res.status(500).send('Internal Server Error'); res.status(500).send('Internal Server Error');
@@ -312,20 +340,20 @@ app.post('/saveData', (req, res) => {
app.get('/getData', (req, res) => { app.get('/getData', (req, res) => {
if(req.session.isAdminAuthenticated) { if(req.session.isAdminAuthenticated) {
// Check if the file exists // Check if the file exists
fs.access(configPath, fs.constants.F_OK, (err) => { fs.access(configName + '.json', fs.constants.F_OK, (err) => {
if (err) { if (err) {
// File does not exist // File does not exist
res.status(404).send('Data not found'); res.status(404).send('Data not found');
} else { } else {
// File exists, send it as the response // File exists, send it as the response
res.sendFile(configPath); res.sendFile(path.join(__dirname) + '/' + configName + '.json');
} }
}); });
} }
}); });
app.get('/getDevices', (req, res) => { app.get('/getDevices', (req, res) => {
if (req.session.isAdminAuthenticated || !fs.existsSync('config.json')) { if (req.session.isAdminAuthenticated || !fs.existsSync(configName + '.json')) {
parseAudioDevice((result) => { parseAudioDevice((result) => {
res.json(result); res.json(result);
}); });
@@ -342,6 +370,9 @@ wss.on('connection', (ws, request) => {
const clientIp = request.headers['x-forwarded-for'] || request.connection.remoteAddress; const clientIp = request.headers['x-forwarded-for'] || request.connection.remoteAddress;
currentUsers++; currentUsers++;
dataHandler.showOnlineUsers(currentUsers); dataHandler.showOnlineUsers(currentUsers);
if(currentUsers > 0 && serverConfig.autoShutdown === true) {
client.write('x\n');
}
// Use ipinfo.io API to get geolocation information // Use ipinfo.io API to get geolocation information
https.get(`https://ipinfo.io/${clientIp}/json`, (response) => { https.get(`https://ipinfo.io/${clientIp}/json`, (response) => {
@@ -391,6 +422,9 @@ wss.on('connection', (ws, request) => {
ws.on('close', (code, reason) => { ws.on('close', (code, reason) => {
currentUsers--; currentUsers--;
dataHandler.showOnlineUsers(currentUsers); dataHandler.showOnlineUsers(currentUsers);
if(currentUsers === 0 && serverConfig.autoShutdown === true) {
client.write('X\n');
}
logInfo(`Web client \x1b[31mdisconnected\x1b[0m (${clientIp}) \x1b[90m[${currentUsers}]`); logInfo(`Web client \x1b[31mdisconnected\x1b[0m (${clientIp}) \x1b[90m[${currentUsers}]`);
}); });
@@ -410,7 +444,9 @@ httpServer.on('upgrade', (request, socket, head) => {
app.use(express.static(path.join(__dirname, 'web'))); app.use(express.static(path.join(__dirname, 'web')));
httpServer.listen(serverConfig.webserver.webserverPort, serverConfig.webserver.webserverIp, () => { httpServer.listen(serverConfig.webserver.webserverPort, serverConfig.webserver.webserverIp, () => {
logInfo(`Web server is running at \x1b[34mhttp://${serverConfig.webserver.webserverIp}:${serverConfig.webserver.webserverPort}\x1b[0m.`); let currentAddress = serverConfig.webserver.webserverIp;
currentAddress == '0.0.0.0' ? currentAddress = 'localhost' : currentAddress = serverConfig.webserver.webserverIp;
logInfo(`Web server is running at \x1b[34mhttp://${currentAddress}:${serverConfig.webserver.webserverPort}\x1b[0m.`);
}); });
fmdxList.update(); fmdxList.update();

22
package-lock.json generated
View File

@@ -1,12 +1,12 @@
{ {
"name": "xdrd-client", "name": "fm-dx-webserver",
"version": "1.0.0", "version": "1.0.6",
"lockfileVersion": 3, "lockfileVersion": 3,
"requires": true, "requires": true,
"packages": { "packages": {
"": { "": {
"name": "xdrd-client", "name": "fm-dx-webserver",
"version": "1.0.0", "version": "1.0.6",
"license": "ISC", "license": "ISC",
"dependencies": { "dependencies": {
"@mapbox/node-pre-gyp": "^1.0.11", "@mapbox/node-pre-gyp": "^1.0.11",
@@ -18,7 +18,6 @@
"http": "^0.0.1-security", "http": "^0.0.1-security",
"https": "1.0.0", "https": "1.0.0",
"koffi": "2.7.2", "koffi": "2.7.2",
"lamejs": "^1.2.1",
"net": "1.0.2", "net": "1.0.2",
"websocket": "1.0.34", "websocket": "1.0.34",
"wrtc": "^0.4.7", "wrtc": "^0.4.7",
@@ -921,14 +920,6 @@
"integrity": "sha512-AWcsEKETQuELxK0Wq/aXDkDiNFFY41TxZQSrKm2Nd6HO/KTHeohPOOIlh2OfQnBXJbRjx5etpWt8cbqMUZo2sg==", "integrity": "sha512-AWcsEKETQuELxK0Wq/aXDkDiNFFY41TxZQSrKm2Nd6HO/KTHeohPOOIlh2OfQnBXJbRjx5etpWt8cbqMUZo2sg==",
"hasInstallScript": true "hasInstallScript": true
}, },
"node_modules/lamejs": {
"version": "1.2.1",
"resolved": "https://registry.npmjs.org/lamejs/-/lamejs-1.2.1.tgz",
"integrity": "sha512-s7bxvjvYthw6oPLCm5pFxvA84wUROODB8jEO2+CE1adhKgrIvVOlmMgY8zyugxGrvRaDHNJanOiS21/emty6dQ==",
"dependencies": {
"use-strict": "1.0.1"
}
},
"node_modules/lru-cache": { "node_modules/lru-cache": {
"version": "6.0.0", "version": "6.0.0",
"resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-6.0.0.tgz", "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-6.0.0.tgz",
@@ -1536,11 +1527,6 @@
"node": ">= 0.8" "node": ">= 0.8"
} }
}, },
"node_modules/use-strict": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/use-strict/-/use-strict-1.0.1.tgz",
"integrity": "sha512-IeiWvvEXfW5ltKVMkxq6FvNf2LojMKvB2OCeja6+ct24S1XOmQw2dGr2JyndwACWAGJva9B7yPHwAmeA9QCqAQ=="
},
"node_modules/utf-8-validate": { "node_modules/utf-8-validate": {
"version": "5.0.10", "version": "5.0.10",
"resolved": "https://registry.npmjs.org/utf-8-validate/-/utf-8-validate-5.0.10.tgz", "resolved": "https://registry.npmjs.org/utf-8-validate/-/utf-8-validate-5.0.10.tgz",

View File

@@ -1,10 +1,12 @@
{ {
"name": "fm-dx-webserver", "name": "fm-dx-webserver",
"version": "1.0.2", "version": "1.0.6",
"description": "", "description": "",
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"debug": "node index.js --debug", "debug": "node index.js --debug",
"debug_ffmpeg": "node index.js --ffmpegdebug",
"debug_full": "node index.js --debug --ffmpegdebug",
"webserver": "node index.js" "webserver": "node index.js"
}, },
"author": "", "author": "",
@@ -19,7 +21,6 @@
"http": "^0.0.1-security", "http": "^0.0.1-security",
"https": "1.0.0", "https": "1.0.0",
"koffi": "2.7.2", "koffi": "2.7.2",
"lamejs": "^1.2.1",
"net": "1.0.2", "net": "1.0.2",
"websocket": "1.0.34", "websocket": "1.0.34",
"wrtc": "^0.4.7", "wrtc": "^0.4.7",

View File

@@ -2,6 +2,14 @@
const fs = require('fs'); const fs = require('fs');
const { logDebug, logError, logInfo, logWarn } = require('./console'); const { logDebug, logError, logInfo, logWarn } = require('./console');
let configName = 'config';
const index = process.argv.indexOf('--config');
if (index !== -1 && index + 1 < process.argv.length) {
configName = process.argv[index + 1];
logInfo('Loading with a custom config file:', configName + '.json')
}
let serverConfig = { let serverConfig = {
webserver: { webserver: {
webserverIp: "0.0.0.0", webserverIp: "0.0.0.0",
@@ -13,6 +21,11 @@ let serverConfig = {
xdrdPort: "7373", xdrdPort: "7373",
xdrdPassword: "" xdrdPassword: ""
}, },
audio: {
audioDevice: "Microphone (High Definition Audio Device)",
audioChannels: 2,
audioBitrate: "128k"
},
identification: { identification: {
token: null, token: null,
tunerName: "", tunerName: "",
@@ -27,7 +40,8 @@ let serverConfig = {
adminPass: "" adminPass: ""
}, },
publicTuner: true, publicTuner: true,
lockToAdmin: false lockToAdmin: false,
autoShutdown: false,
}; };
function deepMerge(target, source) function deepMerge(target, source)
@@ -46,7 +60,7 @@ function configUpdate(newConfig) {
} }
function configSave() { function configSave() {
fs.writeFile('config.json', JSON.stringify(serverConfig, null, 2), (err) => { fs.writeFile(configName + '.json', JSON.stringify(serverConfig, null, 2), (err) => {
if (err) { if (err) {
logError(err); logError(err);
} else { } else {
@@ -55,11 +69,11 @@ function configSave() {
}); });
} }
if (fs.existsSync('config.json')) { if (fs.existsSync(configName + '.json')) {
const configFileContents = fs.readFileSync('config.json', 'utf8'); const configFileContents = fs.readFileSync(configName + '.json', 'utf8');
serverConfig = JSON.parse(configFileContents); serverConfig = JSON.parse(configFileContents);
} }
module.exports = { module.exports = {
serverConfig, configUpdate, configSave configName, serverConfig, configUpdate, configSave
}; };

View File

@@ -1,22 +1,7 @@
const { spawn } = require('child_process'); const { spawn } = require('child_process');
const fs = require('fs'); const fs = require('fs');
const consoleCmd = require('../console.js'); const consoleCmd = require('../console.js');
const { configName, serverConfig, configUpdate, configSave } = require('../server_config');
let serverConfig = {
webserver: {
audioPort: "8081"
},
audio: {
audioDevice: "Microphone (High Definition Audio Device)",
audioChannels: 2,
audioBitrate: "128k"
},
};
if(fs.existsSync('./config.json')) {
const configFileContents = fs.readFileSync('./config.json', 'utf8');
serverConfig = JSON.parse(configFileContents);
}
function enableAudioStream() { function enableAudioStream() {
var ffmpegCommand; var ffmpegCommand;

View File

@@ -1,21 +1,9 @@
const fetch = require('node-fetch'); const fetch = require('node-fetch');
var fs = require('fs'); var fs = require('fs');
const { serverConfig } = require('./server_config')
let cachedData = {}; let cachedData = {};
let serverConfig = {
identification: {
lat: 0,
lon: 0
},
};
if(fs.existsSync('config.json')) {
const configFileContents = fs.readFileSync('config.json', 'utf8');
serverConfig = JSON.parse(configFileContents);
}
let lastFetchTime = 0; let lastFetchTime = 0;
const fetchInterval = 3000; const fetchInterval = 3000;

View File

@@ -117,10 +117,18 @@
font-size: 11px; font-size: 11px;
} }
.text-light {
font-weight: 300;
}
.text-bold { .text-bold {
font-weight: bold; font-weight: bold;
} }
.text-monospace {
font-family: "Roboto Mono", monospace;
}
.text-gray { .text-gray {
color: #666; color: #666;
} }

View File

@@ -5,6 +5,7 @@ var socket = new WebSocket(socketAddress);
var parsedData; var parsedData;
var data = []; var data = [];
let signalChart; let signalChart;
let updateCounter = 0;
const europe_programmes = [ const europe_programmes = [
"No PTY", "News", "Current Affairs", "Info", "No PTY", "News", "Current Affairs", "Info",
@@ -176,15 +177,12 @@ function getLocalizedTime(serverTime) {
// Convert server time to a Date object // Convert server time to a Date object
const serverDate = new Date(serverTime); const serverDate = new Date(serverTime);
// Get local time zone offset
const localOffset = serverDate.getTimezoneOffset() * 60000; // Convert minutes to milliseconds
// Calculate local time by adding the offset // Calculate local time by adding the offset
const localTime = new Date(serverDate.getTime()); const localTime = new Date(serverDate.getTime());
// Format local time // Format local time
const options = { year: 'numeric', month: 'short', day: 'numeric', hour: '2-digit', minute: '2-digit', hour12: false }; const options = { year: 'numeric', month: 'short', day: 'numeric', hour: '2-digit', minute: '2-digit', hour12: false };
const formattedLocalTime = localTime.toLocaleString('en-US', options); const formattedLocalTime = localTime.toLocaleString(navigator.language ? navigator.language : 'en-US', options);
return formattedLocalTime; return formattedLocalTime;
} }
@@ -603,12 +601,17 @@ function updateDataElements(parsedData) {
} else { } else {
$('#data-station-container').removeAttr('style'); $('#data-station-container').removeAttr('style');
} }
updateCounter++;
if (updateCounter % 30 === 0) {
$('#data-ps').attr('aria-label', parsedData.ps);
$('#data-rt0').attr('aria-label', parsedData.rt0);
$('#data-rt1').attr('aria-label', parsedData.rt1);
}
} }
let isEventListenerAdded = false; let isEventListenerAdded = false;
let updateCounter = 0;
function updatePanels(parsedData) { function updatePanels(parsedData) {
updateCounter++; updateCounter++;

View File

@@ -160,6 +160,7 @@ function fetchData() {
$("#tuner-public").prop("checked", data.publicTuner); $("#tuner-public").prop("checked", data.publicTuner);
$("#tuner-lock").prop("checked", data.lockToAdmin); $("#tuner-lock").prop("checked", data.lockToAdmin);
$("#shutdown-tuner").prop("checked", data.autoShutdown);
// Check if latitude and longitude are present in the data // Check if latitude and longitude are present in the data
if (data.identification.lat && data.identification.lon) { if (data.identification.lat && data.identification.lon) {
@@ -214,6 +215,7 @@ function submitData() {
const publicTuner = $("#tuner-public").is(":checked"); const publicTuner = $("#tuner-public").is(":checked");
const lockToAdmin = $("#tuner-lock").is(":checked"); const lockToAdmin = $("#tuner-lock").is(":checked");
const autoShutdown = $("#shutdown-tuner").is(":checked");
const data = { const data = {
webserver: { webserver: {
@@ -244,7 +246,8 @@ function submitData() {
adminPass, adminPass,
}, },
publicTuner, publicTuner,
lockToAdmin lockToAdmin,
autoShutdown
}; };

View File

@@ -16,7 +16,7 @@
<% if (isAdminAuthenticated) { %> <% if (isAdminAuthenticated) { %>
<div class="panel-100 no-bg"> <div class="panel-100 no-bg">
<h1>FM-DX WebServer</h1> <h1>FM-DX WebServer</h1>
<h2>[ADMIN PANEL]</h2> <h2 class="text-monospace text-light">[ADMIN PANEL]</h2>
<p>This web setup allows you to set up your entire tuner. <br>Some settings will only change after a server restart.</p> <p>This web setup allows you to set up your entire tuner. <br>Some settings will only change after a server restart.</p>
<p>In case you are setting up the webserver for the first time, we already filled fail-safe defaults for you.</p> <p>In case you are setting up the webserver for the first time, we already filled fail-safe defaults for you.</p>
</div> </div>
@@ -51,7 +51,6 @@
<input class="input-text w-150" type="text" name="audio-port" id="audio-port" placeholder="8081"> <input class="input-text w-150" type="text" name="audio-port" id="audio-port" placeholder="8081">
</div> </div>
<br> <br>
<!--tune password, public/private tuner, admin password, verbose mode-->
</div> </div>
<div class="panel-50" style="min-height: 120px;margin-bottom: 0;"> <div class="panel-50" style="min-height: 120px;margin-bottom: 0;">
<h2>AUDIO SETTINGS</h2> <h2>AUDIO SETTINGS</h2>
@@ -147,6 +146,10 @@
<input type="checkbox" id="tuner-lock"> <input type="checkbox" id="tuner-lock">
<label for="tuner-lock">Lock to admin</label> <label for="tuner-lock">Lock to admin</label>
</div><br> </div><br>
<div class="form-group checkbox">
<input type="checkbox" id="shutdown-tuner">
<label for="shutdown-tuner">Auto-shutdown on empty server</label>
</div><br>
<div class="form-group"> <div class="form-group">
<label for="tune-pass">Tune password:</label> <label for="tune-pass">Tune password:</label>
<input class="input-text w-150" type="password" name="tune-pass" id="tune-pass"> <input class="input-text w-150" type="password" name="tune-pass" id="tune-pass">
@@ -179,8 +182,9 @@
<button onclick="document.location.href='./'" id="back-btn" aria-label="Go back to tuning"><i class="fa-solid fa-arrow-left"></i></button> <button onclick="document.location.href='./'" id="back-btn" aria-label="Go back to tuning"><i class="fa-solid fa-arrow-left"></i></button>
<% } else { %> <% } else { %>
<div class="panel-100 no-bg"> <div class="panel-100 no-bg">
<img src="../favicon2.png">
<h1>FM-DX WebServer</h1> <h1>FM-DX WebServer</h1>
<h2>[ADMIN PANEL]</h2> <h2 class="text-monospace text-light">[ADMIN PANEL]</h2>
<p>You are currently not logged in as an administrator and therefore can't change the settings.</p> <p>You are currently not logged in as an administrator and therefore can't change the settings.</p>
<p>Please login below.</p> <p>Please login below.</p>
</div> </div>