feat: get influxdb version

Author: NguyenHoangSon96

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

@@ -449,6 +449,14 @@ Stream<VectorSchemaRoot> queryBatches(@Nonnull final String query,
                                           @Nonnull final Map<String, Object> parameters,
                                           @Nonnull final QueryOptions options);
 
+    /**
+     * Sends a ping and returns the InfluxDB version.
+     *
+     * @return a non-null string representing the response to the ping request
+     */
+    @Nonnull
+    String ping();
+
     /**
      * Creates a new instance of the {@link InfluxDBClient} for interacting with an InfluxDB server, simplifying
      * common operations such as writing, querying.

src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java

@@ -290,6 +290,12 @@ public Stream<VectorSchemaRoot> queryBatches(@Nonnull final String query,
         return queryData(query, parameters, options);
     }
 
+    @Nonnull
+    @Override
+    public String ping() {
+        return this.restClient.ping();
+    }
+
     @Override
     public void close() throws Exception {
         restClient.close();

src/main/java/com/influxdb/v3/client/internal/RestClient.java

@@ -140,6 +140,26 @@ public void checkServerTrusted(
         this.client = builder.build();
     }
 
+    @Nonnull
+    public String ping() throws InfluxDBApiException {
+        HttpRequest request = HttpRequest.newBuilder()
+                .uri(URI.create(this.baseUrl + "ping"))
+                .GET()
+                .build();
+
+        HttpResponse<String> response;
+        String influxdbVersion;
+        try {
+            response = client.send(request, HttpResponse.BodyHandlers.ofString());
+            influxdbVersion = response.headers().firstValue("x-influxdb-version").orElseThrow();
+        } catch (Exception e) {
+            throw new InfluxDBApiException(e);
+        }
+        handleInfluxDBApiHttpException(response);
+
+        return influxdbVersion;
+    }
+
     void request(@Nonnull final String path,
                  @Nonnull final HttpMethod method,
                  @Nullable final byte[] data,
@@ -197,6 +217,10 @@ void request(@Nonnull final String path,
             throw new InfluxDBApiException(e);
         }
 
+        handleInfluxDBApiHttpException(response);
+    }
+
+    private void handleInfluxDBApiHttpException(final HttpResponse<String> response) {
         int statusCode = response.statusCode();
         if (statusCode < 200 || statusCode >= 300) {
             String reason = "";

src/test/java/com/influxdb/v3/client/internal/RestClientTest.java

@@ -476,4 +476,30 @@ public void errorHttpExceptionThrown() {
         Assertions.assertThat(he.getMessage())
           .isEqualTo("HTTP status code: 503; Message: temporarily offline");
     }
+
+    @Test
+    public void pingReturnsVersionWhenSuccessful() throws Exception {
+        String influxDBVersion = "v2.1.0";
+        mockServer.enqueue(createResponse(200).setHeader("x-influxdb-version", influxDBVersion));
+
+        restClient = new RestClient(new ClientConfig.Builder()
+                .host(baseURL)
+                .build());
+
+        String version = restClient.ping();
+
+        Assertions.assertThat(version).isEqualTo(influxDBVersion);
+    }
+
+    @Test
+    public void pingThrowsExceptionOnFailure() {
+        mockServer.enqueue(createResponse(500).setBody("{\"message\":\"internal server error\"}"));
+
+        restClient = new RestClient(new ClientConfig.Builder()
+                .host(baseURL)
+                .build());
+
+        Assertions.assertThatThrownBy(() -> restClient.ping())
+                .isInstanceOf(InfluxDBApiException.class);
+    }
 }