chore: enforce minimal server version

Author: bevzzz

src/main/java/io/weaviate/client6/v1/api/WeaviateClient.java

@@ -11,6 +11,7 @@
 import io.weaviate.client6.v1.api.rbac.users.WeaviateUsersClient;
 import io.weaviate.client6.v1.internal.ObjectBuilder;
 import io.weaviate.client6.v1.internal.TokenProvider;
+import io.weaviate.client6.v1.internal.VersionSupport;
 import io.weaviate.client6.v1.internal.grpc.DefaultGrpcTransport;
 import io.weaviate.client6.v1.internal.grpc.GrpcChannelOptions;
 import io.weaviate.client6.v1.internal.grpc.GrpcTransport;
@@ -37,7 +38,7 @@ public class WeaviateClient implements AutoCloseable {
 
   /** Client for {@code /backups} endpoints for managing backups. */
   public final WeaviateBackupClient backup;
-  
+
   /**
    * Client for {@code /authz/roles} endpoints for managing RBAC roles.
    */
@@ -96,6 +97,10 @@ public WeaviateClient(Config config) {
       throw ex;
     }
 
+    if (!VersionSupport.isSupported(meta.version())) {
+      throw new WeaviateUnsupportedVersionException(meta.version());
+    }
+
     if (meta.grpcMaxMessageSize() != null) {
       grpcOpt = grpcOpt.withMaxMessageSize(meta.grpcMaxMessageSize());
     }

src/main/java/io/weaviate/client6/v1/api/WeaviateClientAsync.java

@@ -13,6 +13,7 @@
 import io.weaviate.client6.v1.api.rbac.users.WeaviateUsersClientAsync;
 import io.weaviate.client6.v1.internal.ObjectBuilder;
 import io.weaviate.client6.v1.internal.TokenProvider;
+import io.weaviate.client6.v1.internal.VersionSupport;
 import io.weaviate.client6.v1.internal.grpc.DefaultGrpcTransport;
 import io.weaviate.client6.v1.internal.grpc.GrpcChannelOptions;
 import io.weaviate.client6.v1.internal.grpc.GrpcTransport;
@@ -99,6 +100,10 @@ public WeaviateClientAsync(Config config) {
       throw ex;
     }
 
+    if (!VersionSupport.isSupported(meta.version())) {
+      throw new WeaviateUnsupportedVersionException(meta.version());
+    }
+
     if (meta.grpcMaxMessageSize() != null) {
       grpcOpt = grpcOpt.withMaxMessageSize(meta.grpcMaxMessageSize());
     }

src/main/java/io/weaviate/client6/v1/api/WeaviateUnsupportedVersionException.java

@@ -0,0 +1,19 @@
+package io.weaviate.client6.v1.api;
+
+import io.weaviate.client6.v1.internal.VersionSupport;
+
+/**
+ * This exception is thrown when the client refuses to talk to an unsupported
+ * version of the server.
+ *
+ * @see VersionSupport#MINIMAL_SUPPORTED_VERSION.
+ */
+public class WeaviateUnsupportedVersionException extends WeaviateException {
+  public WeaviateUnsupportedVersionException(String actual) {
+    this(VersionSupport.MINIMAL_SUPPORTED_VERSION.toString(), actual);
+  }
+
+  public WeaviateUnsupportedVersionException(String minimal, String actual) {
+    super("Server version %s is not supported. Earliest supported version is %s.".formatted(actual, minimal));
+  }
+}

src/main/java/io/weaviate/client6/v1/internal/VersionSupport.java

@@ -0,0 +1,46 @@
+package io.weaviate.client6.v1.internal;
+
+import java.util.Arrays;
+
+public final class VersionSupport {
+  public static final SemanticVersion MINIMAL_SUPPORTED_VERSION = new SemanticVersion(1, 33);
+
+  /**
+   * Returns true if the {@code version} is the same as or older than the
+   * {@link VersionSupport#MINIMAL_SUPPORTED_VERSION}.
+   */
+  public static boolean isSupported(String version) {
+    var semver = SemanticVersion.of(version);
+    return semver.compareTo(MINIMAL_SUPPORTED_VERSION) >= 0;
+  }
+
+  public record SemanticVersion(int major, int minor, String patch) implements Comparable<SemanticVersion> {
+
+    public SemanticVersion(int major, int minor) {
+      this(major, minor, null);
+    }
+
+    /**
+     * Parse semantic version from a formatted string, e.g.
+     * {@code "(v)1.23.6-rc.1"}.
+     */
+    public static SemanticVersion of(String version) {
+      var parts = version.replaceFirst("v", "").split("\\.");
+      var major = Integer.valueOf(parts[0].replaceAll("[^0-9]", ""));
+      var minor = Integer.valueOf(parts[1].replaceAll("[^0-9]", ""));
+      var patch = String.join(".", Arrays.stream(parts, 2, parts.length).toList());
+      return new SemanticVersion(major, minor, patch);
+    }
+
+    @Override
+    public int compareTo(SemanticVersion that) {
+      var this_v = Integer.valueOf("%d%d".formatted(this.major, this.minor));
+      var that_v = Integer.valueOf("%d%d".formatted(that.major, that.minor));
+      return this_v.compareTo(that_v);
+    }
+
+    public String toString() {
+      return String.join(".", String.valueOf(major), String.valueOf(minor), patch);
+    }
+  }
+}