feat: added configuration

Author: SamTyrrellNHS

src/ServiceLayer.Mesh/Configuration/AppConfiguration.cs

@@ -4,14 +4,17 @@ public class AppConfiguration :
     IFileDiscoveryFunctionConfiguration,
     IFileExtractFunctionConfiguration,
     IFileExtractQueueClientConfiguration,
-    IFileTransformQueueClientConfiguration
+    IFileTransformQueueClientConfiguration,
+    IFileRetryFunctionConfiguration
 {
     public string NbssMeshMailboxId => GetRequired("NbssMailboxId");
 
     public string FileExtractQueueName => GetRequired("FileExtractQueueName");
 
     public string FileTransformQueueName => GetRequired("FileTransformQueueName");
 
+    public string StaleHours => GetRequired("StaleHours");
+
     private static string GetRequired(string key)
     {
         var value = Environment.GetEnvironmentVariable(key);

src/ServiceLayer.Mesh/Configuration/IFileRetryFunctionConfiguration.cs

@@ -0,0 +1,6 @@
+namespace ServiceLayer.Mesh.Configuration;
+
+public interface IFileRetryFunctionConfiguration
+{
+    string StaleHours { get; }
+}

src/ServiceLayer.Mesh/Functions/FileRetryFunction.cs

@@ -5,31 +5,34 @@
 using ServiceLayer.Mesh.Data;
 using ServiceLayer.Mesh.Messaging;
 using ServiceLayer.Mesh.Models;
+using ServiceLayer.Mesh.Configuration;
 
 namespace ServiceLayer.Mesh.Functions
 {
     public class FileRetryFunction(
         ILogger<FileRetryFunction> logger,
         IMeshInboxService meshInboxService,
         ServiceLayerDbContext serviceLayerDbContext,
-        IFileExtractQueueClient fileExtractQueueClient)
+        IFileExtractQueueClient fileExtractQueueClient,
+        IFileTransformQueueClient fileTransformQueueClient,
+        IFileRetryFunctionConfiguration configuration)
     {
         [Function("FileRetryFunction")]
         public async Task Run([TimerTrigger("%FileRetryTimerExpression%")] TimerInfo myTimer)
         {
             logger.LogInformation($"FileRetryFunction started at: {DateTime.Now}");
 
-            var twelveHoursAgo = DateTime.UtcNow.AddHours(-12);
+            var overdueAnUpdateDateTime = DateTime.UtcNow.AddHours(-Convert.ToInt32(configuration.StaleHours));
 
             var files = await serviceLayerDbContext.MeshFiles
                 .Where(f =>
                     (f.Status == MeshFileStatus.Discovered ||
                      f.Status == MeshFileStatus.Extracting ||
                      f.Status == MeshFileStatus.Extracted ||
-                     f.Status == MeshFileStatus.Transforming) && f.LastUpdatedUtc <= twelveHoursAgo)
+                     f.Status == MeshFileStatus.Transforming) && f.LastUpdatedUtc <= overdueAnUpdateDateTime)
                 .ToListAsync();
 
-            logger.LogInformation($"FileRetryFunction, {files.Count} stale files found");
+            logger.LogInformation($"FileRetryFunction: {files.Count} stale files found");
 
             foreach (var file in files)
             {
@@ -38,12 +41,14 @@ public async Task Run([TimerTrigger("%FileRetryTimerExpression%")] TimerInfo myT
                     await fileExtractQueueClient.EnqueueFileExtractAsync(file);
                     file.LastUpdatedUtc = DateTime.UtcNow;
                     await serviceLayerDbContext.SaveChangesAsync();
+                    logger.LogInformation($"FileRetryFunction: File {file.FileId} enqueued to Extract queue");
                 }
                 else if (file.Status == MeshFileStatus.Extracted || file.Status == MeshFileStatus.Transforming)
                 {
-                    //await fileExtractQueueClient.EnqueueFileExtractAsync(file);
+                    await fileTransformQueueClient.EnqueueFileTransformAsync(file);
                     file.LastUpdatedUtc = DateTime.UtcNow;
                     await serviceLayerDbContext.SaveChangesAsync();
+                    logger.LogInformation($"FileRetryFunction: File {file.FileId} enqueued to Transform queue");
                 }
             }
         }

src/ServiceLayer.Mesh/Program.cs

@@ -63,6 +63,7 @@
         services.AddTransient<IFileExtractFunctionConfiguration, AppConfiguration>();
         services.AddTransient<IFileExtractQueueClientConfiguration, AppConfiguration>();
         services.AddTransient<IFileTransformQueueClientConfiguration, AppConfiguration>();
+        services.AddTransient<IFileRetryFunctionConfiguration, AppConfiguration>();
     });