diff --git a/app.js b/app.js index aa6c3f5..e5d0b70 100644 --- a/app.js +++ b/app.js @@ -768,7 +768,19 @@ function addMessageToStore(topic, messageObj) { if (!messagesStore[topic]) { messagesStore[topic] = []; } - messagesStore[topic].push(messageObj); + + // Check for duplicates + const isDuplicate = messagesStore[topic].some(msg => + msg.from === messageObj.from && + msg.message === messageObj.message && + msg.timestamp === messageObj.timestamp + ); + + if (!isDuplicate) { + messagesStore[topic].push(messageObj); + } else { + console.log('Duplicate message detected:', messageObj); // Debugging log + } } function loadConfigFromFile() {