feat: validate host ipv4 and ipv6

Author: NguyenHoangSon96

src/main/java/com/influxdb/v3/client/InfluxDBClient.java

@@ -483,7 +483,7 @@ Stream<VectorSchemaRoot> queryBatches(@Nonnull final String query,
      * Creates a new instance of the {@link InfluxDBClient} for interacting with an InfluxDB server, simplifying
      * common operations such as writing, querying.
      *
-     * @param host     the URL of the InfluxDB server
+     * @param host     the URL of the InfluxDB server. If IPv6 is using it must be wrapped inside brackets.
      * @param token    the authentication token for accessing the InfluxDB server, can be null
      * @param database the database to be used for InfluxDB operations, can be null
      * @return new instance of the {@link InfluxDBClient}
@@ -505,7 +505,7 @@ static InfluxDBClient getInstance(@Nonnull final String host,
      * Creates a new instance of the {@link InfluxDBClient} for interacting with an InfluxDB server, simplifying
      * common operations such as writing, querying.
      *
-     * @param host        the URL of the InfluxDB server
+     * @param host        the URL of the InfluxDB server. If IPv6 is using it must be wrapped inside brackets.
      * @param token       the authentication token for accessing the InfluxDB server, can be null
      * @param database    the database to be used for InfluxDB operations, can be null
      * @param defaultTags tags to be added by default to writes of points
@@ -561,7 +561,7 @@ static InfluxDBClient getInstance(@Nonnull final ClientConfig config) {
      *   <li>writeUseV2Api - use V2 API endpoint</li>
      * </ul>
      *
-     * @param connectionString connection string
+     * @param connectionString connection string. If IPv6 is using it must be wrapped inside brackets.
      * @return instance of {@link InfluxDBClient}
      */
     @Nonnull
@@ -584,7 +584,7 @@ static InfluxDBClient getInstance(@Nonnull final String connectionString) {
      * <p>
      * Supported environment variables:
      * <ul>
-     *   <li>INFLUX_HOST - cloud/server URL <i>required</i></li>
+     *   <li>INFLUX_HOST - cloud/server URL. If IPv6 is using it must be wrapped inside brackets. <i>required</i></li>
      *   <li>INFLUX_TOKEN - authentication token <i>required</i></li>
      *   <li>INFLUX_AUTH_SCHEME - authentication scheme</li>
      *   <li>INFLUX_ORG - organization name</li>
@@ -597,7 +597,7 @@ static InfluxDBClient getInstance(@Nonnull final String connectionString) {
      * </ul>
      * Supported system properties:
      * <ul>
-     *   <li>influx.host - cloud/server URL <i>required</i></li>
+     *   <li>influx.host - cloud/server URL. If IPv6 is using it must be wrapped inside brackets. <i>required</i></li>
      *   <li>influx.token - authentication token <i>required</i></li>
      *   <li>influx.authScheme - authentication scheme</li>
      *   <li>influx.org - organization name</li>

src/main/java/com/influxdb/v3/client/config/ClientConfig.java

@@ -24,6 +24,8 @@
 import java.net.Authenticator;
 import java.net.MalformedURLException;
 import java.net.ProxySelector;
+import java.net.URI;
+import java.net.URISyntaxException;
 import java.net.URL;
 import java.time.Duration;
 import java.util.Arrays;
@@ -48,7 +50,10 @@
  * <p>
  * You can configure following properties:
  * <ul>
- *     <li><code>host</code> - hostname or IP address of the InfluxDB server</li>
+ *     <li>
+ *         <code>host</code> - hostname or IP address of the InfluxDB server.
+ *         If IPv6 is using it must be wrapped inside brackets.
+ *     </li>
  *     <li><code>token</code> - authentication token for accessing the InfluxDB server</li>
  *     <li><code>authScheme</code> - authentication scheme</li>
  *     <li><code>organization</code> - organization to be used for operations</li>
@@ -375,8 +380,17 @@ public List<ClientInterceptor> getInterceptors() {
      * Validates the configuration properties.
      */
     public void validate() {
-        if (host == null || host.isBlank()) {
-            throw new IllegalArgumentException("The URL of the InfluxDB server has to be defined.");
+        try {
+            if (host == null) {
+                throw new IllegalArgumentException("Invalid URL.");
+            }
+
+            URI uri = new URI(host);
+            if (uri.getHost() == null) {
+                throw new URISyntaxException(host, "Invalid URL.");
+            }
+        } catch (URISyntaxException e) {
+            throw new IllegalArgumentException(e.getMessage());
         }
     }
 
@@ -481,7 +495,7 @@ public static final class Builder {
         private List<ClientInterceptor> interceptors;
 
         /**
-         * Sets the URL of the InfluxDB server.
+         * Sets the URL of the InfluxDB server. If IPv6 is using it must be wrapped inside brackets.
          *
          * @param host URL of the InfluxDB server
          * @return this
@@ -827,7 +841,7 @@ public ClientConfig build() {
         /**
          * Build an instance of {@code ClientConfig} from connection string.
          *
-         * @param connectionString connection string in URL format
+         * @param connectionString connection string in URL format. If IPv6 is using it must be wrapped inside brackets.
          * @return the configuration for an {@code InfluxDBClient}
          * @throws MalformedURLException when argument is not valid URL
          */

src/test/java/com/influxdb/v3/client/InfluxDBClientTest.java

@@ -21,6 +21,9 @@
  */
 package com.influxdb.v3.client;
 
+import java.net.URISyntaxException;
+import java.net.UnknownHostException;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 
@@ -40,6 +43,30 @@ void withProxyUrl() {
         Assertions.assertThat(clientConfig.getProxyUrl()).isEqualTo(proxyUrl);
     }
 
+    @Test
+    void parseIpv6() throws UnknownHostException, URISyntaxException {
+        record Test(String url, boolean isCorrect) {
+        }
+        var tests = List.of(
+                new Test("http://[2001:db8::1]/", true),
+                new Test("http://[2001:db8:a0b:12f0::1]/index.html", true),
+                new Test("http://[2001:db8:a0b:12f0::1]:80/index.html", true),
+                new Test("https://[2001:db8:a0b:12f0::1%25eth0]:15000/", true),
+                new Test("http://[2607:f8b0:4005:802::1007]/", true),
+                new Test("http://2001:db8::1/", false),
+                new Test("http://2001:db8::1:8080/", false)
+        );
+        for (Test test : tests) {
+            if (!test.isCorrect()) {
+                Assertions.assertThatThrownBy(() ->
+                        InfluxDBClient.getInstance(test.url(), "my-token".toCharArray(), "bucket0")
+                ).hasMessageContaining("Invalid URL.");
+            } else {
+                InfluxDBClient.getInstance(test.url(), "my-token".toCharArray(), "bucket0");
+            }
+        }
+    }
+
     @Test
     void withSslRootsFilePath() {
         String path = "/path/to/cert";
@@ -51,10 +78,9 @@ void withSslRootsFilePath() {
 
     @Test
     void requiredHost() {
-
         Assertions.assertThatThrownBy(() -> InfluxDBClient.getInstance(null, "my-token".toCharArray(), "my-database"))
                 .isInstanceOf(IllegalArgumentException.class)
-                .hasMessage("The URL of the InfluxDB server has to be defined.");
+                .hasMessage("Invalid URL.");
     }
 
     @Test