Timestamped Heartbeat

Added timestamp support to heartbeat for removing stale messages

dispatch_module/dispatch_daemon/index.js

@@ -101,7 +101,7 @@ function startWorker(local_repository, functionHash,function_id, producer, runti
 function heartbeat() {
     let payload = [{
         topic: "heartbeat",
-        messages: JSON.stringify({"address": node_id})
+        messages: JSON.stringify({"address": node_id, "timestamp": Date.now()})
     }]
     producer.send(payload, function() {
 

dispatch_module/dispatcher/index.js

@@ -222,11 +222,11 @@ consumer.on('message', function (message) {
         db.delete(message.function_id)
     } else if (topic === "heartbeat") {
         message = JSON.parse(message)
-        
-        if (workerNodes.indexOf(message.address) === -1)  {
-            workerNodes.push(message.address)
-            console.log(workerNodes);
-        }
+        if (Date.now() - message.timestamp < 300)
+            if (workerNodes.indexOf(message.address) === -1)  {
+                workerNodes.push(message.address)
+                console.log(workerNodes);
+            }
     }
 });