wip

Author: ianfnelson

src/ServiceLayer.Mesh/Functions/ExtractFunction.cs

@@ -0,0 +1,78 @@
+using Azure.Storage.Blobs;
+using Azure.Storage.Queues;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using NHS.MESH.Client.Contracts.Services;
+using ServiceLayer.Mesh.Data;
+using ServiceLayer.Mesh.Models;
+
+namespace ServiceLayer.Mesh.Functions;
+
+public class ExtractFunction
+{
+    private readonly ILogger _logger;
+    private readonly IMeshInboxService _meshInboxService;
+    private readonly ServiceLayerDbContext _serviceLayerDbContext;
+    private readonly QueueClient _queueClient;
+    private readonly BlobClient _blobClient;
+
+
+    public ExtractFunction(ILogger logger, IMeshInboxService meshInboxService, ServiceLayerDbContext serviceLayerDbContext, QueueClient queueClient, BlobClient blobClient)
+    {
+        _logger = logger;
+        _meshInboxService = meshInboxService;
+        _serviceLayerDbContext = serviceLayerDbContext;
+        _queueClient = queueClient;
+        _blobClient = blobClient;
+    }
+
+    [Function("ExtractFunction")]
+    public async Task Run([QueueTrigger("TODO")] ExtractQueueMessage message)
+    {
+        _logger.LogInformation($"ExtractFunction started at: {DateTime.Now}");
+
+        await using var transaction = await _serviceLayerDbContext.Database.BeginTransactionAsync();
+
+        var file = await _serviceLayerDbContext.MeshFiles
+            .FirstOrDefaultAsync(f => f.FileId == message.FileId);
+
+        if (file == null)
+        {
+            // TODO - do we want to throw exception or just exit silently?
+            throw new InvalidOperationException("File not found");
+        }
+
+        // We only want to extract files if they are in a Discovered state,
+        //   or are in an Extracting state and have been last touched over 12 hours ago.
+        var expectedStatuses = new[] { MeshFileStatus.Discovered, MeshFileStatus.Extracting };
+        if (!expectedStatuses.Contains(file.Status) ||
+            file.Status == MeshFileStatus.Extracting && file.LastUpdatedUtc > DateTime.UtcNow.AddHours(-12))
+        {
+            // TODO - do we want to throw exception or just exit silently?
+            throw new InvalidOperationException("File is not in expected status");
+        }
+
+        file.Status = MeshFileStatus.Extracting;
+        file.LastUpdatedUtc = DateTime.UtcNow;
+
+        await _serviceLayerDbContext.SaveChangesAsync();
+        await transaction.CommitAsync();
+
+        var mailboxId = Environment.GetEnvironmentVariable("BSSMailBox")
+            ?? throw new InvalidOperationException($"Environment variable 'BSSMailBox' is not set or is empty.");
+
+        var meshResponse = await _meshInboxService.GetMessageByIdAsync(mailboxId, file.FileId);
+        if (!meshResponse.IsSuccessful)
+        {
+            // TODO - what to do if unsuccessful?
+            throw new InvalidOperationException($"Mesh extraction failed: {meshResponse.Error}");
+        }
+    }
+
+}
+
+public class ExtractQueueMessage
+{
+    public string FileId { get; set; }
+}

src/ServiceLayer.Mesh/ServiceLayer.Mesh.csproj

@@ -9,12 +9,14 @@
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Azure.Identity" Version="1.13.2" />
+    <PackageReference Include="Azure.Storage.Blobs" Version="12.24.0" />
     <PackageReference Include="Azure.Storage.Queues" Version="12.22.0" />
     <!-- Application Insights isn't enabled by default. See https://aka.ms/AAt8mw4. -->
     <!-- <PackageReference Include="Microsoft.ApplicationInsights.WorkerService" Version="2.22.0" /> -->
     <!-- <PackageReference Include="Microsoft.Azure.Functions.Worker.ApplicationInsights" Version="2.0.0" /> -->
     <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.0.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" Version="2.0.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Storage.Queues" Version="5.5.2" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Timer" Version="4.3.1" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" Version="2.0.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.1" />