WIP

Author: ianfnelson

src/ServiceLayer.Mesh/Functions/FileDiscoveryFunction.cs

@@ -62,7 +62,7 @@ private async Task<MeshFile> CreateMeshFile(string messageId)
 
         ServiceLayerDbContext.MeshFiles.Add(file);
 
-        await UpdateFileStatus(file, MeshFileStatus.Discovered);
+        await UpdateMeshFile(file, MeshFileStatus.Discovered);
 
         return file;
     }

src/ServiceLayer.Mesh/Functions/FileExtractFunction.cs

@@ -32,7 +32,7 @@ public async Task Run([QueueTrigger("%FileExtractQueueName%")] FileExtractQueueM
             return;
         }
 
-        await UpdateFileStatus(file, MeshFileStatus.Extracting);
+        await UpdateMeshFile(file, MeshFileStatus.Extracting);
         await transaction.CommitAsync();
 
         try
@@ -93,15 +93,15 @@ private async Task ProcessFileExtraction(MeshFile file)
         }
 
         file.BlobPath = blobPath;
-        await UpdateFileStatus(file, MeshFileStatus.Extracted);
+        await UpdateMeshFile(file, MeshFileStatus.Extracted);
 
         await fileTransformQueueClient.EnqueueFileTransformAsync(file);
     }
 
     private async Task HandleExtractionError(MeshFile file, FileExtractQueueMessage message, Exception ex)
     {
         logger.LogError(ex, "An exception occurred during file extraction for fileId: {FileId}", message.FileId);
-        await UpdateFileStatus(file, MeshFileStatus.FailedExtract);
+        await UpdateMeshFile(file, MeshFileStatus.FailedExtract);
         await fileExtractQueueClient.SendToPoisonQueueAsync(message);
     }
 

src/ServiceLayer.Mesh/Functions/FileRetryFunction.cs

@@ -39,7 +39,7 @@ private async Task RetryStaleExtractions(DateTime staleDateTimeUtc)
         foreach (var file in staleFiles)
         {
             await fileExtractQueueClient.EnqueueFileExtractAsync(file);
-            await UpdateFileStatus(file, file.Status);
+            await UpdateMeshFile(file, file.Status);
             await ServiceLayerDbContext.SaveChangesAsync();
             logger.LogInformation("FileRetryFunction: File {FileFileId} enqueued to Extract queue", file.FileId);
         }
@@ -58,7 +58,7 @@ private async Task RetryStaleTransformations(DateTime staleDateTimeUtc)
         foreach (var file in staleFiles)
         {
             await fileTransformQueueClient.EnqueueFileTransformAsync(file);
-            await UpdateFileStatus(file, file.Status);
+            await UpdateMeshFile(file, file.Status);
             await ServiceLayerDbContext.SaveChangesAsync();
             logger.LogInformation("FileRetryFunction: File {FileFileId} enqueued to Transform queue", file.FileId);
         }

src/ServiceLayer.Mesh/Functions/FileTransformFunction.cs

@@ -42,7 +42,7 @@ public async Task Run([QueueTrigger("%FileTransformQueueName%")] FileTransformQu
             return;
         }
 
-        await UpdateFileStatus(file, MeshFileStatus.Transforming);
+        await UpdateMeshFile(file, MeshFileStatus.Transforming);
         await transaction.CommitAsync();
 
         try
@@ -100,7 +100,7 @@ private async Task ProcessFileTransformation(MeshFile file)
             throw new InvalidOperationException("Validation errors encountered");
         }
 
-        await UpdateFileStatus(file, MeshFileStatus.Transformed);
+        await UpdateMeshFile(file, MeshFileStatus.Transformed);
     }
 
     private IFileTransformer GetTransformerFor(MeshFileType type)
@@ -120,7 +120,7 @@ private IFileTransformer GetTransformerFor(MeshFileType type)
     private async Task HandleTransformationError(MeshFile file, FileTransformQueueMessage message, Exception ex)
     {
         logger.LogError(ex, "An exception occurred during file transformation for fileId: {FileId}", message.FileId);
-        await UpdateFileStatus(file, MeshFileStatus.FailedTransform);
+        await UpdateMeshFile(file, MeshFileStatus.FailedTransform);
         await fileTransformQueueClient.SendToPoisonQueueAsync(message);
     }
 

src/ServiceLayer.Mesh/Functions/MeshFileFunctionBase.cs

@@ -9,7 +9,7 @@ public abstract class MeshFileFunctionBase(ServiceLayerDbContext serviceLayerDbC
 
     protected abstract FileEventSource Source { get; }
 
-    protected async Task UpdateFileStatus(MeshFile file, MeshFileStatus status)
+    protected async Task UpdateMeshFile(MeshFile file, MeshFileStatus status)
     {
         var now = DateTime.UtcNow;