wip

Author: NguyenHoangSon96

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

@@ -21,7 +21,6 @@
  */
 package com.influxdb.v3.client.internal;
 
-import java.net.InetSocketAddress;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.nio.charset.StandardCharsets;
@@ -43,9 +42,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.grpc.Codec;
 import io.grpc.DecompressorRegistry;
-import io.grpc.HttpConnectProxiedSocketAddress;
 import io.grpc.Metadata;
-import io.grpc.ProxyDetector;
 import io.grpc.netty.GrpcSslContexts;
 import io.grpc.netty.NettyChannelBuilder;
 import io.netty.handler.ssl.SslContext;

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

@@ -21,14 +21,9 @@
  */
 package com.influxdb.v3.client.internal;
 
-import java.io.FileInputStream;
 import java.net.URI;
 import java.net.URISyntaxException;
-import java.security.KeyStore;
-import java.security.cert.Certificate;
-import java.security.cert.CertificateFactory;
 import java.time.Duration;
-import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -37,9 +32,6 @@
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 import javax.net.ssl.SSLException;
-import javax.net.ssl.TrustManager;
-import javax.net.ssl.TrustManagerFactory;
-import javax.net.ssl.X509TrustManager;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
@@ -322,38 +314,6 @@ private void closeChannel() throws InterruptedException {
         }
     }
 
-    private X509TrustManager getX509TrustManagerFromFile(@Nonnull final String filePath) {
-        try {
-            KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
-            trustStore.load(null);
-
-            FileInputStream fis = new FileInputStream(filePath);
-            List<? extends Certificate> certificates = new ArrayList<Certificate>(
-                    CertificateFactory.getInstance("X.509")
-                            .generateCertificates(fis)
-            );
-
-            for (int i = 0; i < certificates.size(); i++) {
-                Certificate cert = certificates.get(i);
-                trustStore.setCertificateEntry("alias" + i, cert);
-            }
-
-            TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(
-                    TrustManagerFactory.getDefaultAlgorithm()
-            );
-            trustManagerFactory.init(trustStore);
-            X509TrustManager x509TrustManager = null;
-            for (TrustManager trustManager : trustManagerFactory.getTrustManagers()) {
-                if (trustManager instanceof X509TrustManager) {
-                    x509TrustManager = (X509TrustManager) trustManager;
-                }
-            }
-            return x509TrustManager;
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-    }
-
     @Override
     public void close() throws InterruptedException {
         this.eventLoopGroup.shutdownGracefully();