Add GitHub Action workflow for MQTT tests

.github/workflows/mqtt.yml

@@ -0,0 +1,62 @@
+name: mqtt
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+    branches: [ main ]
+
+env:
+  config: Release
+  disable_test_parallelization: true
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    timeout-minutes: 10
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: Setup .NET 8
+        uses: actions/setup-dotnet@v1
+        with:
+          dotnet-version: 8.0.x
+
+      - name: Setup .NET 9
+        uses: actions/setup-dotnet@v1
+        with:
+          dotnet-version: 9.0.x
+
+      - name: Setup .NET 10
+        uses: actions/setup-dotnet@v1
+        with:
+          dotnet-version: 10.0.x
+
+      - name: Start PostgreSQL
+        run: docker compose up -d postgresql
+
+      - name: Wait for PostgreSQL
+        run: |
+          echo "Waiting for PostgreSQL to be ready..."
+          for i in {1..30}; do
+            if nc -z localhost 5433 > /dev/null 2>&1; then
+              echo "PostgreSQL is ready"
+              break
+            fi
+            echo "Attempt $i: PostgreSQL not ready yet, waiting..."
+            sleep 2
+          done
+
+      - name: Build
+        run: dotnet build src/Transports/MQTT/Wolverine.MQTT.Tests/Wolverine.MQTT.Tests.csproj --configuration ${{ env.config }} --framework net10.0
+
+      - name: Test
+        run: dotnet test src/Transports/MQTT/Wolverine.MQTT.Tests/Wolverine.MQTT.Tests.csproj --configuration ${{ env.config }} --framework net10.0 --no-build --logger "GitHubActions;summary.includePassedTests=true;summary.includeSkippedTests=true"
+
+      - name: Stop containers
+        if: always()
+        run: docker compose down

src/Transports/MQTT/Wolverine.MQTT.Tests/Wolverine.MQTT.Tests.csproj

@@ -18,6 +18,7 @@
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>
+        <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" PrivateAssets="All" />
     </ItemGroup>
 
     <ItemGroup>

src/Transports/MQTT/Wolverine.MQTT.Tests/ack_smoke_tests.cs

@@ -7,6 +7,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class ack_smoke_tests : IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
@@ -72,6 +73,8 @@ public async Task DisposeAsync()
     {
         await _sender.StopAsync();
         await _receiver.StopAsync();
+        await Broker.StopAsync();
+        await Broker.DisposeAsync();
     }
 }
 

src/Transports/MQTT/Wolverine.MQTT.Tests/broadcast_to_topic_async.cs

@@ -9,6 +9,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class broadcast_to_topic_async : IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
@@ -64,6 +65,7 @@ public async Task broadcast()
     public async Task DisposeAsync()
     {
         await Broker.StopAsync();
+        await Broker.DisposeAsync();
         await _sender.StopAsync();
         await _receiver.StopAsync();
     }

src/Transports/MQTT/Wolverine.MQTT.Tests/broadcast_to_topic_by_user_logic.cs

@@ -7,6 +7,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class broadcast_to_topic_by_user_logic: IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
@@ -58,7 +59,7 @@
     [Fact]
     public async Task route_by_derived_topics_1()
     {
         var session = await _sender
             .TrackActivity()
             .AlsoTrack(_receiver)
             .WaitForMessageToBeReceivedAt<ColorMessage>(_receiver)
@@ -86,6 +87,7 @@
     public async Task DisposeAsync()
     {
         await Broker.StopAsync();
+        await Broker.DisposeAsync();
         await _sender.StopAsync();
         await _receiver.StopAsync();
     }

src/Transports/MQTT/Wolverine.MQTT.Tests/broadcast_to_topic_rules.cs

@@ -9,6 +9,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class broadcast_to_topic_rules : IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
@@ -88,6 +89,7 @@ public async Task route_by_derived_topics_2()
     public async Task DisposeAsync()
     {
         await Broker.StopAsync();
+        await Broker.DisposeAsync();
         await _sender.StopAsync();
         await _receiver.StopAsync();
     }

src/Transports/MQTT/Wolverine.MQTT.Tests/buffered_compliance.cs

@@ -52,11 +52,10 @@ await ReceiverIs(opts =>
 
     public LocalMqttBroker Broker { get; private set; }
 
-    public async Task DisposeAsync()
+    public new async Task DisposeAsync()
     {
         await Broker.StopAsync();
         await Broker.DisposeAsync();
-        await DisposeAsync();
     }
 }
 

src/Transports/MQTT/Wolverine.MQTT.Tests/connectivity.cs

@@ -10,6 +10,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class connectivity
 {
     private readonly ITestOutputHelper _output;
@@ -55,7 +56,7 @@ public async Task can_connect_to_a_local_broker()
         await managedClient.EnqueueAsync(topic: "Step", payload: "3");
 
 
-        await Task.Delay(1.Minutes());
+        await Task.Delay(3.Seconds());
 
         // var transport = new MqttTransport();
         // transport.Configuration = builder =>

src/Transports/MQTT/Wolverine.MQTT.Tests/inline_compliance.cs

@@ -52,11 +52,10 @@ await ReceiverIs(opts =>
 
     public LocalMqttBroker Broker { get; private set; }
 
-    public async Task DisposeAsync()
+    public new async Task DisposeAsync()
     {
         await Broker.StopAsync();
         await Broker.DisposeAsync();
-        await DisposeAsync();
     }
 }
 

src/Transports/MQTT/Wolverine.MQTT.Tests/listen_with_topic_wildcards.cs

@@ -8,6 +8,7 @@
 
 namespace Wolverine.MQTT.Tests;
 
+[Collection("acceptance")]
 public class listen_with_topic_wildcards : IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
@@ -67,6 +68,7 @@ public async Task broadcast()
     public async Task DisposeAsync()
     {
         await Broker.StopAsync();
+        await Broker.DisposeAsync();
         await _sender.StopAsync();
         await _receiver.StopAsync();
     }