Merge pull request #292 from avaje/feature/http-client-build

[http client] Refactor move DBaseBuilder code into DHttpClientBuilder

Author: rbygrave

http-client/src/main/java/io/avaje/http/client/DBaseBuilder.java

@@ -1,18 +1,174 @@
 package io.avaje.http.client;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.avaje.inject.BeanScope;
+import io.avaje.jsonb.Jsonb;
 
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.SSLParameters;
 import java.net.Authenticator;
 import java.net.CookieHandler;
+import java.net.CookieManager;
 import java.net.ProxySelector;
 import java.time.Duration;
+import java.util.ArrayList;
 import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
 import java.util.concurrent.Executor;
 import java.util.function.Function;
 
-final class DHttpClientBuilder extends DBaseBuilder implements HttpClient.Builder, HttpClient.Builder.State {
+import static java.util.Objects.requireNonNull;
+
+final class DHttpClientBuilder implements HttpClient.Builder, HttpClient.Builder.State {
+
+  private java.net.http.HttpClient client;
+  private String baseUrl;
+  private boolean requestLogging = true;
+  private Duration connectionTimeout = Duration.ofSeconds(20);
+  private Duration requestTimeout = Duration.ofSeconds(20);
+  private BodyAdapter bodyAdapter;
+  private RetryHandler retryHandler;
+  private Function<HttpException, RuntimeException> errorHandler;
+  private AuthTokenProvider authTokenProvider;
+
+  private CookieHandler cookieHandler = new CookieManager();
+  private java.net.http.HttpClient.Redirect redirect = java.net.http.HttpClient.Redirect.NORMAL;
+  private java.net.http.HttpClient.Version version;
+  private Executor executor;
+  private ProxySelector proxy;
+  private SSLContext sslContext;
+  private SSLParameters sslParameters;
+  private Authenticator authenticator;
+  private int priority;
+
+  private final List<RequestIntercept> interceptors = new ArrayList<>();
+  private final List<RequestListener> listeners = new ArrayList<>();
+
+  private void configureRetryHandler(BeanScope beanScope) {
+    beanScope.getOptional(RetryHandler.class)
+      .ifPresent(this::setRetryHandler);
+  }
+
+  private void setRetryHandler(RetryHandler retryHandler) {
+    this.retryHandler = retryHandler;
+  }
+
+  private void configureBodyAdapter(BeanScope beanScope) {
+    Optional<BodyAdapter> body = beanScope.getOptional(BodyAdapter.class);
+    if (body.isPresent()) {
+      bodyAdapter = body.get();
+    } else if (beanScope.contains("io.avaje.jsonb.Jsonb")) {
+      bodyAdapter = new JsonbBodyAdapter(beanScope.get(Jsonb.class));
+    } else if (beanScope.contains("com.fasterxml.jackson.databind.ObjectMapper")) {
+      ObjectMapper objectMapper = beanScope.get(ObjectMapper.class);
+      bodyAdapter = new JacksonBodyAdapter(objectMapper);
+    }
+  }
+
+  private RequestListener buildListener() {
+    if (listeners.isEmpty()) {
+      return null;
+    } else if (listeners.size() == 1) {
+      return listeners.get(0);
+    } else {
+      return new DRequestListeners(listeners);
+    }
+  }
+
+  private RequestIntercept buildIntercept() {
+    if (interceptors.isEmpty()) {
+      return null;
+    } else if (interceptors.size() == 1) {
+      return interceptors.get(0);
+    } else {
+      return new DRequestInterceptors(interceptors);
+    }
+  }
+
+  private java.net.http.HttpClient defaultClient() {
+    final var builder = java.net.http.HttpClient.newBuilder()
+      .followRedirects(redirect)
+      .connectTimeout(connectionTimeout);
+
+    if (cookieHandler != null) {
+      builder.cookieHandler(cookieHandler);
+    }
+    if (version != null) {
+      builder.version(version);
+    }
+    if (executor != null) {
+      builder.executor(executor);
+    }
+    if (proxy != null) {
+      builder.proxy(proxy);
+    }
+    if (sslContext != null) {
+      builder.sslContext(sslContext);
+    }
+    if (sslParameters != null) {
+      builder.sslParameters(sslParameters);
+    }
+    if (authenticator != null) {
+      builder.authenticator(authenticator);
+    }
+    if (priority > 0) {
+      builder.priority(priority);
+    }
+    return builder.build();
+  }
+
+  /**
+   * Create a reasonable default BodyAdapter if avaje-jsonb or Jackson are present.
+   */
+  private BodyAdapter defaultBodyAdapter() {
+    if (detectJsonb()) {
+      bodyAdapter = new JsonbBodyAdapter();
+    } else if (detectJackson()) {
+      bodyAdapter = new JacksonBodyAdapter();
+    }
+    return bodyAdapter;
+  }
+
+  private boolean detectJsonb() {
+    return detectTypeExists("io.avaje.jsonb.Jsonb");
+  }
+
+  private boolean detectJackson() {
+    return detectTypeExists("com.fasterxml.jackson.databind.ObjectMapper");
+  }
+
+  private boolean detectTypeExists(String className) {
+    try {
+      Class.forName(className);
+      return true;
+    } catch (ClassNotFoundException | IllegalAccessError e) {
+      return false;
+    }
+  }
+
+  private DHttpClientContext buildClient() {
+    requireNonNull(baseUrl, "baseUrl is not specified");
+    requireNonNull(requestTimeout, "requestTimeout is not specified");
+    final var httpClient = client != null ? client : defaultClient();
+    if (requestLogging) {
+      // register the built-in request/response logging
+      this.listeners.add(new RequestLogger());
+    }
+    if (bodyAdapter == null) {
+      bodyAdapter = defaultBodyAdapter();
+    }
+    return new DHttpClientContext(
+      httpClient,
+      baseUrl,
+      requestTimeout,
+      bodyAdapter,
+      retryHandler,
+      errorHandler,
+      buildListener(),
+      authTokenProvider,
+      buildIntercept());
+  }
 
   DHttpClientBuilder() {
   }
@@ -144,7 +300,12 @@ public HttpClient.Builder.State state() {
 
   @Override
   public HttpClient.Builder configureWith(BeanScope beanScope) {
-    super.configureFromScope(beanScope);
+    if (bodyAdapter == null) {
+      configureBodyAdapter(beanScope);
+    }
+    if (retryHandler == null) {
+      configureRetryHandler(beanScope);
+    }
     return this;
   }