feat: get server version

Author: NguyenHoangSon96

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

@@ -142,11 +142,12 @@ public void checkServerTrusted(
     }
 
     public String getServerVersion() throws InfluxDBApiException {
-        HttpResponse<String> response;
         String influxdbVersion;
+        HttpResponse<String> response = request("ping", HttpMethod.GET, null, null, null);
         try {
-            response = request("ping", HttpMethod.GET, null, null, null);
             influxdbVersion = extractServerVersion(response);
+        } catch (JsonProcessingException e) {
+            influxdbVersion = null;
         } catch (Exception e) {
             throw new InfluxDBApiException(e);
         }
@@ -164,10 +165,10 @@ private String extractServerVersion(final HttpResponse<String> response) throws
     }
 
     HttpResponse<String> request(@Nonnull final String path,
-                 @Nonnull final HttpMethod method,
-                 @Nullable final byte[] data,
-                 @Nullable final Map<String, String> queryParams,
-                 @Nullable final Map<String, String> headers) {
+                                 @Nonnull final HttpMethod method,
+                                 @Nullable final byte[] data,
+                                 @Nullable final Map<String, String> queryParams,
+                                 @Nullable final Map<String, String> headers) {
 
         QueryStringEncoder uriEncoder = new QueryStringEncoder(String.format("%s%s", baseUrl, path));
         if (queryParams != null) {

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

@@ -36,6 +36,7 @@
 import java.util.Optional;
 
 import io.netty.handler.codec.http.HttpMethod;
+import okhttp3.mockwebserver.MockResponse;
 import okhttp3.mockwebserver.RecordedRequest;
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.AfterEach;
@@ -502,4 +503,28 @@ public void getServerVersionV3Successful() throws Exception {
 
         Assertions.assertThat(version).isEqualTo(influxDBVersion);
     }
+
+    @Test
+    public void getServerVersionError() {
+        MockResponse mockResponse = new MockResponse();
+        mockResponse.setBody("not json")
+                .setHeader("something", "something");
+        mockServer.enqueue(mockResponse);
+
+        restClient = new RestClient(new ClientConfig.Builder()
+                .host(baseURL)
+                .build());
+        String version = restClient.getServerVersion();
+        Assertions.assertThat(version).isEqualTo(null);
+    }
+
+    @Test
+    public void getServerVersionErrorNoBody() {
+        mockServer.enqueue(new MockResponse().setResponseCode(200));
+        restClient = new RestClient(new ClientConfig.Builder()
+                .host(baseURL)
+                .build());
+        String version = restClient.getServerVersion();
+        Assertions.assertThat(version).isEqualTo(null);
+    }
 }