From a5a4e0d1f6e91ee68e9ef65695d492118d8f0ca2 Mon Sep 17 00:00:00 2001 From: "Benjamin Arntzen (aider)" Date: Thu, 27 Jun 2024 06:42:59 +0100 Subject: [PATCH] Improved log processing by adding index logging, client count logging, and client address logging when sending events. --- server.js | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/server.js b/server.js index abb5070..e964a9b 100644 --- a/server.js +++ b/server.js @@ -67,7 +67,8 @@ setInterval(async () => { logs = validLogs; if (Array.isArray(logs)) { console.log('Processing logs array'); - logs.forEach(log => { + logs.forEach((log, index) => { + console.log(`Processing log at index ${index}:`, log); const msgMatch = log._msg.match(/msg_hash=0x[0-9a-fA-F]+/); const timeMatch = log._msg.match(/receivedTime=\d+/); const nodeIdMatch = log.kubernetes_pod_name.match(/nodes-(\d+)/); @@ -95,8 +96,12 @@ setInterval(async () => { } else { console.log(`Sending "light up node ${logData.nodeId}" event to clients`); } + + console.log('Number of connected clients:', wss.clients.size); + wss.clients.forEach(client => { if (client.readyState === WebSocket.OPEN) { + console.log(`Sending event to client ${client._socket.remoteAddress}`); client.send(JSON.stringify(logData)); } });