WIP

Author: ianfnelson

src/ServiceLayer.Mesh/Functions/FileDiscoveryFunction.cs

@@ -14,7 +14,8 @@ public class FileDiscoveryFunction(
     IFileDiscoveryFunctionConfiguration configuration,
     IMeshInboxService meshInboxService,
     ServiceLayerDbContext serviceLayerDbContext,
-    IFileExtractQueueClient fileExtractQueueClient)
+    IFileExtractQueueClient fileExtractQueueClient,
+    IMeshFileStatusService meshFileStatusService)
 {
     [Function("FileDiscoveryFunction")]
     public async Task Run([TimerTrigger("%FileDiscoveryTimerExpression%")] TimerInfo myTimer)

src/ServiceLayer.Mesh/Functions/MeshFileStatusService.cs

@@ -0,0 +1,31 @@
+using ServiceLayer.Data;
+using ServiceLayer.Data.Models;
+
+namespace ServiceLayer.Mesh.Functions;
+
+public interface IMeshFileStatusService
+{
+    Task SetStatusAsync(MeshFile file, MeshFileStatus status, FileEventSource source);
+}
+
+public class MeshFileStatusService(ServiceLayerDbContext serviceLayerDbContext) : IMeshFileStatusService
+{
+    public async Task SetStatusAsync(MeshFile file, MeshFileStatus status, FileEventSource source)
+    {
+        var now = DateTime.UtcNow;
+
+        serviceLayerDbContext.MeshFileEvents.Add(new MeshFileEvent
+        {
+            FileId = file.FileId,
+            NewStatus = status,
+            OldStatus = file.Status,
+            TimestampUtc = now,
+            Source = source
+        });
+
+        file.Status = status;
+        file.LastUpdatedUtc = now;
+
+        await serviceLayerDbContext.SaveChangesAsync();
+    }
+}

src/ServiceLayer.Mesh/Program.cs

@@ -6,6 +6,7 @@
 using ServiceLayer.Mesh.Messaging;
 using ServiceLayer.Mesh.Storage;
 using ServiceLayer.Mesh.FileTypes.NbssAppointmentEvents;
+using ServiceLayer.Mesh.Functions;
 
 var host = new HostBuilder()
     .ConfigureFunctionsWebApplication()
@@ -23,6 +24,8 @@
 
         services.AddApplicationConfiguration();
         services.AddNbssAppointmentEventServices();
+
+        services.AddScoped<IMeshFileStatusService, MeshFileStatusService>();
     });
 
 var app = host.Build();

src/ServiceLayer.Shared/Data/Models/MeshFile.cs

@@ -20,37 +20,6 @@ public class MeshFile
     // ReSharper disable once EntityFramework.ModelValidation.UnlimitedStringLength
     public string? ValidationErrors { get; set; }
 
-    public List<MeshFileEvent> Events { get; } = [];
-
-    public static MeshFile Create(
-        FileEventSource source,
-        MeshFileType fileType,
-        string fileId,
-        string mailboxId)
-    {
-        var now = DateTime.UtcNow;
-
-        var file = new MeshFile
-        {
-            FileId = fileId,
-            FileType = fileType,
-            Status = MeshFileStatus.Discovered,
-            MailboxId = mailboxId,
-            FirstSeenUtc = now,
-            LastUpdatedUtc = now
-        };
-
-        file.Events.Add(new MeshFileEvent
-        {
-            FileId = fileId,
-            Source = source,
-            NewStatus = MeshFileStatus.Discovered,
-            TimestampUtc = now
-        });
-
-        return file;
-    }
-
     public void SetStatus(FileEventSource source, MeshFileStatus status)
     {
         var now = DateTime.UtcNow;

src/ServiceLayer.Shared/Data/ServiceLayerDbContext.cs

@@ -21,10 +21,6 @@ private static void ConfigureMeshFiles(ModelBuilder modelBuilder)
         modelBuilder.Entity<MeshFile>().HasKey(p => p.FileId);
         modelBuilder.Entity<MeshFile>().Property(e => e.Status).HasConversion<string>();
         modelBuilder.Entity<MeshFile>().Property(e => e.FileType).HasConversion<string>();
-        modelBuilder.Entity<MeshFile>()
-            .HasMany(f => f.Events)
-            .WithOne()
-            .HasForeignKey(e => e.FileId);
     }
 
     private static void ConfigureMeshFileEvents(ModelBuilder modelBuilder)
@@ -33,6 +29,10 @@ private static void ConfigureMeshFileEvents(ModelBuilder modelBuilder)
         modelBuilder.Entity<MeshFileEvent>().Property(e => e.NewStatus).HasConversion<string>();
         modelBuilder.Entity<MeshFileEvent>().Property(e => e.OldStatus).HasConversion<string>();
         modelBuilder.Entity<MeshFileEvent>().Property(e => e.Source).HasConversion<string>();
+        modelBuilder.Entity<MeshFileEvent>()
+            .HasOne<MeshFile>()
+            .WithMany()
+            .HasForeignKey(e => e.FileId);
     }
 
     private static void ConfigureNbssAppointmentEvents(ModelBuilder modelBuilder)