diff --git a/server.js b/server.js index 03a3cfe..e8281e6 100644 --- a/server.js +++ b/server.js @@ -3,6 +3,7 @@ const http = require('http'); const WebSocket = require('ws'); const axios = require('axios'); +const argv = require('yargs').argv; const app = express(); const server = http.createServer(app); const wss = new WebSocket.Server({ server }); @@ -15,13 +16,18 @@ wss.on('connection', (ws) => { console.log('Client connected'); }); +const debugMode = argv.debug || false; + setInterval(async () => { + const query = debugMode + ? 'query=_time:2024-06-27T05:13:52 relay received' + : 'query=_time:5s relay received'; try { - const response = await axios.post('https://vmselect.riff.cc/select/logsql/query', 'query=_time:2024-06-27T05:13 relay received'); + const response = await axios.post('https://vmselect.riff.cc/select/logsql/query', query); try { const responseData = JSON.parse(response.data); console.log('Parsed response data:', responseData); - const logs = responseData.data; // Assuming the logs are in responseData.data + logs = responseData.data; // Assuming the logs are in responseData.data } catch (parseError) { console.error('Error parsing response data:', parseError); const logLines = response.data.split('\n'); @@ -34,7 +40,7 @@ setInterval(async () => { console.error(`Error parsing log line at index ${index}:`, line); } }); - const logs = validLogs; + logs = validLogs; } console.log('Logs response:', logs); @@ -69,9 +75,10 @@ setInterval(async () => { } else { console.error('Logs response is not an array:', logs); } - } catch (error) { - console.error('Error querying logs:', error); } +} catch (error) { + console.error('Error querying logs:', error); +} }, 3000); server.listen(3000, () => {