feat: Check if mesh message id exists in db table

Author: alex-clayton-1

src/ServiceLayer.Mesh/Data/ServiceLayerDbConext.cs

@@ -0,0 +1,15 @@
+using Microsoft.EntityFrameworkCore;
+using ServiceLayer.Mesh.Models;
+
+namespace ServiceLayer.Mesh.Data;
+
+public class ServiceLayerDbContext(DbContextOptions<ServiceLayerDbContext> options) : DbContext(options)
+{
+    public DbSet<MeshFile> MeshFiles { get; set; }
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        // Configure relationships, keys, etc.
+        modelBuilder.Entity<MeshFile>().HasKey(p => p.FileId);
+    }
+}

src/ServiceLayer.Mesh/Functions/DiscoveryFunction.cs

@@ -1,10 +1,8 @@
-using System;
 using Microsoft.Azure.Functions.Worker;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
-using NHS.MESH.Client.Services;
-using NHS.MESH.Client.Models;
 using NHS.MESH.Client.Contracts.Services;
-using System.Threading.Tasks;
+using ServiceLayer.Mesh.Data;
 
 namespace ServiceLayer.Mesh.Functions
 {
@@ -13,20 +11,40 @@ public class DiscoveryFunction
         private readonly ILogger _logger;
 
         private readonly IMeshInboxService _meshInboxService;
+        private readonly ServiceLayerDbContext _serviceLayerDbContext;
 
-        public DiscoveryFunction(ILoggerFactory loggerFactory, IMeshInboxService meshInboxService)
+        public DiscoveryFunction(ILoggerFactory loggerFactory, IMeshInboxService meshInboxService, ServiceLayerDbContext serviceLayerDbContext)
         {
             _logger = loggerFactory.CreateLogger<DiscoveryFunction>();
             _meshInboxService = meshInboxService;
+            _serviceLayerDbContext = serviceLayerDbContext;
         }
 
         [Function("DiscoveryFunction")]
-        public async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer)
+        public async Task Run([TimerTrigger("0 */1 * * * *")] TimerInfo myTimer)
         {
             _logger.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");
 
             var response = await _meshInboxService.GetMessagesAsync(Environment.GetEnvironmentVariable("MailboxId"));
 
+            if (response.Response.Messages.Count() > 500)
+            {
+                // TODO: Get next page
+                // 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)
+            {
+                // Check if message has been seen before
+                var doesFileIdExist = await _serviceLayerDbContext.MeshFiles.AnyAsync(m => m.FileId == message.ToString());
+
+
+                // If no then insert into db
+                // Then enqueue message
+
+                // If no then do nothing
+            }
+
             if (myTimer.ScheduleStatus is not null)
             {
                 _logger.LogInformation($"Next timer schedule at: {myTimer.ScheduleStatus.Next}");

src/ServiceLayer.Mesh/Models/MeshFile.cs

@@ -0,0 +1,6 @@
+namespace ServiceLayer.Mesh.Models;
+
+public class MeshFile
+{
+    public string FileId { get; set; }
+}

src/ServiceLayer.Mesh/Program.cs

@@ -1,12 +1,13 @@
 using Microsoft.Azure.Functions.Worker.Builder;
 using Microsoft.Extensions.Hosting;
 using NHS.MESH.Client;
+using ServiceLayer.Mesh.Data;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.DependencyInjection;
 
-var host = new HostBuilder();
-
-host.ConfigureFunctionsWebApplication();
-
-host.ConfigureServices(services =>
+var host = new HostBuilder()
+    .ConfigureFunctionsWebApplication()
+    .ConfigureServices(services =>
     {
         services
             .AddMeshClient(_ => _.MeshApiBaseUrl = Environment.GetEnvironmentVariable("MeshApiBaseUrl"))
@@ -15,8 +16,16 @@
                 Password = Environment.GetEnvironmentVariable("MeshPassword"),
                 SharedKey = Environment.GetEnvironmentVariable("MeshSharedKey"),
                 //Cert = cert
-            })
-            .Build();
+            }).Build();
+
+        services.AddDbContext<ServiceLayerDbContext>(options =>
+        {
+            var databaseConnectionString = Environment.GetEnvironmentVariable("DatabaseConnectionString");
+            if (string.IsNullOrEmpty(databaseConnectionString))
+                throw new InvalidOperationException("The connection string has not been initialized.");
+
+            options.UseSqlServer(databaseConnectionString);
+        });
     });
 
 

src/ServiceLayer.Mesh/ServiceLayer.Mesh.csproj

@@ -15,6 +15,9 @@
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" Version="2.0.0" />
     <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" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.1" />
   </ItemGroup>
   <ItemGroup>
     <None Update="host.json">