feat: adding push to queue

Author: SamTyrrellNHS

src/ServiceLayer.Mesh/Functions/DiscoveryFunction.cs

@@ -1,8 +1,11 @@
+using Azure.Identity;
+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
 {
@@ -33,16 +36,38 @@ public async Task Run([TimerTrigger("0 */1 * * * *")] TimerInfo myTimer)
                 // dotnet-mesh-client needs to be updated to support pagination for when inbox containers more than 500 messages
             }
 
-            foreach (var message in response.Response.Messages)
+            foreach (var messageId in response.Response.Messages)
             {
                 // Check if message has been seen before
-                var doesFileIdExist = await _serviceLayerDbContext.MeshFiles.AnyAsync(m => m.FileId == message.ToString());
+                var doesFileIdExist = await _serviceLayerDbContext.MeshFiles.AnyAsync(m => m.FileId == messageId.ToString());
 
+                if (!doesFileIdExist)
+                {
+                    var meshFile = new MeshFile()
+                    {
+                        FileId = messageId,
+                        FileType = "",
+                        MailboxId = Environment.GetEnvironmentVariable("MailboxId"),
+                        Status = "Discovered"
+                    };
 
-                // If no then insert into db
-                // Then enqueue message
+                    _serviceLayerDbContext.MeshFiles.Add(meshFile);
 
-                // If no then do nothing
+                    QueueClient queueClient;
+
+                    if (Environment.GetEnvironmentVariable("ASPNETCORE_ENV") == "Dev")
+                    {
+                        queueClient = new QueueClient("UseDevelopmentStorage=true", "my-local-queue");
+                    }
+                    else
+                    {
+                        var credential = new ManagedIdentityCredential();
+                        queueClient = new QueueClient(new Uri(Environment.GetEnvironmentVariable("QueueUrl")), credential);
+                    }
+
+                    queueClient.CreateIfNotExists();
+                    queueClient.SendMessage(messageId);
+                }
             }
 
             if (myTimer.ScheduleStatus is not null)

src/ServiceLayer.Mesh/Models/MeshFile.cs

@@ -1,6 +1,14 @@
+using Microsoft.EntityFrameworkCore.Metadata.Internal;
+
 namespace ServiceLayer.Mesh.Models;
 
 public class MeshFile
 {
-    public string FileId { get; set; }
+    public required string FileId { get; set; }
+    public required string FileType { get; set; }
+    public required string MailboxId { get; set; }
+    public required string Status { get; set; }
+    public string? BlobPath { get; set; }
+    public DateTime FirstSeenUtc { get; set; }
+    public DateTime LastUpdatedUtc { get; set; }
 }

src/ServiceLayer.Mesh/ServiceLayer.Mesh.csproj

@@ -8,6 +8,8 @@
   </PropertyGroup>
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="Azure.Identity" Version="1.13.2" />
+    <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" /> -->