[#490] [add] impl

[r] to primary constructors

Author: i4004

src/Simplify.Scheduler/SchedulerExceptionArgs.cs

@@ -11,32 +11,27 @@ namespace Simplify.Scheduler;
 /// <summary>
 /// Provides scheduler exception event args
 /// </summary>
-public class SchedulerExceptionArgs
+/// <remarks>
+/// Initializes a new instance of the <see cref="SchedulerExceptionArgs"/> class.
+/// </remarks>
+/// <param name="appName">Name of the scheduling application.</param>
+/// <param name="exception">The exception.</param>
+public class SchedulerExceptionArgs(string appName, Exception exception)
 {
-	/// <summary>
-	/// Initializes a new instance of the <see cref="SchedulerExceptionArgs"/> class.
-	/// </summary>
-	/// <param name="appName">Name of the scheduling application.</param>
-	/// <param name="exception">The exception.</param>
-	public SchedulerExceptionArgs(string appName, Exception exception)
-	{
-		AppName = appName;
-		Exception = exception;
-	}
 
 	/// <summary>
 	/// Gets the name of the application.
 	/// </summary>
 	/// <value>
 	/// The name of the application.
 	/// </value>
-	public string AppName { get; }
+	public string AppName { get; } = appName;
 
 	/// <summary>
 	/// Gets the exception.
 	/// </summary>
 	/// <value>
 	/// The exception.
 	/// </value>
-	public Exception Exception { get; }
+	public Exception Exception { get; } = exception;
 }

src/Simplify.Scheduler/SchedulerJobsHandler.cs

@@ -145,12 +145,21 @@ protected async Task StartJobsAsync()
 	{
 		Console.WriteLine("Starting Scheduler jobs...");
 
-		foreach (var job in _jobs)
+		try
 		{
-			job.Start();
+			foreach (var job in _jobs)
+			{
+				job.Start();
 
-			if (!(job is ICrontabSchedulerJob))
-				await RunBasicJobAsync(job);
+				if (!(job is ICrontabSchedulerJob))
+					await RunBasicJobAsync(job);
+			}
+		}
+		catch (Exception e)
+		{
+			TryRaiseOnExceptionEvent(e);
+
+			throw;
 		}
 
 		Console.WriteLine("Scheduler jobs started.");
@@ -174,6 +183,22 @@ protected void StopJobs()
 		Console.WriteLine("All jobs finished.");
 	}
 
+	/// <summary>
+	/// Tries to raise the OnException event, returns true if the OnException event raised, otherwise false.
+	/// </summary>
+	/// <param name="e">The exception.</param>
+	protected bool TryRaiseOnExceptionEvent(Exception e)
+	{
+		if (OnException != null)
+		{
+			OnException(new SchedulerExceptionArgs(AppName, e));
+
+			return true;
+		}
+
+		return false;
+	}
+
 	/// <summary>
 	/// Releases unmanaged and - optionally - managed resources.
 	/// </summary>
@@ -252,9 +277,7 @@ private async Task Run(object? state)
 		}
 		catch (Exception e)
 		{
-			if (OnException != null)
-				OnException(new SchedulerExceptionArgs(AppName, e));
-			else
+			if (!TryRaiseOnExceptionEvent(e))
 				throw;
 		}
 		finally
@@ -292,9 +315,7 @@ private async Task RunBasicJobAsync(ISchedulerJobRepresentation job)
 		}
 		catch (Exception e)
 		{
-			if (OnException != null)
-				OnException(new SchedulerExceptionArgs(AppName, e));
-			else
+			if (!TryRaiseOnExceptionEvent(e))
 				throw;
 		}
 	}