Schedule a job when a trigger is created/updated

Author: ethanhann

IntegrationEngine/Api/Controllers/CronTriggerController.cs

@@ -45,6 +45,7 @@ public IHttpActionResult PutIntegrationJob(string id, CronTrigger trigger)
             if (id != trigger.Id)
                 return BadRequest();
             Repository.Update(trigger);
+            EngineScheduler.ScheduleJobWithCronTrigger(trigger);
             return StatusCode(HttpStatusCode.NoContent);
         }
 

IntegrationEngine/Api/Controllers/SimpleTriggerController.cs

@@ -16,14 +16,16 @@ namespace IntegrationEngine.Api.Controllers
     public class SimpleTriggerController : ApiController
     {
         public IRepository<SimpleTrigger> Repository { get; set; }
+        public IEngineScheduler EngineScheduler { get; set; }
 
         public SimpleTriggerController()
         {}
 
-        public SimpleTriggerController(ESRepository<SimpleTrigger> repository)
+        public SimpleTriggerController(ESRepository<SimpleTrigger> repository, IEngineScheduler engineScheduler)
             : this()
         {
             Repository = repository;
+            EngineScheduler = engineScheduler;
         }
 
         // GET api/IntegrationJob
@@ -48,6 +50,7 @@ public IHttpActionResult PutIntegrationJob(string id, SimpleTrigger trigger)
             if (id != trigger.Id)
                 return BadRequest();
             Repository.Update(trigger);
+            EngineScheduler.ScheduleJobWithSimpleTrigger(trigger);
             return StatusCode(HttpStatusCode.NoContent);
         }
 
@@ -56,6 +59,7 @@ public IHttpActionResult PutIntegrationJob(string id, SimpleTrigger trigger)
         public IHttpActionResult PostIntegrationJob(SimpleTrigger trigger)
         {
             var triggerWithId = Repository.Insert(trigger);
+            EngineScheduler.ScheduleJobWithSimpleTrigger(triggerWithId);
             return CreatedAtRoute("DefaultApi", new { id = triggerWithId.Id }, triggerWithId);
         }