Add vhost creation

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

Tests/ConnectionRecoveryTests.cs

@@ -13,22 +13,6 @@
 
 namespace Tests;
 
-internal class FakeBackOffDelayPolicyDisabled : IBackOffDelayPolicy
-{
-    public int CurrentAttempt => 1;
-    public int Delay() => 1;
-    public bool IsActive() => false;
-    public void Reset() { }
-}
-
-internal class FakeFastBackOffDelay : IBackOffDelayPolicy
-{
-    public int CurrentAttempt => 1;
-    public int Delay() => 200;
-    public bool IsActive() => true;
-    public void Reset() { }
-}
-
 public class ConnectionRecoveryTests(ITestOutputHelper testOutputHelper)
     : IntegrationTest(testOutputHelper, setupConnectionAndManagement: false)
 {

Tests/HttpApiClient.cs

@@ -39,6 +39,11 @@ public async Task CreateUserAsync(string userName)
         await _managementClient.CreatePermissionAsync("/", userName, permissionInfo);
     }
 
+    public async Task CreateVhostAsync(string vhostName)
+    {
+        await _managementClient.CreateVhostAsync(vhostName);
+    }
+
     public async Task<bool> CheckConnectionAsync(string containerId, bool checkOpened = true)
     {
         bool rv = true;

Tests/IntegrationTest.Static.cs

@@ -296,6 +296,11 @@ private static string InitRabbitMqHost()
         }
     }
 
+    protected static Task CreateVhostAsync(string vhost)
+    {
+        return s_httpApiClient.CreateVhostAsync(vhost);
+    }
+
     private static bool InitIsRunningInCI()
     {
         if (bool.TryParse(Environment.GetEnvironmentVariable("CI"), out bool ci))

Tests/TlsConnectionTests.cs

@@ -6,6 +6,7 @@
 using System.Net.Security;
 using System.Security.Authentication;
 using System.Security.Cryptography.X509Certificates;
+using System.Threading;
 using System.Threading.Tasks;
 using RabbitMQ.AMQP.Client;
 using RabbitMQ.AMQP.Client.Impl;
@@ -47,10 +48,11 @@ public override Task DisposeAsync()
     }
 
     [Theory]
+    [InlineData("/my_tls_host")]
     [InlineData("/")]
-    [InlineData("tls")]
     public async Task ConnectUsingTlsAndUserPassword(string virtualHost)
     {
+        await CreateVhostAsync(virtualHost);
         ConnectionSettings connectionSettings = _connectionSettingBuilder
             .Scheme("amqps")
             .Port(_port)

Tests/UtilsTests.cs

@@ -9,8 +9,25 @@
 
 namespace Tests;
 
+internal class FakeBackOffDelayPolicyDisabled : IBackOffDelayPolicy
+{
+    public int CurrentAttempt => 1;
+    public int Delay() => 1;
+    public bool IsActive() => false;
+    public void Reset() { }
+}
+
+internal class FakeFastBackOffDelay : IBackOffDelayPolicy
+{
+    public int CurrentAttempt => 1;
+    public int Delay() => 200;
+    public bool IsActive() => true;
+    public void Reset() { }
+}
+
 public class UtilsTests
 {
+
     [Fact]
     public void ValidateMessageAnnotationsTest()
     {