perf: clean seens msgs

lib/common/createData.js

@@ -1,5 +1,4 @@
 const createData = (type, data) => ({ type, data });
-
 const createMessage = ({ type, to, message, messageId, ttl }) => ({
   messageId,
   ...createData(type, message),

lib/connection.js

@@ -16,7 +16,6 @@ class Connection extends EventEmitter {
     socket.connect(targetNode, () => this.#handleConnection(socket));
   }
 
-  /**@param {net.Socket} socket*/
   #handleConnection(socket) {
     const connectionId = uuid();
     socket.setNoDelay(false);

lib/constants.js

@@ -1,15 +1,17 @@
-const HANDSHAKE = 'HANDSHAKE';
-const DM = 'MESSAGE';
 const CHECK_INTERVAL = 500;
-const TIMEOUT_DURATION = 20000;
+const TIMEOUT_DURATION = 2 * 60000;
+const TIME_CLEAN_MSG = 30 * 60000;
 const TTL = 300;
+const HANDSHAKE = 'HANDSHAKE';
+const DM = 'MESSAGE';
 const TIMEOUT_ERROR_MESSAGE = `Neighbor check timed out after ${TIMEOUT_DURATION / 1000} seconds`;
 
 module.exports = {
   HANDSHAKE,
-  DM,
+  TIME_CLEAN_MSG,
   CHECK_INTERVAL,
   TIMEOUT_DURATION,
   TIMEOUT_ERROR_MESSAGE,
   TTL,
+  DM,
 };

lib/messaging.js

@@ -8,16 +8,18 @@ const {
   TIMEOUT_DURATION,
   TIMEOUT_ERROR_MESSAGE,
   TTL,
+  TIME_CLEAN_MSG,
 } = require('./constants');
 
 class Messaging extends Connection {
   NODE_ID = uuid();
   neighbors = new Map();
-  seenMessages = new Set();
+  seenMessages = new Set('sd', 'sd');
 
-  constructor(port, targetNode, nodeId) {
+  constructor(port, nodeId, targetNode) {
     super(port, targetNode);
     if (nodeId) this.NODE_ID = nodeId;
+    this.#cleanSeenMessages();
   }
 
   _newConnection(connectionId) {
@@ -83,10 +85,14 @@ class Messaging extends Connection {
   [DM](_, messageObject) {
     const { messageId, data, to, ttl } = messageObject;
     if (to === this.NODE_ID) return void this.emit(DM, data);
-    const isProcessed = this.seenMessages.has(messageId);
-    if (ttl < 1 || isProcessed) return;
+    const isSeenMessage = this.seenMessages.has(messageId);
+    if (ttl < 1 || isSeenMessage) return;
     this.#broadcast(to, data, { messageId, ttl: ttl - 1 });
   }
+
+  #cleanSeenMessages() {
+    setTimeout(() => this.seenMessages.clear(), TIME_CLEAN_MSG);
+  }
 }
 
 module.exports = Messaging;