Test nodes in maintenance are filtered out from metadata

Test is disabled for now.

Author: acogoluegnes

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

@@ -14,6 +14,7 @@
 package com.rabbitmq.stream.impl;
 
 import static com.rabbitmq.stream.impl.TestUtils.streamName;
+import static com.rabbitmq.stream.impl.TestUtils.waitAtMost;
 import static java.util.Arrays.asList;
 import static org.assertj.core.api.Assertions.assertThat;
 
@@ -24,8 +25,10 @@
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.*;
+import java.util.function.BooleanSupplier;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInfo;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -38,6 +41,8 @@ public class MetadataTest {
 
   TestUtils.ClientFactory cf;
 
+  String stream;
+
   @ValueSource(ints = {1, 2, 3, 4, 5})
   @ParameterizedTest
   void metadataExistingStreams(int streamCount, TestInfo info) {
@@ -152,4 +157,17 @@ static String hostname() {
       }
     }
   }
+
+  // TODO enable this test when the server fix is available
+  @Test
+  @Disabled
+  void shouldFilterOutNodesInMaintenance() throws Exception {
+    Client client = cf.get();
+    BooleanSupplier hasLeader = () -> client.metadata(stream).get(stream).getLeader() != null;
+    waitAtMost(() -> hasLeader.getAsBoolean());
+    Host.rabbitmqctl("eval 'rabbit_maintenance:drain().'");
+    waitAtMost(() -> !hasLeader.getAsBoolean());
+    Host.rabbitmqctl("eval 'rabbit_maintenance:revive().'");
+    waitAtMost(() -> hasLeader.getAsBoolean());
+  }
 }