Minor bug fixed

Fixed minor bugs introduced due to code streamlining

.gitignore

@@ -4,5 +4,4 @@ node_modules
 package-lock.json
 firecracker*
 secrets.json
-resource_manager/bin/**
-
+resource_manager/bin/**
\ No newline at end of file

dispatch_module/dispatch_daemon/config.json

-{"id":"192.168.31.51","master_node":"10.129.6.5"}
+{"id":"192.168.1.103","master_node":"10.129.6.5"}
\ No newline at end of file

dispatch_module/dispatch_daemon/index.js

@@ -41,7 +41,7 @@ libSupport.makeTopic(node_id).then(() => {
             if (message.type === "execute") {
                 console.log("function_id", function_id);
                 libSupport.download(host_url + "/repository/" + functionHash, local_repository + functionHash).then(() => {
-                    startWorker(local_repository, functionHash, producer, runtime)
+                    startWorker(local_repository, functionHash, function_id, producer, runtime)
                 })
 
             }
@@ -51,7 +51,7 @@ libSupport.makeTopic(node_id).then(() => {
 })
     
 
-function startWorker(local_repository, functionHash, producer, runtime) {
+function startWorker(local_repository, functionHash,function_id, producer, runtime) {
     if (runtime === "isolate")
         execute.runIsolate(local_repository + functionHash).then(result => {
             producer.send([{

dispatch_module/dispatch_daemon/lib.js

@@ -46,7 +46,7 @@ function makeTopic(id) {
 var download = function (url, dest, cb) {
     return new Promise((resolve, reject) => {
         console.log(url);
-        if (!fs.existsSync(local_repository + functionHash)) {
+        if (!fs.existsSync(dest)) {
             var file = fs.createWriteStream(dest);
             var request = http.get(url, function (response) {
                 response.pipe(file);

dispatch_module/dispatcher/index.js

@@ -222,6 +222,7 @@ 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);