New: AfterRunFail event with Exception info

Author: justdmitry

src/RecurrentTasks/ExceptionEventArgs.cs

@@ -0,0 +1,18 @@
+namespace RecurrentTasks
+{
+    using System;
+
+    public class ExceptionEventArgs : EventArgs
+    {
+        public ExceptionEventArgs(Exception exception)
+        {
+            if (exception == null)
+            {
+                throw new ArgumentNullException(nameof(exception));
+            }
+            this.Exception = exception;
+        }
+
+        public Exception Exception { get; protected set; }
+    }
+}

src/RecurrentTasks/TaskBase.cs

@@ -28,6 +28,8 @@ public TaskBase(ILoggerFactory loggerFactory, TimeSpan interval, IServiceScopeFa
             RunStatus = new TRunStatus();
         }
 
+        public event EventHandler<ExceptionEventArgs> AfterRunFail;
+
         TaskRunStatus ITask.RunStatus { get { return RunStatus; } }
 
         public TRunStatus RunStatus { get; protected set; }
@@ -138,7 +140,7 @@ protected void MainLoop(TimeSpan initialTimeout)
                     }
                     catch (Exception ex)
                     {
-                        Logger.LogWarning("Ooops, error (ignoring, see RunStatus.LastException):", ex);
+                        Logger.LogWarning(0, ex, "Ooops, error (ignoring, see RunStatus.LastException or handle AfterRunFail event)");
                         RunStatus.LastResult = TaskRunResult.Fail;
                         RunStatus.LastException = ex;
                         if (RunStatus.FailsCount == 0)
@@ -149,6 +151,15 @@ protected void MainLoop(TimeSpan initialTimeout)
                         IsRunningRightNow = false;
 
                         OnAfterRunFail();
+
+                        try
+                        {
+                            AfterRunFail?.Invoke(this, new ExceptionEventArgs(ex));
+                        }
+                        catch (Exception ex2)
+                        {
+                            Logger.LogError(0, ex2, "Error while processing AfterRunFail event (ignored)");
+                        }
                     }
                     finally
                     {

src/RecurrentTasks/project.json

@@ -1,12 +1,12 @@
 {
-  "version": "2.1.0",
+  "version": "2.2.0",
   "title": "RecurrentTasks",
   "copyright": "Dmitry Popov, 2016",
   "packOptions": {
     "summary": "RecurrentTasks for .NET allows you to run simple recurrent background tasks with specific intervals, without complex frameworks, persistance, etc...",
     "tags": [ "task", "job", "recurrent", "recurring", "aspnetcore" ],
     "owners": [ "Dmitry Popov" ],
-    "releaseNotes": "Upgrade to RC2 and netstandard",
+    "releaseNotes": "New: AfterRunFail event (with Exception info)",
     "licenseUrl": "https://github.com/justdmitry/RecurrentTasks/blob/master/LICENSE",
     "projectUrl": "https://github.com/justdmitry/RecurrentTasks",
     "repository": {

test/RecurrentTasks.Tests/TaskBaseTests.cs

@@ -175,5 +175,26 @@ public void Task_RunningAgainAfterException()
             // should run again - waiting twice default interval
             Assert.True(sampleTask.TaskRunCalled.Wait(TimeSpan.FromSeconds(10)));
         }
+
+        [Fact]
+        public void Task_AfterRunFailGeneratedAfterException()
+        {
+            var eventGenerated = false;
+
+            sampleTask.MustThrowError = true;
+            sampleTask.AfterRunFail += (object sender, ExceptionEventArgs e) =>
+            {
+                eventGenerated = true;
+            }; 
+
+            sampleTask.Start(TimeSpan.FromSeconds(2));
+
+            // waiting 5 seconds max, then failing
+            Assert.True(sampleTask.TaskRunCalled.Wait(TimeSpan.FromSeconds(5)));
+
+            System.Threading.Thread.Sleep(200); // wait for run cycle completed
+
+            Assert.True(eventGenerated);
+        }
     }
 }