test: Integration test WIP

Author: alex-clayton-1

src/ServiceLayer.Mesh/Functions/HealthCheck.cs

@@ -0,0 +1,14 @@
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.Functions.Worker.Http;
+using System.Net;
+
+namespace ServiceLayer.Mesh.Functions;
+
+public class HealthCheckFunction
+{
+    [Function("HealthCheck")]
+    public static HttpResponseData Run([HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "health")] HttpRequestData req)
+    {
+        return req.CreateResponse(HttpStatusCode.OK);
+    }
+}

src/ServiceLayer.Mesh/Functions/HealthCheckFunction.cs

@@ -1,49 +1,25 @@
-using System;
 using System.Diagnostics;
-using System.IO;
-using System.Threading.Tasks;
-using Microsoft.Data.SqlClient;
-using Moq;
-
-using System;
-using System.Net.Http;
+using System.Net;
 using System.Net.Http.Headers;
-using System.Threading.Tasks;
-using ServiceLayer.Data;
 
-namespace ServiceLayer.Mesh.Tests.Integration;
+namespace ServiceLayer.Mesh.Tests;
 
-public class IntegrationTests
+[CollectionDefinition("DockerComposeCollection")]
+public class DockerComposeCollection : ICollectionFixture<DockerComposeFixture>
 {
-    private const string ConnectionString = "Server=localhost,1433;User Id=sa;Password=YourPassword123;TrustServerCertificate=True;";
-
-    public IntegrationTests()
-    {
-
-    }
+}
 
-    private async Task SetupEnvironment()
+[Collection("DockerComposeCollection")]
+public class IntegrationTests
+{
+    private static async Task WaitForHealthyService()
     {
-        var environment = "development";
-        if (environment == null)
-        {
-            throw new InvalidOperationException("ASPNETCORE_ENVIRONMENT environment variable is not set of is empty.");
-        }
-        if (environment == "development")
-        {
-            RunCommand("podman compose up -d");
-        }
-        if (environment == "production")
-        {
-            RunCommand("docker compose up -d");
-        }
-
         bool environmentIsUp = false;
 
         while (environmentIsUp == false)
         {
-            var responce = await HttpHelper.SendHttpRequestAsync(HttpMethod.Get, "http://localhost:7072/api/health");
-            if (responce.IsSuccessStatusCode)
+            var response = await HttpHelper.SendHttpRequestAsync(HttpMethod.Get, "http://localhost:7072/api/health");
+            if (response.IsSuccessStatusCode)
             {
                 environmentIsUp = true;
             }
@@ -54,18 +30,20 @@ private async Task SetupEnvironment()
         }
     }
 
-    public void Teardown()
-    {
-        // Stop containers
-        RunCommand("docker compose down");
-    }
-
     [Fact]
     public async Task EndToEndTest()
     {
-        await SetupEnvironment();
+        // Arrange
+        await WaitForHealthyService();
+
+        await SendFileToMeshInbox("KMK_20250212095121_APPT_87.dat");
+
+        await Task.Delay(5000);
+    }
 
-        byte[] binaryData = await File.ReadAllBytesAsync("TestData/KMK_20250212095121_APPT_87.dat");
+    private static async Task SendFileToMeshInbox(string fileName)
+    {
+        byte[] binaryData = await File.ReadAllBytesAsync($"TestData/{fileName}");
         var content = new ByteArrayContent(binaryData);
         content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
 
@@ -76,41 +54,15 @@ public async Task EndToEndTest()
             headers =>
             {
                 headers.Add("Authorization", "NHSMESH X26ABC1:a42f77b9-58de-4b45-b599-2d5bf320b44d:0:202407291437:e3005627136e01706efabcfe72269bc8da3192e90a840ab344ab7f82a39bb5c6");
-                headers.Add("Mex-Filename", "KMK_20250212095121_APPT_87.dat");
+                headers.Add("Mex-Filename", fileName);
                 headers.Add("Mex-From", "X26ABC1");
                 headers.Add("Mex-To", "X26ABC1");
                 headers.Add("Mex-Workflowid", "API-DOCS-TEST");
-                headers.Add("User-Agent", "HTTPie");
             }
         );
-
-        await Task.Delay(5000);
-
-        Teardown();
-    }
-
-    private void RunCommand(string command)
-    {
-        var psi = new ProcessStartInfo("cmd", $"/c {command}")
-        {
-            RedirectStandardOutput = true,
-            RedirectStandardError = true,
-            UseShellExecute = false,
-            CreateNoWindow = true
-        };
-
-        using var process = Process.Start(psi);
-        process.WaitForExit();
-
-        if (process.ExitCode != 0)
-        {
-            throw new Exception($"Command failed: {command}\n{process.StandardError.ReadToEnd()}");
-        }
     }
 }
 
-
-
 public static class HttpHelper
 {
     private static readonly HttpClient _client = new HttpClient();
@@ -138,7 +90,49 @@ public static async Task<HttpResponseMessage> SendHttpRequestAsync(
         catch (HttpRequestException ex)
         {
             Console.WriteLine($"HTTP Request failed: {ex.Message}");
-            throw;
+            return new HttpResponseMessage(HttpStatusCode.ServiceUnavailable);
+        }
+    }
+}
+
+public class DockerComposeFixture : IAsyncLifetime
+{
+    public async Task InitializeAsync()
+    {
+        // Start Docker Compose
+        var startInfo = new ProcessStartInfo
+        {
+            FileName = "docker",
+            Arguments = "compose up -d mesh-ingest azurite db db-migrations",
+            RedirectStandardOutput = true,
+            RedirectStandardError = true,
+            UseShellExecute = false,
+            CreateNoWindow = true
+        };
+
+        using var process = Process.Start(startInfo);
+        await process.WaitForExitAsync();
+
+        if (process.ExitCode != 0)
+        {
+            throw new Exception($"docker compose up failed, error: {process.StandardError.ReadToEnd()}");
         }
     }
+
+    public async Task DisposeAsync()
+    {
+        // Stop Docker Compose
+        var stopInfo = new ProcessStartInfo
+        {
+            FileName = "docker",
+            Arguments = "compose down",
+            RedirectStandardOutput = true,
+            RedirectStandardError = true,
+            UseShellExecute = false,
+            CreateNoWindow = true
+        };
+
+        using var process = Process.Start(stopInfo);
+        await process.WaitForExitAsync();
+    }
 }