wip

Author: NguyenHoangSon96

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

@@ -80,9 +80,9 @@ public interface InfluxDBClient extends AutoCloseable {
      * Write a {@link Point} to the InfluxDB server.
      *
      * @param point the {@link Point} to write, can be null
-     * <p>
-     * Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
-     * by NanosecondConverter helper class
+     *              <p>
+     *              Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
+     *              by NanosecondConverter helper class
      */
     void writePoint(@Nullable final Point point);
 
@@ -91,19 +91,19 @@ public interface InfluxDBClient extends AutoCloseable {
      *
      * @param point   the {@link Point} to write, can be null
      * @param options the options for writing data to InfluxDB
-     * <p>
-     * Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
-     * by NanosecondConverter helper class
+     *                <p>
+     *                Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
+     *                by NanosecondConverter helper class
      */
     void writePoint(@Nullable final Point point, @Nonnull final WriteOptions options);
 
     /**
      * Write a list of {@link Point} to the InfluxDB server.
      *
      * @param points the list of {@link Point} to write, cannot be null
-     * <p>
-     * Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
-     * by NanosecondConverter helper class
+     *               <p>
+     *               Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
+     *               by NanosecondConverter helper class
      */
     void writePoints(@Nonnull final List<Point> points);
 
@@ -112,9 +112,9 @@ public interface InfluxDBClient extends AutoCloseable {
      *
      * @param points  the list of {@link Point} to write, cannot be null
      * @param options the options for writing data to InfluxDB
-     * <p>
-     * Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
-     * by NanosecondConverter helper class
+     *                <p>
+     *                Note: the timestamp passed will be converted to nanoseconds since the Unix epoch
+     *                by NanosecondConverter helper class
      */
     void writePoints(@Nonnull final List<Point> points, @Nonnull final WriteOptions options);
 
@@ -460,7 +460,8 @@ Stream<VectorSchemaRoot> queryBatches(@Nonnull final String query,
      * Returns <code>null</code> if the server version can't be determined.
      */
     @Nullable
-    String getServerVersion() throws RuntimeException, ExecutionException, InterruptedException, JsonProcessingException;
+    String getServerVersion()
+            throws RuntimeException, ExecutionException, InterruptedException, JsonProcessingException;
 
     /**
      * Creates a new instance of the {@link InfluxDBClient} for interacting with an InfluxDB server, simplifying
@@ -498,7 +499,8 @@ static InfluxDBClient getInstance(@Nonnull final String host,
     static InfluxDBClient getInstance(@Nonnull final String host,
                                       @Nullable final char[] token,
                                       @Nullable final String database,
-                                      @Nullable Map<String, String> defaultTags) throws URISyntaxException, SSLException {
+                                      @Nullable Map<String, String> defaultTags)
+            throws URISyntaxException, SSLException {
 
         ClientConfig config = new ClientConfig.Builder()
                 .host(host)

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

@@ -731,7 +731,7 @@ public Builder disableGRPCCompression(final boolean disableGRPCCompression) {
         }
 
         @Nonnull
-        public Builder nettyHttpClientConfig(NettyHttpClientConfig nettyHttpClientConfig) {
+        public Builder nettyHttpClientConfig(final NettyHttpClientConfig nettyHttpClientConfig) {
             this.nettyHttpClientConfig = nettyHttpClientConfig;
             return this;
         }

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

@@ -40,8 +40,6 @@ public class ClientChannelInitializer extends ChannelInitializer<OioSocketChanne
 
     private final SslContext sslCtx;
 
-//    private final Promise<FullHttpResponse> promise;
-
     private final String host;
 
     private final Integer port;
@@ -50,10 +48,10 @@ public class ClientChannelInitializer extends ChannelInitializer<OioSocketChanne
 
     private ChannelHandler[] h;
 
-    public ClientChannelInitializer(@Nonnull String host,
-                                    @Nonnull Integer port,
-                                    @Nullable SslContext sslCtx,
-                                    @Nullable HttpProxyHandler proxyHandler,
+    public ClientChannelInitializer(@Nonnull final String host,
+                                    @Nonnull final Integer port,
+                                    @Nullable final SslContext sslCtx,
+                                    @Nullable final HttpProxyHandler proxyHandler,
                                     ChannelHandler... handlers
 
     ) {
@@ -65,7 +63,7 @@ public ClientChannelInitializer(@Nonnull String host,
     }
 
     @Override
-    public void initChannel(OioSocketChannel ch) {
+    public void initChannel(final OioSocketChannel ch) {
         ChannelPipeline p = ch.pipeline();
         p.addLast(new LoggingHandler(LogLevel.INFO));
         if (proxyHandler != null) {

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

@@ -42,11 +42,6 @@ public void channelRead0(final ChannelHandlerContext ctx, final FullHttpResponse
         this.responseFuture.complete(msg.retain());
     }
 
-    @Override
-    public void channelInactive(final ChannelHandlerContext ctx) throws Exception {
-        ctx.fireChannelInactive();
-    }
-
     @Override
     public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) {
         this.responseFuture.completeExceptionally(cause);

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

@@ -139,8 +139,8 @@ final class RestClient implements AutoCloseable {
         this.timeout = config.getWriteTimeout();
 
         if ("https".equalsIgnoreCase(scheme)) {
-            if (config.getNettyHttpClientConfig() != null &&
-                    config.getNettyHttpClientConfig().getSslContext() != null) {
+            if (config.getNettyHttpClientConfig() != null
+                    && config.getNettyHttpClientConfig().getSslContext() != null) {
                 this.sslContext = config.getNettyHttpClientConfig().getSslContext();
             } else {
                 this.sslContext = SslContextBuilder.forClient().build();
@@ -157,8 +157,8 @@ final class RestClient implements AutoCloseable {
         //fixme `clientHandler`should store in a list and pass to `ClientChannelInitializer()`
         this.clientHandler = new ClientHandler();
 
-        if (this.config.getNettyHttpClientConfig() != null &&
-                this.config.getNettyHttpClientConfig().getHttpProxyHandler() != null) {
+        if (this.config.getNettyHttpClientConfig() != null
+                && this.config.getNettyHttpClientConfig().getHttpProxyHandler() != null) {
             this.proxyHandler = this.config.getNettyHttpClientConfig().getHttpProxyHandler();
         }
 
@@ -192,7 +192,8 @@ public String getServerVersion() throws ExecutionException, InterruptedException
         return influxdbVersion;
     }
 
-    public FullHttpResponse request(@Nonnull HttpMethod method, @Nonnull final String path, @Nonnull final Map<String, String> headers)
+    public FullHttpResponse request(@Nonnull final HttpMethod method, @Nonnull final String path,
+                                    @Nonnull final Map<String, String> headers)
             throws RuntimeException, InterruptedException, ExecutionException {
         return request(method, path, headers, null, null);
     }

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

@@ -174,7 +174,7 @@ public static MockWebServer customDispatchServer(@NotNull final String host, @No
         server.setDispatcher(new Dispatcher() {
             @NotNull
             @Override
-            public MockResponse dispatch(@NotNull RecordedRequest recordedRequest) {
+            public MockResponse dispatch(@NotNull final RecordedRequest recordedRequest) {
                 return mockResponse != null ? mockResponse : new MockResponse(200, Headers.EMPTY, "Success");
             }
         });