Wire Azure integration tests to the Service Bus emulator

- AzureTestEnvironment.GetServiceBusConnectionString now falls back to
  AZURE_SERVICEBUS_CONNECTION_STRING (set by CI) and then to the local
  Service Bus emulator default, instead of returning an empty string that
  threw on ServiceBusClient construction.
- Config.json: add test-commands.fifo (session), test-commands-dedup
  (duplicate detection), and test-events / test-events-fanout topics so the
  deterministic dispatching, event-publishing and session suites have their
  entities pre-declared (the emulator does not create entities at runtime).
- Azure-Build.yml: scope the emulator integration step to the deterministic
  Service Bus messaging suites; align the emulator connection string.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

Author: NinjaRocks

.github/azure-emulator/Config.json

@@ -4,8 +4,9 @@
       {
         "Name": "sbemulatorns",
         "Queues": [
-          { "Name": "test-commands", "Properties": { "LockDuration": "PT1M", "RequiresDuplicateDetection": true, "DuplicateDetectionHistoryTimeWindow": "PT10M", "MaxDeliveryCount": 5 } },
-          { "Name": "test-events", "Properties": { "LockDuration": "PT1M", "MaxDeliveryCount": 5 } },
+          { "Name": "test-commands", "Properties": { "LockDuration": "PT1M", "MaxDeliveryCount": 10 } },
+          { "Name": "test-commands.fifo", "Properties": { "LockDuration": "PT1M", "RequiresSession": true, "MaxDeliveryCount": 10 } },
+          { "Name": "test-commands-dedup", "Properties": { "LockDuration": "PT1M", "RequiresDuplicateDetection": true, "DuplicateDetectionHistoryTimeWindow": "PT10M", "MaxDeliveryCount": 10 } },
           { "Name": "autoscaling-test-queue", "Properties": { "MaxDeliveryCount": 5 } },
           { "Name": "autoscaling-small-queue", "Properties": { "MaxDeliveryCount": 5 } },
           { "Name": "autoscaling-medium-queue", "Properties": { "MaxDeliveryCount": 5 } },
@@ -41,6 +42,8 @@
           { "Name": "perf-resource-queue", "Properties": { "MaxDeliveryCount": 5 } }
         ],
         "Topics": [
+          { "Name": "test-events", "Properties": {}, "Subscriptions": [ { "Name": "test-subscription", "Properties": { "MaxDeliveryCount": 5 } } ] },
+          { "Name": "test-events-fanout", "Properties": {}, "Subscriptions": [ { "Name": "test-subscription", "Properties": { "MaxDeliveryCount": 5 } }, { "Name": "fanout-sub-1", "Properties": { "MaxDeliveryCount": 5 } }, { "Name": "fanout-sub-2", "Properties": { "MaxDeliveryCount": 5 } } ] },
           { "Name": "session-events-topic", "Properties": {}, "Subscriptions": [ { "Name": "session-events-sub", "Properties": { "RequiresSession": true, "MaxDeliveryCount": 5 } } ] },
           { "Name": "session-lock-topic", "Properties": {}, "Subscriptions": [ { "Name": "session-lock-sub", "Properties": { "RequiresSession": true, "MaxDeliveryCount": 5 } } ] },
           { "Name": "session-state-topic", "Properties": {}, "Subscriptions": [ { "Name": "session-state-sub", "Properties": { "RequiresSession": true, "MaxDeliveryCount": 5 } } ] },

.github/workflows/Azure-Build.yml

@@ -55,7 +55,7 @@ jobs:
     env:
       MSSQL_SA_PASSWORD: "SourceFlow!Emulator1"
       # Emulator client connection string (documented default for the emulator image).
-      AZURE_SERVICEBUS_CONNECTION_STRING: "Endpoint=sb://localhost:5672;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true"
+      AZURE_SERVICEBUS_CONNECTION_STRING: "Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true"
     steps:
       - uses: actions/checkout@v4
       - name: Setup .NET
@@ -89,11 +89,15 @@ jobs:
           dotnet restore SourceFlow.Net.sln
           dotnet build SourceFlow.Net.sln --configuration Release --no-restore
 
-      - name: Run Azure integration tests
+      # Deterministic Service Bus messaging suites whose entities are declared in
+      # .github/azure-emulator/Config.json. Key Vault / Managed Identity / monitor /
+      # telemetry suites need real Azure, and the property/perf suites create many
+      # queues at runtime (unsupported by the static-entity emulator) — excluded here.
+      - name: Run Azure Service Bus integration tests (emulator)
         run: >-
           dotnet test tests/SourceFlow.Cloud.Azure.Tests/SourceFlow.Cloud.Azure.Tests.csproj
           --configuration Release --no-build --verbosity normal
-          --filter "Category=Integration"
+          --filter "FullyQualifiedName~ServiceBusCommandDispatchingTests|FullyQualifiedName~ServiceBusEventPublishingTests|FullyQualifiedName~ServiceBusEventSessionHandlingTests"
           -- RunConfiguration.TestSessionTimeout=600000
 
       - name: Dump emulator logs on failure

tests/SourceFlow.Cloud.Azure.Tests/TestHelpers/AzureTestEnvironment.cs

@@ -77,7 +77,28 @@ public async Task CleanupAsync()
         await Task.CompletedTask;
     }
 
-    public string GetServiceBusConnectionString() => _config.ServiceBusConnectionString;
+    /// <summary>
+    /// Default connection string for the local Azure Service Bus emulator
+    /// (see .github/azure-emulator/docker-compose.yml).
+    /// </summary>
+    public const string EmulatorConnectionString =
+        "Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true";
+
+    public string GetServiceBusConnectionString()
+    {
+        // 1. Explicit connection string from configuration.
+        if (!string.IsNullOrEmpty(_config.ServiceBusConnectionString))
+            return _config.ServiceBusConnectionString;
+
+        // 2. Environment override (real Azure namespace or emulator) — set by CI.
+        var fromEnv = Environment.GetEnvironmentVariable("AZURE_SERVICEBUS_CONNECTION_STRING");
+        if (!string.IsNullOrEmpty(fromEnv))
+            return fromEnv;
+
+        // 3. Fall back to the local Service Bus emulator. Azurite cannot emulate
+        // Service Bus, so tests requesting "Azurite" really target the emulator here.
+        return EmulatorConnectionString;
+    }
     public string GetServiceBusFullyQualifiedNamespace() => _config.FullyQualifiedNamespace;
     public string GetKeyVaultUrl() => _config.KeyVaultUrl;