feat(http): support HTTP-Proxy connections on client level

3 files changed, 74 insertions, 0 deletions

diff --git a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientConfiguration.java b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientConfiguration.java
index 4d808f2b..2081bd24 100644
--- a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientConfiguration.java
+++ b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientConfiguration.java
@@ -49,6 +49,9 @@ public class HttpClientConfiguration {
   boolean enablePreEmptiveHttpBasicAuth = true;
   
   @Setter
+  boolean enableHttpProxyMode = false;
+
+  @Setter
   boolean disableTlsHostCertificateValidation = false;
 
   @Setter
diff --git a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientFactory.java b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientFactory.java
index 04dd36cb..62e781b9 100644
--- a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientFactory.java
+++ b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/http/HttpClientFactory.java
@@ -22,6 +22,7 @@ import org.apache.hc.client5.http.impl.classic.HttpClientBuilder;
 import org.apache.hc.client5.http.impl.classic.HttpClients;
 import org.apache.hc.client5.http.impl.io.BasicHttpClientConnectionManager;
 import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager;
+import org.apache.hc.client5.http.impl.routing.DefaultProxyRoutePlanner;
 import org.apache.hc.client5.http.io.HttpClientConnectionManager;
 import org.apache.hc.client5.http.protocol.RedirectStrategy;
 import org.apache.hc.client5.http.socket.ConnectionSocketFactory;
@@ -30,8 +31,10 @@ import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory;
 import org.apache.hc.client5.http.ssl.NoopHostnameVerifier;
 import org.apache.hc.client5.http.ssl.SSLConnectionSocketFactory;
 import org.apache.hc.core5.http.HttpException;
+import org.apache.hc.core5.http.HttpHost;
 import org.apache.hc.core5.http.HttpRequest;
 import org.apache.hc.core5.http.HttpResponse;
+import org.apache.hc.core5.http.URIScheme;
 import org.apache.hc.core5.http.config.Registry;
 import org.apache.hc.core5.http.config.RegistryBuilder;
 import org.apache.hc.core5.http.io.SocketConfig;
@@ -81,6 +84,20 @@ public class HttpClientFactory implements IHttpClientFactory {
   public static final String PROP_CONFIG_CLIENT_HTTP_SSL_HOSTNAMEVERIFIER_TRUSTALL =
       "client.http.ssl.hostnameverifier.trustall";
 
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_HOST_SSL =
+      "client.http.connection.proxy.host.ssl";
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_HOST =
+      "client.http.connection.proxy.host";
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_PORT =
+      "client.http.connection.proxy.port";
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_AUTH_USERNAME =
+      "client.http.connection.proxy.auth.username";
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_AUTH_PASSWORD =
+      "client.http.connection.proxy.auth.password";
+
+  public static final String PROP_CONFIG_CLIENT_HTTP_PROXY_ENABLED =
+      "client.http.connection.proxy.enabled";
+
   public static final String PROP_CONFIG_CLIENT_MODE = "client.authmode";
   public static final String PROP_CONFIG_CLIENT_AUTH_HTTP_USERNAME = "client.auth.http.username";
   public static final String PROP_CONFIG_CLIENT_AUTH_HTTP_PASSORD = "client.auth.http.password";
@@ -149,6 +166,9 @@ public class HttpClientFactory implements IHttpClientFactory {
       builder.setDefaultRequestConfig(buildDefaultRequestConfig(config));
       injectInternalRetryHandler(builder, config);
 
+      // inject HTTP Proxy
+      injectHttpProxyConnections(builder, config);
+
       // inject basic authentication infos
       injectBasicAuthenticationIfRequired(builder, config);
 
@@ -212,6 +232,9 @@ public class HttpClientFactory implements IHttpClientFactory {
     defaultHttpClientBuilder.setDefaultRequestConfig(buildDefaultRequestConfig(defaultHttpClientConfig));
     injectInternalRetryHandler(defaultHttpClientBuilder, defaultHttpClientConfig);
 
+    // inject HTTP Proxy
+    injectHttpProxyConnections(defaultHttpClientBuilder, defaultHttpClientConfig);
+
     // inject http basic authentication
     injectBasicAuthenticationIfRequired(defaultHttpClientBuilder, defaultHttpClientConfig);
 
@@ -230,6 +253,28 @@ public class HttpClientFactory implements IHttpClientFactory {
 
   }
 
+  private void injectHttpProxyConnections(HttpClientBuilder httpClientBuilder,
+      HttpClientConfiguration httpClientConfig) throws EaafConfigurationException {
+    if (httpClientConfig.isEnableHttpProxyMode()) {
+      log.debug("Injecting HTTP Proxy-Connections ...  ");
+      URIScheme proxySchema = basicConfig.getBasicConfigurationBoolean(
+          PROP_CONFIG_CLIENT_HTTP_PROXY_HOST_SSL, false)
+              ? URIScheme.HTTPS
+              : URIScheme.HTTP;
+      HttpHost proxy = new HttpHost(
+          proxySchema.getId(),
+          ConfigurationUtils.parseString(basicConfig, PROP_CONFIG_CLIENT_HTTP_PROXY_HOST),
+          ConfigurationUtils.parseInteger(basicConfig, PROP_CONFIG_CLIENT_HTTP_PROXY_PORT));
+      DefaultProxyRoutePlanner routePlanner = new DefaultProxyRoutePlanner(proxy);
+      httpClientBuilder.setRoutePlanner(routePlanner);
+      log.info("Set HTTP Proxy-Connection: {} for client: {}", proxy, httpClientConfig.getFriendlyName());
+
+    } else {
+      log.trace("Injection of HTTP Proxy-Connection was skipped");
+
+    }
+  }
+
   private HttpClientConfiguration buildDefaultHttpClientConfiguration() throws EaafConfigurationException {
     final HttpClientConfiguration config = new HttpClientConfiguration("Default");
 
@@ -265,6 +310,9 @@ public class HttpClientFactory implements IHttpClientFactory {
         PROP_CONFIG_CLIENT_HTTP_CONNECTION_RETRY_COUNT,
         DEFAULT_CONFIG_CLIENT_HTTP_CONNECTION_RETRY_COUNT)));
 
+    config.setEnableHttpProxyMode(basicConfig.getBasicConfigurationBoolean(
+        PROP_CONFIG_CLIENT_HTTP_PROXY_ENABLED, false));
+
     // validate configuration object
     config.validate();
 
diff --git a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/utils/ConfigurationUtils.java b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/utils/ConfigurationUtils.java
index 81de9762..ae39ba49 100644
--- a/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/utils/ConfigurationUtils.java
+++ b/eaaf_core_utils/src/main/java/at/gv/egiz/eaaf/core/impl/utils/ConfigurationUtils.java
@@ -1,5 +1,7 @@
 package at.gv.egiz.eaaf.core.impl.utils;
 
+import org.apache.commons.lang3.StringUtils;
+
 import at.gv.egiz.eaaf.core.api.idp.IConfiguration;
 import at.gv.egiz.eaaf.core.exceptions.EaafConfigurationException;
 import lombok.extern.slf4j.Slf4j;
@@ -15,6 +17,26 @@ public class ConfigurationUtils {
 
 
   /**
+   * Read String value from configuration.
+   * 
+   * @param basicConfig Configuration object
+   * @param propertyKey Configuration key
+   * @return Configuration value
+   * @throws EaafConfigurationException If configuration value does not exist
+   */
+  public static String parseString(IConfiguration basicConfig, String propertyKey)
+      throws EaafConfigurationException {
+    String value = basicConfig.getBasicConfiguration(propertyKey); 
+    if (StringUtils.isEmpty(value)) {
+      log.error("Can not find String value from configuration: {}", propertyKey);
+      throw new EaafConfigurationException("internal.configuration.00", new Object[] { propertyKey });
+
+    }
+    
+    return value;
+  }
+
+  /**
    * Parse Integer value from configuration.
    * 
    * @param basicConfig Configuration object
@@ -81,4 +103,5 @@ public class ConfigurationUtils {
   private ConfigurationUtils() {
 
   }
+
 }