do http-callback

jobworker/lib/jobtask.js

@@ -18,6 +18,7 @@ function JobTask (prm)
   this.handle = prm.handle;
   this.mem = prm.handle.mem;
   this.jobcaller = prm.handle.jobcaller;
+  this.msgsender = prm.handle.msgsender;
   this.storagecaller = prm.handle.storagecaller;
   this.acl_validator = prm.handle.acl_validator
 
@@ -300,10 +301,12 @@ function perform_do(prm,cb)
   var DOTask = getPlugins('do',do_cfg.type);
   var doMem = new memstore({'job_id':job_id,'cat':'do','mem':prm.handle.mem});
   var jobcaller = prm.handle.jobcaller;
+  var msgsender = prm.handle.msgsender;
   var storagecaller = prm.handle.storagecaller;
   do_context.task = {
     "memstore" : doMem,
     "jobcaller" : jobcaller,
+    "msgsender" : msgsender,
     "storagecaller" : storagecaller
   }
 

plugins/do/do-http-callback/index.js

+var util = require('util');
+var DOPlugin = require('../do-plugin');
+
+function DOTask(context,request){
+  DOPlugin.call(this,context,request);
+  this.name = "http-callback";
+}
+util.inherits(DOTask,DOPlugin);
+
+DOTask.prototype.perform  =  require('./perform');
+
+module.exports = DOTask;

plugins/do/do-http-callback/perform.js

+
+var ctx = require('../../../context');
+var Utils = ctx.getLib('lib/util/plugin-utils');
+
+
+function perform_function(context,request,response){
+  var job_id = context.jobconfig.job_id;
+  var job_vo = context.jobconfig._vo || '';
+  var transaction_id = context.transaction.id;
+  var param = context.jobconfig.data_out.param;
+  var memstore = context.task.memstore;
+  var msgsender = context.task.msgsender;
+
+  var in_type = request.type;
+  var data = request.data;
+  var meta = request.meta;
+
+  var prm_session = param.session || meta._sid;
+
+  var ev =  {
+    'type' : in_type,
+    'meta' : meta,
+    'data' : data
+  }
+  
+  prm_session = Utils.vm_execute_text(ev,prm_session)
+  var topic = "msg.httpcb." + prm_session
+  var msg = {
+    'err':null,
+    'meta':meta,
+    'data':data
+  }
+
+  msgsender.send(topic,msg)
+
+  response.success();
+  //response.reject();
+  //response.error("error message")
+
+}
+
+module.exports = perform_function;