session

http-listener/ws/service-main.js

 var ctx = require('../../context');
 
+const uuid = require('uuid');
 var async = require('async');
 var express = require('express');
 var router = express.Router();
@@ -16,6 +17,7 @@ var process_req = function(req, res ,method) {
   var appkey = req.params.akey;
   var ctx = req.context;
 
+  var session_id = uuid.v4()
   var httpacl = req.context.httpacl;
   //var evp = req.context.evp;
   var jobcaller = req.context.jobcaller;
@@ -24,6 +26,7 @@ var process_req = function(req, res ,method) {
 
   var topic_prex = 'cmd.execute.';
 
+  var resp_msg = {'status':'OK'}
 
   j.forEach(function(item){
     var httpdata = {
@@ -45,6 +48,7 @@ var process_req = function(req, res ,method) {
       'source' : 'http_listener',
       'jobId' : '',
       'option' : {},
+      'input_meta' : {'_sid':session_id},
       'input_data' : {
         'type' : 'bsdata',
         'value' : {
@@ -55,22 +59,24 @@ var process_req = function(req, res ,method) {
       }
     }
 
-    var topic = topic_prex + item.jobid;
+    if(item.opt && item.opt.session){ resp_msg.session=session_id }
+
     var msg = job_execute_msg;
     msg.jobId = item.jobid;
 
     jobcaller.send(msg);
-    //evp.send(topic,msg);
+  
   });
 
   if(j.length > 0)
   {
-    respHelper.responseOK({'status':'OK'});
+    respHelper.responseOK(resp_msg);
   }else{
     respHelper.response403();
   }
 
 }
+
 router.get('/:akey',function(req, res){process_req(req,res,'get')});
 router.post('/:akey',function(req, res){process_req(req,res,'post')});
 

package.json

@@ -36,8 +36,10 @@
     "random-access-file": "^1.3.0",
     "redis": "^3.1.2",
     "request": "^2.79.0",
+    "socket.io": "^4.6.1",
     "thunky": "^1.0.2",
-    "tiny-worker": "^2.1.1"
+    "tiny-worker": "^2.1.1",
+    "uuid": "^9.0.0"
   },
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",