feat/async http transporter, internal logger, withDebig flag to enable internal logs

Author: piotr-szewczyk

.idea/workspace.xml

@@ -19,7 +19,11 @@
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <apache.httpclient.version>4.5.13</apache.httpclient.version>
+        <apache.httpcore.version>4.4.14</apache.httpcore.version>
+        <apache.httpasync.version>4.1.4</apache.httpasync.version>
         <jackson.databind.version>2.13.0</jackson.databind.version>
+        <mockito.core.version>3.11.2</mockito.core.version>
+        <slf4j.api.version>1.7.36</slf4j.api.version>
     </properties>
 
 </project>

pom.xml

@@ -23,6 +23,16 @@
             <artifactId>httpclient</artifactId>
             <version>${apache.httpclient.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+            <version>${apache.httpcore.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpasyncclient</artifactId>
+            <version>${apache.httpasync.version}</version>
+        </dependency>
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
@@ -34,6 +44,22 @@
             <version>4.13.1</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>${mockito.core.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>1.7.21</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${slf4j.api.version}</version> <!-- {x-version-update;org.slf4j:slf4j-api;external_dependency} -->
+        </dependency>
     </dependencies>
     <build>
         <plugins>

traceo-sdk-core/pom.xml

@@ -6,11 +6,17 @@ public class ClientCoreConfiguration {
 
     private String host = null;
 
+    private boolean isEnabled = true;
+
+    private boolean isDebug = false;
+
     public ClientCoreConfiguration() {}
 
     public ClientCoreConfiguration(ClientCoreConfiguration configuration) {
         this.apiKey = configuration.getApiKey();
         this.host = configuration.getHost();
+        this.isEnabled = configuration.isEnabled();
+        this.isDebug = configuration.isDebug();
     }
 
     public String getApiKey() {
@@ -28,4 +34,20 @@ public void setApiKey(String apiKey) {
     public void setHost(String host) {
         this.host = host;
     }
+
+    public boolean isEnabled() {
+        return isEnabled;
+    }
+
+    public void setEnabled(boolean enabled) {
+        isEnabled = enabled;
+    }
+
+    public boolean isDebug() {
+        return isDebug;
+    }
+
+    public void setDebug(boolean debug) {
+        isDebug = debug;
+    }
 }

traceo-sdk-core/src/main/java/com/traceo/sdk/builder/ClientCoreConfiguration.java

@@ -25,4 +25,14 @@ public final Subclass withHost(String host) {
         configuration.setHost(host);
         return getSubclass();
     }
+
+    public final Subclass withEnabled(boolean enabled) {
+        configuration.setEnabled(enabled);
+        return getSubclass();
+    }
+
+    public final Subclass withDebug(boolean enabled) {
+        configuration.setDebug(enabled);
+        return getSubclass();
+    }
 }

traceo-sdk-core/src/main/java/com/traceo/sdk/builder/CoreBuilder.java

@@ -1,18 +1,43 @@
 package com.traceo.sdk.client;
 
 import com.traceo.sdk.builder.ClientCoreConfiguration;
+import com.traceo.sdk.http.HttpAsyncClient;
+import com.traceo.sdk.logging.ClientLogger;
+import org.apache.commons.logging.Log;
+
+import java.io.IOException;
 
 public class CoreClient<T extends ClientCoreConfiguration> {
+    private final static ClientLogger LOGGER = new ClientLogger(CoreClient.class);
     private static volatile ClientCoreConfiguration configuration;
+    private static HttpAsyncClient asyncTransport;
 
     protected CoreClient() {}
 
     public static <T extends ClientCoreConfiguration> void init(T clientConfiguration) {
         configuration = clientConfiguration;
+
+        if (clientConfiguration.isEnabled()) {
+            asyncTransport = new HttpAsyncClient();
+            shutdownHook();
+        } else {
+            LOGGER.log("Traceo client is not enabled.");
+        }
     }
 
     public static <T extends ClientCoreConfiguration> T getConfigs() {
         return (T) configuration;
     }
+
+    private static void shutdownHook() {
+        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+            try {
+                asyncTransport.closeHttpClient();
+            } catch (IOException e) {
+                LOGGER.logThrowableWithMessage("Exception while closing http client.", e);
+                throw new RuntimeException(e);
+            }
+        }));
+    }
 }
 

traceo-sdk-core/src/main/java/com/traceo/sdk/client/CoreClient.java

@@ -4,8 +4,6 @@ public class StringConverter {
     /**
      *  Method to convert string to header-string:
      *  eq. Some header Key -> some-header-key
-     * @param key
-     * @return
      */
     public static String convertToHeaderKey(String key) {
         if (key == null) {