Test connection is closed if no access to vhost after secret update

References rabbitmq/rabbitmq-server#14403

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/Cli.java

@@ -239,6 +239,10 @@ public static void setPermissions(String username, String vhost, List<String> pe
             vhost, username, permissions.get(0), permissions.get(1), permissions.get(2)));
   }
 
+  public static void clearPermissions(String username) {
+    rabbitmqctl(format("clear_permissions --vhost %s %s", "/", username));
+  }
+
   public static void changePassword(String username, String newPassword) {
     rabbitmqctl(format("change_password %s %s", username, newPassword));
   }

src/test/java/com/rabbitmq/stream/impl/AuthenticationTest.java

@@ -15,8 +15,10 @@
 package com.rabbitmq.stream.impl;
 
 import static com.rabbitmq.stream.Cli.*;
+import static com.rabbitmq.stream.Cli.clearPermissions;
 import static com.rabbitmq.stream.impl.Assertions.assertThat;
 import static com.rabbitmq.stream.impl.TestUtils.BrokerVersion.RABBITMQ_3_13_0;
+import static com.rabbitmq.stream.impl.TestUtils.BrokerVersion.RABBITMQ_4_1_4;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
@@ -196,6 +198,34 @@ void updateSecretBrokerShouldCloseConnectionWithUpdatedUsername() {
     }
   }
 
+  @Test
+  @BrokerVersionAtLeast(RABBITMQ_4_1_4)
+  void updateSecretBrokerShouldCloseConnectionIfUnauthorizedVhost() {
+    String u = "stream";
+    String p = "stream";
+    try {
+      addUser(u, p);
+      setPermissions(u, "/", "^stream.*$");
+      TestUtils.Sync closedSync = TestUtils.sync();
+      Client client =
+          cf.get(
+              new Client.ClientParameters()
+                  .username(u)
+                  .password(p)
+                  .shutdownListener(shutdownContext -> closedSync.down()));
+      clearPermissions(u);
+      assertThatThrownBy(() -> client.authenticate(credentialsProvider(u, p)))
+          .isInstanceOf(StreamException.class)
+          .hasMessageContaining(
+              String.valueOf(Constants.RESPONSE_CODE_VIRTUAL_HOST_ACCESS_FAILURE));
+      assertThat(closedSync).completes();
+      assertThat(client.isOpen()).isFalse();
+      client.close();
+    } finally {
+      deleteUser(u);
+    }
+  }
+
   @Test
   @BrokerVersionAtLeast(TestUtils.BrokerVersion.RABBITMQ_4_0_0)
   void anonymousAuthenticationShouldWork() {
@@ -209,6 +239,6 @@ private static CredentialsProvider credentialsProvider(String username, String p
   }
 
   private boolean connectionClosedOnUpdateSecretFailure() {
-    return TestUtils.atLeastVersion("4.1.4", brokerVersion);
+    return TestUtils.atLeastVersion(RABBITMQ_4_1_4.version(), brokerVersion);
   }
 }

src/test/java/com/rabbitmq/stream/impl/TestUtils.java

@@ -1065,14 +1065,19 @@ public enum BrokerVersion {
     RABBITMQ_3_11_14("3.11.14"),
     RABBITMQ_3_13_0("3.13.0"),
     RABBITMQ_4_0_0("4.0.0"),
-    RABBITMQ_4_1_2("4.1.2");
+    RABBITMQ_4_1_2("4.1.2"),
+    RABBITMQ_4_1_4("4.1.4");
 
     final String value;
 
     BrokerVersion(String value) {
       this.value = value;
     }
 
+    String version() {
+      return this.value;
+    }
+
     @Override
     public String toString() {
       return this.value;