Make a cronjob functionality intended for InspectionReportGeneration

backend/api/Database/Context/FlotillaDbContext.cs

@@ -11,6 +11,7 @@ public class FlotillaDbContext(DbContextOptions options) : DbContext(options)
         public DbSet<MissionRun> MissionRuns => Set<MissionRun>();
         public DbSet<MissionTask> MissionTasks => Set<MissionTask>();
         public DbSet<Inspection> Inspections => Set<Inspection>();
+        public DbSet<InspectionFinding> InspectionFindings => Set<InspectionFinding>();
         public DbSet<MissionDefinition> MissionDefinitions => Set<MissionDefinition>();
         public DbSet<Plant> Plants => Set<Plant>();
         public DbSet<Installation> Installations => Set<Installation>();
@@ -48,11 +49,6 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                     }
                 );
             });
-            modelBuilder.Entity<Inspection>(inspectionEntity =>
-            {
-                if (isSqlLite) { AddConverterForDateTimeOffsets(ref inspectionEntity); }
-                inspectionEntity.OwnsMany(i => i.InspectionFindings);
-            });
 
             modelBuilder.Entity<MissionDefinition>()
                 .Property(m => m.InspectionFrequency)

backend/api/EventHandlers/InspectionFindingsEventHandler.cs

@@ -0,0 +1,34 @@
+using Api.Services;
+namespace Api.EventHandlers
+{
+    public class InspectionFindingEventHandler(IConfiguration configuration,
+    IServiceScopeFactory scopeFactory,
+    ILogger<InspectionFindingEventHandler> logger) : BackgroundService
+    {
+        private readonly TimeSpan _interval = configuration.GetValue<TimeSpan>("InspectionFindingEventHandler:Interval");
+        private InspectionFindingService InspectionFindingService => scopeFactory.CreateScope().ServiceProvider.GetRequiredService<InspectionFindingService>();
+        private readonly TimeSpan _timeSpan = configuration.GetValue<TimeSpan>("InspectionFindingEventHandler:TimeSpan");
+
+        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            while (!stoppingToken.IsCancellationRequested)
+            {
+                try
+                {
+                    await Task.Delay(_interval, stoppingToken);
+
+                    var lastReportingTime = DateTime.UtcNow - _timeSpan;
+
+                    var inspectionFindings = await InspectionFindingService.RetrieveInspectionFindings(lastReportingTime);
+
+                    logger.LogInformation("Found {count} inspection findings in the last {interval}.", inspectionFindings.Count, _timeSpan);
+
+                }
+                catch (OperationCanceledException)
+                {
+                    throw;
+                }
+            }
+        }
+    }
+}