Merge remote-tracking branch 'origin/issues/22_Blaze_fhir-bridge' into

develop

Author: hhund

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/client/FttpClientFactory.java

@@ -89,18 +89,29 @@ public void testConnection()
 	private final String fttpStudy;
 	private final String fttpTarget;
 
+	private final int connectTimeout;
+	private final int socketTimeout;
+	private final int connectionRequestTimeout;
+
 	private final String proxySchemeHostPort;
 	private final String proxyUsername;
 	private final String proxyPassword;
 
-	public FttpClientFactory(Path trustStorePath, Path certificatePath, Path privateKeyPath,
-			String fttpBasicAuthUsername, String fttpBasicAuthPassword, String fttpServerBase, String fttpApiKey,
-			String fttpStudy, String fttpTarget, String proxySchemeHostPort, String proxyUsername, String proxyPassword)
+	private final boolean hapiClientVerbose;
+
+	public FttpClientFactory(Path trustStorePath, Path certificatePath, Path privateKeyPath, int connectTimeout,
+			int socketTimeout, int connectionRequestTimeout, String fttpBasicAuthUsername, String fttpBasicAuthPassword,
+			String fttpServerBase, String fttpApiKey, String fttpStudy, String fttpTarget, String proxySchemeHostPort,
+			String proxyUsername, String proxyPassword, boolean hapiClientVerbose)
 	{
 		this.trustStorePath = trustStorePath;
 		this.certificatePath = certificatePath;
 		this.privateKeyPath = privateKeyPath;
 
+		this.connectTimeout = connectTimeout;
+		this.socketTimeout = socketTimeout;
+		this.connectionRequestTimeout = connectionRequestTimeout;
+
 		this.fttpBasicAuthUsername = fttpBasicAuthUsername;
 		this.fttpBasicAuthPassword = fttpBasicAuthPassword;
 
@@ -112,6 +123,8 @@ public FttpClientFactory(Path trustStorePath, Path certificatePath, Path private
 		this.proxySchemeHostPort = proxySchemeHostPort;
 		this.proxyUsername = proxyUsername;
 		this.proxyPassword = proxyPassword;
+
+		this.hapiClientVerbose = hapiClientVerbose;
 	}
 
 	@EventListener({ ContextRefreshedEvent.class })
@@ -155,8 +168,9 @@ protected FttpClient createFttpClient()
 		logger.debug("Creating key-store from {} and {}", certificatePath.toString(), privateKeyPath.toString());
 		KeyStore keyStore = readKeyStore(certificatePath, privateKeyPath, keyStorePassword);
 
-		return new FttpClientImpl(trustStore, keyStore, keyStorePassword, fttpBasicAuthUsername, fttpBasicAuthPassword,
-				fttpServerBase, fttpApiKey, fttpStudy, fttpTarget, proxySchemeHostPort, proxyUsername, proxyPassword);
+		return new FttpClientImpl(trustStore, keyStore, keyStorePassword, connectTimeout, socketTimeout,
+				connectionRequestTimeout, fttpBasicAuthUsername, fttpBasicAuthPassword, fttpServerBase, fttpApiKey,
+				fttpStudy, fttpTarget, proxySchemeHostPort, proxyUsername, proxyPassword, hapiClientVerbose);
 	}
 
 	private KeyStore readTrustStore(Path trustPath)

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/client/FttpClientImpl.java

@@ -49,15 +49,15 @@ public class FttpClientImpl implements FttpClient, InitializingBean
 	private final String proxyUsername;
 	private final String proxyPassword;
 
-	public FttpClientImpl(KeyStore trustStore, KeyStore keyStore, char[] keyStorePassword, String fttpBasicAuthUsername,
-			String fttpBasicAuthPassword, String fttpServerBase, String fttpApiKey, String fttpStudy, String fttpTarget,
-			String proxySchemeHostPort, String proxyUsername, String proxyPassword)
-	{
-		this.proxySchemeHostPort = proxySchemeHostPort;
-		this.proxyUsername = proxyUsername;
-		this.proxyPassword = proxyPassword;
+	private final boolean hapiClientVerbose;
 
-		clientFactory = createClientFactory(trustStore, keyStore, keyStorePassword);
+	public FttpClientImpl(KeyStore trustStore, KeyStore keyStore, char[] keyStorePassword, int connectTimeout,
+			int socketTimeout, int connectionRequestTimeout, String fttpBasicAuthUsername, String fttpBasicAuthPassword,
+			String fttpServerBase, String fttpApiKey, String fttpStudy, String fttpTarget, String proxySchemeHostPort,
+			String proxyUsername, String proxyPassword, boolean hapiClientVerbose)
+	{
+		clientFactory = createClientFactory(trustStore, keyStore, keyStorePassword, connectTimeout, socketTimeout,
+				connectionRequestTimeout);
 
 		this.fttpServerBase = fttpServerBase;
 		this.fttpBasicAuthUsername = fttpBasicAuthUsername;
@@ -66,10 +66,16 @@ public FttpClientImpl(KeyStore trustStore, KeyStore keyStore, char[] keyStorePas
 		this.fttpApiKey = fttpApiKey;
 		this.fttpStudy = fttpStudy;
 		this.fttpTarget = fttpTarget;
+
+		this.proxySchemeHostPort = proxySchemeHostPort;
+		this.proxyUsername = proxyUsername;
+		this.proxyPassword = proxyPassword;
+
+		this.hapiClientVerbose = hapiClientVerbose;
 	}
 
 	protected ApacheRestfulClientFactoryWithTlsConfig createClientFactory(KeyStore trustStore, KeyStore keyStore,
-			char[] keyStorePassword)
+			char[] keyStorePassword, int connectTimeout, int socketTimeout, int connectionRequestTimeout)
 	{
 		Objects.requireNonNull(trustStore, "trustStore");
 		Objects.requireNonNull(keyStore, "keyStore");
@@ -81,6 +87,10 @@ protected ApacheRestfulClientFactoryWithTlsConfig createClientFactory(KeyStore t
 		hapiClientFactory.setServerValidationMode(ServerValidationModeEnum.NEVER);
 		configureProxy(hapiClientFactory);
 
+		hapiClientFactory.setConnectTimeout(connectTimeout);
+		hapiClientFactory.setSocketTimeout(socketTimeout);
+		hapiClientFactory.setConnectionRequestTimeout(connectionRequestTimeout);
+
 		fhirContext.setRestfulClientFactory(hapiClientFactory);
 		return hapiClientFactory;
 	}
@@ -228,16 +238,26 @@ public void testConnection()
 	private IGenericClient createGenericClient()
 	{
 		IGenericClient client = clientFactory.newGenericClient(fttpServerBase);
-		client.registerInterceptor(new LoggingInterceptor());
 
-		if (configuredWithBasicAuth())
-			client.registerInterceptor(new BasicAuthInterceptor(fttpBasicAuthUsername, fttpBasicAuthPassword));
+		configuredWithBasicAuth(client);
+		configureLoggingInterceptor(client);
 
 		return client;
 	}
 
-	private boolean configuredWithBasicAuth()
+	private void configuredWithBasicAuth(IGenericClient client)
 	{
-		return fttpBasicAuthUsername != null && fttpBasicAuthPassword != null;
+		if (fttpBasicAuthUsername != null && fttpBasicAuthPassword != null)
+			client.registerInterceptor(new BasicAuthInterceptor(fttpBasicAuthUsername, fttpBasicAuthPassword));
+	}
+
+	private void configureLoggingInterceptor(IGenericClient client)
+	{
+		if (hapiClientVerbose)
+		{
+			LoggingInterceptor loggingInterceptor = new LoggingInterceptor(true);
+			loggingInterceptor.setLogger(new HapiClientLogger(logger));
+			client.registerInterceptor(loggingInterceptor);
+		}
 	}
 }