feat: Add TimeFileScheduleWorker and let the sample-app use it

Author: davidkallesen

sample/Atc.Hosting.TimeFile.Sample/Program.cs

@@ -9,9 +9,13 @@
     .ConfigureServices(services =>
     {
         services.AddSingleton<ITimeProvider, SystemTimeProvider>();
+
         services.Configure<TimeFileWorkerOptions>(configuration.GetSection(TimeFileWorkerOptions.SectionName));
         services.AddHostedService<TimeFileWorker>();
 
+        services.Configure<TimeFileScheduleWorkerOptions>(configuration.GetSection(TimeFileScheduleWorkerOptions.SectionName));
+        services.AddHostedService<TimeFileScheduleWorker>();
+
         services.AddSingleton<IBackgroundServiceHealthService, BackgroundServiceHealthService>(s =>
         {
             var healthService = new BackgroundServiceHealthService(s.GetRequiredService<ITimeProvider>());
@@ -24,4 +28,4 @@
     })
     .Build();
 
-host.Run();
+await host.RunAsync();

sample/Atc.Hosting.TimeFile.Sample/TimeFileScheduleWorker.cs

@@ -0,0 +1,66 @@
+namespace Atc.Hosting.TimeFile.Sample;
+
+public class TimeFileScheduleWorker : BackgroundScheduleServiceBase<TimeFileScheduleWorker>
+{
+    private readonly ITimeProvider timeProvider;
+
+    private readonly TimeFileScheduleWorkerOptions workerOptions;
+
+    public TimeFileScheduleWorker(
+        ILogger<TimeFileScheduleWorker> logger,
+        IBackgroundServiceHealthService healthService,
+        ITimeProvider timeProvider,
+        IOptions<TimeFileScheduleWorkerOptions> workerOptions)
+        : base(
+            logger,
+            workerOptions.Value,
+            healthService)
+    {
+        this.timeProvider = timeProvider;
+        this.workerOptions = workerOptions.Value;
+    }
+
+    public override Task StartAsync(
+        CancellationToken cancellationToken)
+    {
+        return base.StartAsync(cancellationToken);
+    }
+
+    public override Task StopAsync(
+        CancellationToken cancellationToken)
+    {
+        return base.StopAsync(cancellationToken);
+    }
+
+    public override Task DoWorkAsync(
+        CancellationToken stoppingToken)
+    {
+        var isServiceRunning = healthService.IsServiceRunning(nameof(TimeFileWorker));
+
+        Directory.CreateDirectory(workerOptions.OutputDirectory);
+
+        var time = timeProvider.UtcNow;
+
+        var outFile = Path.Combine(
+            workerOptions.OutputDirectory,
+            $"{nameof(TimeFileWorker)}.txt");
+
+        return File.AppendAllLinesAsync(
+            outFile,
+            [$"{time:yyyy-MM-dd HH:mm:ss} - {ServiceName} - IsRunning={isServiceRunning}"],
+            stoppingToken);
+    }
+
+    protected override Task OnExceptionAsync(
+        Exception exception,
+        CancellationToken stoppingToken)
+    {
+        if (exception is IOException or UnauthorizedAccessException)
+        {
+            logger.LogCritical(exception, "Could not write file!");
+            return StopAsync(stoppingToken);
+        }
+
+        return base.OnExceptionAsync(exception, stoppingToken);
+    }
+}

sample/Atc.Hosting.TimeFile.Sample/TimeFileScheduleWorkerOptions.cs

@@ -0,0 +1,13 @@
+namespace Atc.Hosting.TimeFile.Sample;
+
+public class TimeFileScheduleWorkerOptions : IBackgroundScheduleServiceOptions
+{
+    public const string SectionName = "TimeFileScheduleWorker";
+
+    public string OutputDirectory { get; set; } = Path.GetTempPath();
+
+    public string CronExpression { get; set; } = "*/5 * * * *";
+
+    public override string ToString()
+        => $"{nameof(OutputDirectory)}: {OutputDirectory}, {nameof(CronExpression)}: {CronExpression}";
+}

sample/Atc.Hosting.TimeFile.Sample/TimeFileWorker.cs

@@ -43,9 +43,12 @@ public override Task DoWorkAsync(
 
         var outFile = Path.Combine(
             workerOptions.OutputDirectory,
-            $"{time:yyyy-MM-dd--HHmmss}-{isServiceRunning}.txt");
+            $"{nameof(TimeFileWorker)}.txt");
 
-        return File.WriteAllTextAsync(outFile, $"{ServiceName}-{isServiceRunning}", stoppingToken);
+        return File.AppendAllLinesAsync(
+            outFile,
+            [$"{time:yyyy-MM-dd HH:mm:ss} - {ServiceName} - IsRunning={isServiceRunning}"],
+            stoppingToken);
     }
 
     protected override Task OnExceptionAsync(

sample/Atc.Hosting.TimeFile.Sample/appsettings.json

@@ -1,8 +1,12 @@
 {
   "TimeFileWorker": {
-    "OutputDirectory": "C:\\Temp\\TimeFileWorkerService",
+    "OutputDirectory": "C:\\Temp\\TimeFileWorkerTesting",
     "StartupDelaySeconds": 1,
-    "RetryCount": 3,
+    "RepeatIntervalSeconds": 10
+  },
+  "TimeFileScheduleWorker": {
+    "OutputDirectory": "C:\\Temp\\TimeFileWorkerTesting",
+    "CronExpression": " */1 * * * *",
     "RepeatIntervalSeconds": 10
   }
 }