Added support for a debug mode that queries logs for a specific timestamp.

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, () => {