feat/http client factory builders

Author: piotr-szewczyk

.idea/misc.xml

@@ -18,6 +18,8 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <apache.httpclient.version>4.5.13</apache.httpclient.version>
+        <jackson.databind.version>2.13.0</jackson.databind.version>
     </properties>
 
 </project>

.idea/workspace.xml

@@ -17,4 +17,35 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>${apache.httpclient.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.databind.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.13.1</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>11</source>
+                    <target>11</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
 </project>

pom.xml

@@ -0,0 +1,20 @@
+package com.traceo.sdk.converters;
+
+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) {
+            return null;
+        }
+
+        String lowercaseString = key.toLowerCase();
+        String result = lowercaseString.replaceAll("\\s+", "-");
+
+        return result;
+    }
+}

traceo-sdk-core/pom.xml

@@ -0,0 +1,7 @@
+package com.traceo.sdk.exceptions;
+
+public class SDKException extends Exception {
+    public SDKException(String message) {
+        super(message);
+    }
+}

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

@@ -0,0 +1,45 @@
+package com.traceo.sdk.http;
+
+import org.apache.http.client.ResponseHandler;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.protocol.HttpContext;
+
+import java.io.IOException;
+
+public class HttpClient {
+
+    public static final HttpClientFactory httpClientFactory = new HttpClientFactory();
+    private final HttpRequestFactory httpRequestFactory = new HttpRequestFactory();
+
+    private final CloseableHttpClient httpClient;
+    private final HttpClientConfiguration configuration;
+
+    public HttpClient() {
+        this(new HttpClientConfiguration());
+    }
+
+    public HttpClient(HttpClientConfiguration config) {
+        this.configuration = config;
+        this.httpClient = httpClientFactory.create(config);
+    }
+
+    public void execute(IRequest<?> IRequest) throws IOException {
+        this.httpClient.execute(httpRequestFactory.create(IRequest, this.configuration));
+    }
+
+    public void execute(IRequest<?> IRequest, ResponseHandler<Void> responseHandler) throws IOException {
+        this.httpClient.execute(httpRequestFactory.create(IRequest, this.configuration), responseHandler);
+    }
+
+    public void execute(IRequest<?> IRequest, HttpContext httpContext) throws IOException {
+        this.httpClient.execute(httpRequestFactory.create(IRequest, this.configuration), null, httpContext);
+    }
+
+    public void execute(IRequest<?> IRequest, ResponseHandler<Void> responseHandler, HttpContext context) throws IOException {
+        this.httpClient.execute(httpRequestFactory.create(IRequest, this.configuration), responseHandler, context);
+    }
+
+    public void shutdown() throws IOException {
+        httpClient.close();
+    }
+}

traceo-sdk-core/src/main/java/com/traceo/sdk/converters/StringConverter.java

@@ -0,0 +1,127 @@
+package com.traceo.sdk.http;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class HttpClientConfiguration {
+    private Map<String, String> headers = new HashMap<String, String>();
+
+    private String host = null;
+
+    private String userAgent = null;
+
+    private boolean withCompression = true;
+
+    private int connectionRequestTimeout = 5000;
+
+    private int connectionTimeout = 5000;
+
+    private int socketTimeout = 5000;
+
+    private int maxRedirects = 5;
+
+    // Maximum connections per route (host:port)
+    private int maxConnPerRoute = 5;
+
+    // Maximum total connections in the pool
+    private int maxConnection = 100;
+
+    public HttpClientConfiguration() {}
+
+    public HttpClientConfiguration(HttpClientConfiguration other) {
+        this.headers.putAll(other.getHeaders());
+        this.host = other.getHost();
+        this.connectionRequestTimeout = other.getConnectionTimeout();
+        this.connectionTimeout = other.getConnectionTimeout();
+        this.socketTimeout = other.getSocketTimeout();
+        this.maxRedirects = other.getMaxRedirects();
+        this.maxConnection = other.getMaxConnection();
+        this.maxConnPerRoute = other.getMaxConnPerRoute();
+        this.userAgent = other.getUserAgent();
+        this.withCompression = other.isWithCompression();
+    }
+
+    public int getMaxConnPerRoute() {
+        return maxConnPerRoute;
+    }
+
+    public void setMaxConnPerRoute(int maxConnPerRoute) {
+        this.maxConnPerRoute = maxConnPerRoute;
+    }
+
+    public int getMaxConnection() {
+        return maxConnection;
+    }
+
+    public void setMaxConnection(int maxConnection) {
+        this.maxConnection = maxConnection;
+    }
+
+    public void setWithCompression(boolean withCompression) {
+        this.withCompression = withCompression;
+    }
+
+    public int getSocketTimeout() {
+        return socketTimeout;
+    }
+
+    public void setSocketTimeout(int socketTimeout) {
+        this.socketTimeout = socketTimeout;
+    }
+
+    public boolean isWithCompression() {
+        return withCompression;
+    }
+
+    public String getUserAgent() {
+        return userAgent;
+    }
+
+    public void setUserAgent(String userAgent) {
+        this.userAgent = userAgent;
+    }
+
+    public int getMaxRedirects() {
+        return maxRedirects;
+    }
+
+    public void setMaxRedirects(int maxRedirects) {
+        this.maxRedirects = maxRedirects;
+    }
+
+    public int getConnectionRequestTimeout() {
+        return connectionRequestTimeout;
+    }
+
+    public void setConnectionRequestTimeout(int connectionRequestTimeout) {
+        this.connectionRequestTimeout = connectionRequestTimeout;
+    }
+
+    public int getConnectionTimeout() {
+        return connectionTimeout;
+    }
+
+    public void setConnectionTimeout(int connectionTimeout) {
+        this.connectionTimeout = connectionTimeout;
+    }
+
+    public String getHost() {
+        return host;
+    }
+
+    public void setHost(String host) {
+        this.host = host;
+    }
+
+    public void addHeader(String name, String value) {
+        headers.put(name, value);
+    }
+
+    public Map<String, String> getHeaders() {
+        return headers;
+    }
+
+    public void setHeaders(Map<String, String> headers) {
+        this.headers = headers;
+    }
+}