--no commit message

--no commit message

coreservice/controller-api.js

@@ -5,7 +5,8 @@ var app = express();
 var bodyParser = require('body-parser');
 
 var ConnCtx = ctx.getLib('lib/conn/connection-context');
-var JobManager = require('./lib/job-manager')
+var JobManager = require('./lib/job-manager');
+var TriggerManager = require('./lib/trigger-manager')
 
 var API_PORT = 19980;
 module.exports.create = function(cfg)
@@ -40,7 +41,8 @@ ControllerAPI.prototype._http_start = function()
   var context = ctx.getLib('lib/ws/http-context');
   app.use(context.middleware({
     'conn' : self.conn,
-    'jobManager' : JobManager.create({'conn' : self.conn})
+    'jobManager' : JobManager.create({'conn' : self.conn}),
+    'triggerManager' : triggerManager.create({'conn' : self.conn})
   }));
 
   app.use(require('./ws'));

coreservice/lib/trigger-manager.js

+var ctx = require('../../context');
+var cfg = ctx.config;
+
+var JobRegistry = ctx.getLib('lib/mems/job-registry');
+var TriggerRegistry = ctx.getLib('lib/mems/trigger-registry');
+var JUtils = ctx.getLib('lib/job/jobutils');
+var EvenPub = ctx.getLib('lib/amqp/event-pub');
+
+module.exports.create = function(cfg)
+{
+  return new TriggerManager(cfg);
+}
+
+function TriggerManager (cfg)
+{
+  this.config = cfg;
+  this.conn = cfg.conn;
+  this.mem = this.conn.getMemstore();
+  this.evp = new EvenPub({'url':this.conn.getAmqpUrl(),'name':'bs_trigger_cmd'});
+
+  // this.job_registry = JobRegistry.create({'redis':this.mem});
+  // this.trigger_registry = TriggerRegistry.create({'redis':this.mem});
+}
+
+TriggerManager.prototype.reload = function (prm,cb)
+{
+  var self = this;
+  var topic = 'ctl.trigger.all.reload';
+  var msg = {
+    'trigger_type' : 'all',
+    'cmd' : 'reload',
+    'prm' : {}
+  }
+
+  self.evp.send(topic,msg);
+  cb(null);
+}

coreservice/ws/v1/ws-jobs.js

@@ -37,8 +37,10 @@ router.get('/:jid',function (req, res) {
 router.post('/',function (req, res) {
     var reqHelper = request.create(req);
     var respHelper = response.create(res);
+    var q = req.getQuery()
     var jm = req.context.jobManager;
-    
+    var tm = req.context.triggerManager;
+
     var json_job = req.body;
 
     jm.setJob({'job':json_job},function(err,res){
@@ -46,6 +48,9 @@ router.post('/',function (req, res) {
       {
         respHelper.response400(err);
       }else{
+        if(q.reload){
+          tm.reload();
+        }
         respHelper.response201();
       }
     });