Remove trigger from scheduler when it is deleted

Author: ethanhann

IntegrationEngine/Api/Controllers/CronTriggerController.cs

@@ -71,6 +71,7 @@ public IHttpActionResult DeleteCronTrigger(string id)
             if (trigger == null)
                 return NotFound();
             Repository.Delete(trigger.Id);
+            EngineScheduler.DeleteTrigger(trigger);
             return Ok(trigger);
         }
     }

IntegrationEngine/Api/Controllers/SimpleTriggerController.cs

@@ -75,6 +75,7 @@ public IHttpActionResult DeleteSimpleTrigger(string id)
             if (trigger == null)
                 return NotFound();
             Repository.Delete(trigger.Id);
+            EngineScheduler.DeleteTrigger(trigger);
             return Ok(trigger);
         }
     }

IntegrationEngine/Scheduler/EngineScheduler.cs

@@ -144,5 +144,12 @@ public ITrigger CronTriggerFactory(CronTrigger triggerDefinition, Type jobType,
             triggerBuilder.WithCronSchedule(triggerDefinition.CronExpressionString, x => x.InTimeZone(triggerDefinition.TimeZoneInfo));
             return triggerBuilder.Build();
         }
+
+        public bool DeleteTrigger(IIntegrationJobTrigger triggerDefinition)
+        {
+            var jobType = GetRegisteredJobTypeByName(triggerDefinition.JobType);
+            var triggerKey = TriggerKeyFactory(triggerDefinition, jobType);
+            return Scheduler.UnscheduleJob(triggerKey);
+        }
     }
 }

IntegrationEngine/Scheduler/IEngineScheduler.cs

@@ -12,6 +12,7 @@ public interface IEngineScheduler
         void ScheduleJobWithSimpleTrigger(SimpleTrigger triggerDefinition);
         bool IsJobTypeRegistered(string jobTypeName);
         Type GetRegisteredJobTypeByName(string jobTypeName);
+        bool DeleteTrigger(IIntegrationJobTrigger triggerDefinition);
         void Shutdown();
     }
 }