Added support for dynamic idle time via HTTP requests

dispatch_system/dispatch_daemon/config.json

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

dispatch_system/dispatch_manager/repository/worker_env/env.js

@@ -5,7 +5,7 @@ let request = require('request')
 const process = require('process')
 
 const app = express()
-let port = 5000, resource_id, functionHash, runtime
+let port = 5000, resource_id, functionHash, runtime, idleTime = 30
 
 resource_id = process.argv[2]
 functionHash = process.argv[3]
@@ -25,46 +25,54 @@ let kafka = require('kafka-node'),
 
 app.use(bodyParser.urlencoded({ extended: true }))
 app.use(bodyParser.json())
-let lastRequest = Date.now()
+
+let lastRequest = Date.now(), totalRequest = 0
 app.post('/serverless/function/execute/', (req, res) => {
     let payload = req.body
     lastRequest = Date.now()
+    totalRequest++
     executor(payload).then((result) => {
         res.json(result)
     })
 })
 
+app.post('/serverless/worker/timeout', (req, res) => {
+    idleTime = req.body.timeout
+    console.log("Idle time set to: ", idleTime);
+    
+})
+
 function executor(payload) {
     return new Promise((resolve, reject) => {
         
     })
 }
 
-app.post('/serverless/function/execute/2', (req, res) => {
-    
-    console.log("2", JSON.stringify(req.headers))
-    res.send("done")
-})
-
 app.listen(port, () => {
     console.log(`Resource ${resource_id} Server listening on port ${port}!`)
     producer.send(
     [{
         topic: "deployed",
-        messages: JSON.stringify({ functionHash, portExternal: port, runtime, resource_id, entity_id: process.pid}),
+        messages: JSON.stringify({ functionHash, portExternal: port, 
+            runtime, resource_id, entity_id: process.pid}),
         "status": true
     }], () => { })
 })
 
 function shouldDie() {
     
-    if (Date.now() - lastRequest > 30 * 1000) {
+    if (Date.now() - lastRequest > idleTime * 1000) {
+        let message = JSON.stringify({
+            functionHash, portExternal: port,
+            runtime, resource_id, entity_id: process.pid,
+            total_request: totalRequest
+        })
+
         console.log("Idle for too long. Exiting");
         producer.send(
-            [{
-                topic: "removeWorker",
-                messages: JSON.stringify({ functionHash, portExternal: port, runtime, resource_id, entity_id: process.pid})
-            }], () => {
+            [
+                {topic: "removeWorker", messages: message }
+            ], () => {
                 console.log("Ending worker for function", functionHash, "resource_id", resource_id);
                 process.exit(0)
             })