--no commit message

--no commit message

test/jobs/example.json

@@ -8,7 +8,7 @@
   "data_in" : {
     "type": "example"
   },
-  "data_transfrom" : {
+  "data_transform" : {
     "type": "noop"
   },
   "data_out" : {

test/playjob.js

@@ -48,7 +48,7 @@ function run_job(cfg)
 
   //process di
   perform_di(context,function(err,resp){
-      if(resp.status == 'success' && context.jobconfig.data_transfrom){
+      if(resp.status == 'success' && context.jobconfig.data_transform){
         var dt_request = {'type':resp.type,'data':resp.data}
         perform_dt(context,dt_request,function(err,dt_resp){
 
@@ -93,7 +93,7 @@ function perform_dt(context,request,cb)
   var dt_context = context
 
   var jobId = dt_context.jobconfig.job_id;
-  var dt_cfg = dt_context.jobconfig.data_transfrom;
+  var dt_cfg = dt_context.jobconfig.data_transform;
 
   console.log('[DT_PLUGIN]\t\t: ' + dt_cfg.type);
   var DITask = getPlugins('dt',dt_cfg.type);
@@ -113,6 +113,31 @@ function perform_dt(context,request,cb)
   });
 }
 
+function perform_do(context,request,cb)
+{
+  console.log('\n\n[RUNNING DO]');
+  var do_context = context
+
+  var jobId = do_context.jobconfig.job_id;
+  var do_cfg = do_context.jobconfig.data_out;
+
+  console.log('[DO_PLUGIN]\t\t: ' + do_cfg.type);
+  var DOTask = getPlugins('do',do_cfg.type);
+  var mempref = "ms." + jobId + '.do';
+  var doMem = new memstore(mempref,storage);
+  do_context.task = {
+    "memstore" : doMem
+  }
+
+  var dout = new DOTask(do_context,request);
+  dout.run();
+  dout.on('done',function(resp){
+    console.log('[DO_STATUS]\t\t: ' + resp.status);
+    console.log('>>' + resp.data);
+    cb(null,resp);
+  });
+}
+
 function getPlugins(type,name)
 {
   var path = '../plugins/' + type + '/' + type + '-' +name;