mirror of
https://github.com/KubaPro010/fm-dx-webserver.git
synced 2026-07-30 16:59:15 +02:00
some fixes
This commit is contained in:
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
const WebSocket = require('ws');
|
const WebSocket = require('ws');
|
||||||
const { serverConfig, configExists } = require('./server_config');
|
const { serverConfig, configExists } = require('./server_config');
|
||||||
const { logChat } = require('./console');
|
const { logInfo } = require('./console');
|
||||||
const helpers = require('./helpers');
|
const helpers = require('./helpers');
|
||||||
const storage = require('./storage.js');
|
const storage = require('./storage.js');
|
||||||
|
|
||||||
@@ -85,7 +85,7 @@ function createChatServer() {
|
|||||||
storage.chatHistory.push(messageData);
|
storage.chatHistory.push(messageData);
|
||||||
if (storage.chatHistory.length > 50) storage.chatHistory.shift();
|
if (storage.chatHistory.length > 50) storage.chatHistory.shift();
|
||||||
|
|
||||||
logChat(messageData);
|
logInfo(`${message.nickname} (${message.ip}) sent a chat message: ${message.message}`);
|
||||||
|
|
||||||
chatWss.clients.forEach((client) => {
|
chatWss.clients.forEach((client) => {
|
||||||
if (client.readyState === WebSocket.OPEN) {
|
if (client.readyState === WebSocket.OPEN) {
|
||||||
|
|||||||
+6
-17
@@ -1,7 +1,6 @@
|
|||||||
const fs = require('fs').promises;
|
const fs = require('fs').promises;
|
||||||
|
|
||||||
const verboseMode = process.argv.includes('--debug');
|
const verboseMode = process.argv.includes('--debug');
|
||||||
const verboseModeFfmpeg = process.argv.includes('--ffmpegdebug');
|
|
||||||
|
|
||||||
const LOG_FILE = process.argv.includes('--config') && process.argv[process.argv.indexOf('--config') + 1]
|
const LOG_FILE = process.argv.includes('--config') && process.argv[process.argv.indexOf('--config') + 1]
|
||||||
? `serverlog_${process.argv[process.argv.indexOf('--config') + 1]}.txt`
|
? `serverlog_${process.argv[process.argv.indexOf('--config') + 1]}.txt`
|
||||||
@@ -15,13 +14,10 @@ let logBuffer = [];
|
|||||||
|
|
||||||
// Message prefixes with ANSI codes
|
// Message prefixes with ANSI codes
|
||||||
const MESSAGE_PREFIX = {
|
const MESSAGE_PREFIX = {
|
||||||
CHAT: "\x1b[36m[CHAT]\x1b[0m",
|
|
||||||
DEBUG: "\x1b[36m[DEBUG]\x1b[0m",
|
DEBUG: "\x1b[36m[DEBUG]\x1b[0m",
|
||||||
ERROR: "\x1b[31m[ERROR]\x1b[0m",
|
ERROR: "\x1b[31m[ERROR]\x1b[0m",
|
||||||
FFMPEG: "\x1b[36m[FFMPEG]\x1b[0m",
|
|
||||||
INFO: "\x1b[32m[INFO]\x1b[0m",
|
INFO: "\x1b[32m[INFO]\x1b[0m",
|
||||||
WARN: "\x1b[33m[WARN]\x1b[0m",
|
WARN: "\x1b[33m[WARN]\x1b[0m",
|
||||||
SECURITY: "\x1b[36m[SECURITY]\x1b[0m",
|
|
||||||
};
|
};
|
||||||
|
|
||||||
const getCurrentTime = () => {
|
const getCurrentTime = () => {
|
||||||
@@ -36,28 +32,21 @@ const removeANSIEscapeCodes = (str) => str.replace(ANSI_ESCAPE_CODE_PATTERN, '')
|
|||||||
const logMessage = (type, messages) => {
|
const logMessage = (type, messages) => {
|
||||||
const logMessage = `${getCurrentTime()} ${MESSAGE_PREFIX[type]} ${messages.join(' ')}`;
|
const logMessage = `${getCurrentTime()} ${MESSAGE_PREFIX[type]} ${messages.join(' ')}`;
|
||||||
|
|
||||||
if ((type === 'DEBUG' && verboseMode) || (type === 'FFMPEG' && verboseModeFfmpeg) || type !== 'DEBUG' && type !== 'FFMPEG') {
|
if ((type === 'DEBUG' && verboseMode) || type !== 'DEBUG') {
|
||||||
logs.push(logMessage);
|
logs.push(logMessage);
|
||||||
if (logs.length > maxConsoleLogLines) logs.shift();
|
if (logs.length > maxConsoleLogLines) logs.shift();
|
||||||
console.log(logMessage);
|
console.log(logMessage);
|
||||||
}
|
}
|
||||||
|
|
||||||
if(type !== 'FFMPEG') appendLogToBuffer(logMessage);
|
logBuffer.push(removeANSIEscapeCodes(logMessage) + '\n');
|
||||||
};
|
};
|
||||||
|
|
||||||
const logSecurity = (...messages) => logMessage('SECURITY', messages);
|
|
||||||
const logDebug = (...messages) => logMessage('DEBUG', messages);
|
|
||||||
const logChat = (message) => logMessage('CHAT', [`${message.nickname} (${message.ip}) sent a chat message: ${message.message}`]);
|
|
||||||
const logError = (...messages) => logMessage('ERROR', messages);
|
const logError = (...messages) => logMessage('ERROR', messages);
|
||||||
const logFfmpeg = (...messages) => logMessage('FFMPEG', messages, verboseModeFfmpeg);
|
|
||||||
const logInfo = (...messages) => logMessage('INFO', messages);
|
|
||||||
const logWarn = (...messages) => logMessage('WARN', messages);
|
const logWarn = (...messages) => logMessage('WARN', messages);
|
||||||
|
const logInfo = (...messages) => logMessage('INFO', messages);
|
||||||
|
const logDebug = (...messages) => logMessage('DEBUG', messages);
|
||||||
|
|
||||||
function appendLogToBuffer(logMessage) {
|
logBuffer.push("Server started.");
|
||||||
const cleanLogMessage = removeANSIEscapeCodes(logMessage);
|
|
||||||
logBuffer.push(cleanLogMessage + '\n');
|
|
||||||
}
|
|
||||||
appendLogToBuffer("Server started.");
|
|
||||||
|
|
||||||
async function flushLogBuffer() {
|
async function flushLogBuffer() {
|
||||||
if (logBuffer.length === 0) return;
|
if (logBuffer.length === 0) return;
|
||||||
@@ -90,4 +79,4 @@ process.on('exit', flushLogBuffer);
|
|||||||
process.on('SIGINT', gracefulExit);
|
process.on('SIGINT', gracefulExit);
|
||||||
process.on('SIGTERM', gracefulExit);
|
process.on('SIGTERM', gracefulExit);
|
||||||
|
|
||||||
module.exports = { logError, logDebug, logFfmpeg, logInfo, logWarn, logs, logChat, logSecurity };
|
module.exports = { logError, logDebug, logInfo, logWarn, logs };
|
||||||
+1
-1
@@ -433,7 +433,7 @@ function getIpAddress(request) {
|
|||||||
const xff = request.headers['x-forwarded-for'];
|
const xff = request.headers['x-forwarded-for'];
|
||||||
|
|
||||||
if (xff && !isLocalhost(remoteIp) && !isTrustedProxy(remoteIp)) {
|
if (xff && !isLocalhost(remoteIp) && !isTrustedProxy(remoteIp)) {
|
||||||
consoleCmd.logSecurity(`Untrusted proxy tried to set X-Forwarded-For: ${xff} (remote: ${remoteIpRaw})`);
|
consoleCmd.logWarn(`Untrusted proxy tried to set X-Forwarded-For: ${xff} (remote: ${remoteIpRaw})`);
|
||||||
return remoteIp;
|
return remoteIp;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ const { serverConfig, configExists } = require('../server_config');
|
|||||||
if (!configExists() || !serverConfig.audio.audioDevice) return;
|
if (!configExists() || !serverConfig.audio.audioDevice) return;
|
||||||
|
|
||||||
const { spawn } = require('child_process');
|
const { spawn } = require('child_process');
|
||||||
const { logDebug, logError, logInfo, logWarn, logFfmpeg } = require('../console');
|
const { logDebug, logError, logInfo, logWarn } = require('../console');
|
||||||
const checkFFmpeg = require('./checkFFmpeg');
|
const checkFFmpeg = require('./checkFFmpeg');
|
||||||
|
|
||||||
const consoleLogTitle = '[Audio Stream]';
|
const consoleLogTitle = '[Audio Stream]';
|
||||||
@@ -84,7 +84,7 @@ checkFFmpeg().then((ffmpegPath) => {
|
|||||||
|
|
||||||
ffmpeg.stderr.on('data', (data) => {
|
ffmpeg.stderr.on('data', (data) => {
|
||||||
const msg = data.toString();
|
const msg = data.toString();
|
||||||
logFfmpeg(`[FFmpeg stderr]: ${msg}`);
|
logError(`[FFmpeg stderr]: ${msg}`);
|
||||||
|
|
||||||
// Detect frozen timestamps
|
// Detect frozen timestamps
|
||||||
const match = msg.match(/time=(\d\d):(\d\d):(\d\d\.\d+)/);
|
const match = msg.match(/time=(\d\d):(\d\d):(\d\d\.\d+)/);
|
||||||
|
|||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
const { logDebug, logError, logInfo, logWarn, logFfmpeg } = require('./console');
|
const { logDebug, logError, logInfo, logWarn } = require('./console');
|
||||||
const { serverConfig } = require('./server_config');
|
const { serverConfig } = require('./server_config');
|
||||||
const { Readable } = require('stream');
|
const { Readable } = require('stream');
|
||||||
const { finished } = require('stream/promises');
|
const { finished } = require('stream/promises');
|
||||||
|
|||||||
@@ -91,9 +91,13 @@ function populateFields(data, prefix = "") {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function safeId(str) {
|
||||||
|
return str.replace(/[^a-zA-Z0-9_-]/g, "_");
|
||||||
|
}
|
||||||
|
|
||||||
function updateConfigData(data, prefix = "") {
|
function updateConfigData(data, prefix = "") {
|
||||||
$.each(data, (key, value) => {
|
$.each(data, (key, value) => {
|
||||||
const id = `${prefix}${prefix ? "-" : ""}${key}`;
|
let id = `${prefix}${prefix ? "-" : ""}${safeId(key)}`;
|
||||||
const $element = $(`#${id}`);
|
const $element = $(`#${id}`);
|
||||||
|
|
||||||
if (key === "presets") {
|
if (key === "presets") {
|
||||||
|
|||||||
Reference in New Issue
Block a user