chore: skip tests that require a later version

Author: bevzzz

src/it/java/io/weaviate/ConcurrentTest.java

@@ -10,9 +10,13 @@
 
 import org.apache.commons.lang3.RandomStringUtils;
 import org.assertj.core.api.Assertions;
+import org.assertj.core.api.Assumptions;
 import org.junit.Rule;
 import org.junit.rules.TestName;
 
+import io.weaviate.client6.v1.internal.VersionSupport.SemanticVersion;
+import io.weaviate.containers.Weaviate;
+
 /**
  * ConcurrentTest is the base class for integration tests, which provides
  * utility methods to uniqualize collections and objects created in the
@@ -110,4 +114,24 @@ public static void eventually(Callable<Boolean> cond, int intervalMillis, int ti
       throw new RuntimeException(ex);
     }
   }
+
+  /**
+   * Skip the test if the version that the {@link Weaviate}
+   * container is running is older than the required one.
+   */
+  public static void requireAtLeast(int major, int minor) {
+    var required = new SemanticVersion(major, minor);
+    var actual = SemanticVersion.of(Weaviate.VERSION);
+    Assumptions.assumeThat(actual)
+        .as("requires at least %s, but running %s", required, actual)
+        .isGreaterThanOrEqualTo(required);
+  }
+
+  public static void requireAtLeast(int major, int minor, Runnable r) {
+    var required = new SemanticVersion(major, minor);
+    var actual = SemanticVersion.of(Weaviate.VERSION);
+    if (actual.compareTo(required) >= 0) {
+      r.run();
+    }
+  }
 }

src/it/java/io/weaviate/integration/RbacITest.java

@@ -1,7 +1,7 @@
 package io.weaviate.integration;
 
 import java.io.IOException;
-import java.util.Arrays;
+import java.util.List;
 
 import org.assertj.core.api.Assertions;
 import org.assertj.core.api.InstanceOfAssertFactories;
@@ -64,19 +64,22 @@ public void test_roles_Lifecycle() throws IOException {
     var myCollection = "Things";
     var nsRole = ns("VectorOwner");
 
-    Permission[] permissions = new Permission[] {
+    List<Permission> permissions = List.of(
         Permission.aliases("ThingsAlias", myCollection, AliasesPermission.Action.CREATE),
         Permission.backups(myCollection, BackupsPermission.Action.MANAGE),
         Permission.cluster(ClusterPermission.Action.READ),
         Permission.nodes(myCollection, NodesPermission.Action.READ),
         Permission.roles(VIEWER_ROLE, Scope.MATCH, RolesPermission.Action.CREATE),
         Permission.collections(myCollection, CollectionsPermission.Action.CREATE),
         Permission.data(myCollection, DataPermission.Action.UPDATE),
-        Permission.groups("my-group", GroupType.OIDC, GroupsPermission.Action.READ),
         Permission.tenants(myCollection, "my-tenant", TenantsPermission.Action.DELETE),
         Permission.users("my-user", UsersPermission.Action.READ),
-        Permission.replicate(myCollection, "my-shard", ReplicatePermission.Action.READ),
-    };
+        Permission.replicate(myCollection, "my-shard", ReplicatePermission.Action.READ));
+
+    requireAtLeast(1, 33, () -> {
+      permissions.add(
+          Permission.groups("my-group", GroupType.OIDC, GroupsPermission.Action.READ));
+    });
 
     // Act: create role
     client.roles.create(nsRole, permissions);
@@ -86,7 +89,7 @@ public void test_roles_Lifecycle() throws IOException {
         .as("created role")
         .returns(nsRole, Role::name)
         .extracting(Role::permissions, InstanceOfAssertFactories.list(Permission.class))
-        .containsAll(Arrays.asList(permissions));
+        .containsAll(permissions);
 
     // Act:: add extra permissions
     var extra = new Permission[] {
@@ -150,6 +153,8 @@ public void test_roles_userAssignments() throws IOException {
 
   @Test
   public void test_groups() throws IOException {
+    requireAtLeast(1, 33);
+
     var mediaGroup = "./media-group";
     var friendGroup = "./friend-group";
 

src/main/java/io/weaviate/client6/v1/api/rbac/roles/WeaviateRolesClient.java

@@ -29,6 +29,21 @@ public WeaviateRolesClient(RestTransport restTransport) {
    *                              or the server being unavailable.
    */
   public void create(String roleName, Permission... permissions) throws IOException {
+    create(roleName, Arrays.asList(permissions));
+  }
+
+  /**
+   * Create a new role.
+   *
+   * @param roleName    Role name.
+   * @param permissions Permissions granted to the role.
+   * @throws WeaviateApiException in case the server returned with an
+   *                              error status code.
+   * @throws IOException          in case the request was not sent successfully
+   *                              due to a malformed request, a networking error
+   *                              or the server being unavailable.
+   */
+  public void create(String roleName, List<Permission> permissions) throws IOException {
     var role = new Role(roleName, permissions);
     this.restTransport.performRequest(new CreateRoleRequest(role), CreateRoleRequest._ENDPOINT);
   }