wip

Author: NguyenHoangSon96

examples/src/main/java/com/influxdb/v3/netty/rest/ClientChannelInitializer.java

@@ -21,6 +21,9 @@
  */
 package com.influxdb.v3.netty.rest;
 
+import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
+
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
@@ -30,9 +33,6 @@
 import io.netty.handler.ssl.SslContext;
 import io.netty.util.concurrent.Promise;
 
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
-
 public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {
 
     private final SslContext sslCtx;
@@ -43,7 +43,8 @@ public class ClientChannelInitializer extends ChannelInitializer<SocketChannel>
 
     private final Integer port;
 
-    public ClientChannelInitializer(@Nonnull String host, @Nonnull Integer port, @Nonnull Promise<FullHttpResponse> promise, @Nullable SslContext sslCtx) {
+    public ClientChannelInitializer(@Nonnull String host, @Nonnull Integer port,
+                                    @Nonnull Promise<FullHttpResponse> promise, @Nullable SslContext sslCtx) {
         this.sslCtx = sslCtx;
         this.promise = promise;
         this.host = host;

examples/src/main/java/com/influxdb/v3/netty/rest/ClientHandler.java

@@ -23,8 +23,7 @@
 
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
-import io.netty.handler.codec.http.*;
-import io.netty.util.CharsetUtil;
+import io.netty.handler.codec.http.FullHttpResponse;
 import io.netty.util.concurrent.Promise;
 
 public class ClientHandler extends SimpleChannelInboundHandler<FullHttpResponse> {

examples/src/main/java/com/influxdb/v3/netty/rest/Main.java

@@ -21,20 +21,19 @@
  */
 package com.influxdb.v3.netty.rest;
 
-import com.influxdb.v3.client.InfluxDBClient;
-import com.influxdb.v3.client.Point;
-import com.influxdb.v3.client.config.ClientConfig;
-import io.netty.handler.codec.http.FullHttpResponse;
-import io.netty.handler.codec.http.HttpMethod;
-
-import javax.net.ssl.SSLException;
 import java.net.URISyntaxException;
 import java.util.UUID;
 import java.util.concurrent.ExecutionException;
+import javax.net.ssl.SSLException;
+
+import com.influxdb.v3.client.InfluxDBClient;
+import com.influxdb.v3.client.Point;
+import com.influxdb.v3.client.config.ClientConfig;
 
 
 public class Main {
-    public static void main(String[] args) throws URISyntaxException, SSLException, ExecutionException, InterruptedException {
+    public static void main(String[] args)
+            throws URISyntaxException, SSLException, ExecutionException, InterruptedException {
         ClientConfig clientConfig = configCloud();
 
         var testId = UUID.randomUUID().toString();
@@ -58,7 +57,8 @@ public static void main(String[] args) throws URISyntaxException, SSLException,
             String query = String.format("SELECT * FROM \"cpu_sonnh\" WHERE \"testId\" = '%s'", testId);
             InfluxDBClient influxDBClient = InfluxDBClient.getInstance(clientConfig);
             var stream = influxDBClient.queryPoints(query);
-            stream.findFirst().ifPresent(pointValues -> System.out.println("Field usage_idle: " + pointValues.getField("usage_idle")));
+            stream.findFirst().ifPresent(
+                    pointValues -> System.out.println("Field usage_idle: " + pointValues.getField("usage_idle")));
 
         } catch (Exception e) {
             throw new RuntimeException(e);

examples/src/main/java/com/influxdb/v3/netty/rest/RestClient.java

@@ -21,11 +21,20 @@
  */
 package com.influxdb.v3.netty.rest;
 
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutionException;
+import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
+import javax.net.ssl.SSLException;
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.influxdb.v3.client.InfluxDBApiHttpException;
-import com.influxdb.v3.client.config.ClientConfig;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.Channel;
@@ -34,24 +43,22 @@
 import io.netty.channel.MultiThreadIoEventLoopGroup;
 import io.netty.channel.nio.NioIoHandler;
 import io.netty.channel.socket.nio.NioSocketChannel;
-import io.netty.handler.codec.http.*;
+import io.netty.handler.codec.http.DefaultFullHttpRequest;
+import io.netty.handler.codec.http.FullHttpResponse;
+import io.netty.handler.codec.http.HttpMethod;
+import io.netty.handler.codec.http.HttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.handler.codec.http.HttpVersion;
+import io.netty.handler.codec.http.QueryStringEncoder;
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.util.CharsetUtil;
 import io.netty.util.concurrent.Promise;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
-import javax.net.ssl.SSLException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.nio.charset.StandardCharsets;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ExecutionException;
+import com.influxdb.v3.client.InfluxDBApiHttpException;
+import com.influxdb.v3.client.config.ClientConfig;
 
 public final class RestClient implements AutoCloseable {
 
@@ -154,7 +161,9 @@ public void write(String lineProtocol) throws InterruptedException, ExecutionExc
         this.request(HttpMethod.POST, encoder.toString(), header, lineProtocol);
     }
 
-    public FullHttpResponse request(@Nonnull HttpMethod method, @Nonnull String path, @Nullable Map<String, String> header, @Nullable String body) throws InterruptedException, ExecutionException, JsonProcessingException {
+    public FullHttpResponse request(@Nonnull HttpMethod method, @Nonnull String path,
+                                    @Nullable Map<String, String> header, @Nullable String body)
+            throws InterruptedException, ExecutionException, JsonProcessingException {
         var content = Unpooled.EMPTY_BUFFER;
         if (body != null) {
             content = Unpooled.copiedBuffer(body, CharsetUtil.UTF_8);
@@ -172,7 +181,8 @@ public FullHttpResponse request(@Nonnull HttpMethod method, @Nonnull String path
             if (authScheme == null) {
                 authScheme = "Token";
             }
-            request.headers().set("authorization", String.format("%s %s", authScheme, new String(this.config.getToken())));
+            request.headers()
+                    .set("authorization", String.format("%s %s", authScheme, new String(this.config.getToken())));
         }
         request.headers().set("connection", "closed");