diff --git a/semantik-adapter/src/main/java/de/itvsh/kop/eingangsadapter/semantik/enginebased/xta/XtaZustaendigeStelleMapper.java b/semantik-adapter/src/main/java/de/itvsh/kop/eingangsadapter/semantik/enginebased/xta/XtaZustaendigeStelleMapper.java index 6df7b7fe85274a7bc077827fee0504194d083901..0d7d18e95eb814072220f3b9bb61ec9fb0cf3199 100644 --- a/semantik-adapter/src/main/java/de/itvsh/kop/eingangsadapter/semantik/enginebased/xta/XtaZustaendigeStelleMapper.java +++ b/semantik-adapter/src/main/java/de/itvsh/kop/eingangsadapter/semantik/enginebased/xta/XtaZustaendigeStelleMapper.java @@ -6,7 +6,7 @@ import de.itvsh.kop.eingangsadapter.common.formdata.FormData; import de.itvsh.kop.eingangsadapter.common.formdata.ZustaendigeStelle; @Component -public class XtaZustaendigeStelleMapper implements XtaEngineBasedMapper { +class XtaZustaendigeStelleMapper implements XtaEngineBasedMapper { static final String ORGAID_FOERDERBANK = "9797773"; diff --git a/xta-adapter/pom.xml b/xta-adapter/pom.xml index 11396424c11e2e8094de1f833273f142fc28ba42..c6eae8e484150eab9e7e99540a857f2432e6d68d 100644 --- a/xta-adapter/pom.xml +++ b/xta-adapter/pom.xml @@ -8,9 +8,11 @@ <artifactId>xta-adapter</artifactId> <name>Eingangs Adapter - XTA</name> <packaging>jar</packaging> + <properties> <spring-boot.build-image.imageName>docker.ozg-sh.de/xta-adapter:build-latest</spring-boot.build-image.imageName> </properties> + <dependencies> <dependency> <groupId>org.springframework.boot</groupId> @@ -84,6 +86,7 @@ <optional>true</optional> </dependency> </dependencies> + <build> <plugins> <plugin> diff --git a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaProperties.java b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaProperties.java index 4f06606c7e0c450823f6221ef46e4bbd163225bf..82660abaa429c8f6856300554de00de5c7c0b72f 100644 --- a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaProperties.java +++ b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaProperties.java @@ -3,14 +3,15 @@ package de.ozgcloud.eingang.xta; import java.math.BigInteger; import java.net.URI; +import jakarta.validation.constraints.NotEmpty; +import jakarta.validation.constraints.NotNull; + import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.Resource; import org.springframework.stereotype.Component; import org.springframework.validation.annotation.Validated; -import jakarta.validation.constraints.NotEmpty; -import jakarta.validation.constraints.NotNull; import lombok.Getter; import lombok.Setter; import lombok.ToString; @@ -29,7 +30,7 @@ class XtaProperties { private KeyStore keyStore; private Actions actions; - + @NotEmpty private String identifier; } diff --git a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRemoteServiceConfiguration.java b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRemoteServiceConfiguration.java index 501eafac9c0b739d703e77ec1e855a3406c4074d..e180c5c82094c5793138aac5a4787dcbcbd3b6ab 100644 --- a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRemoteServiceConfiguration.java +++ b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRemoteServiceConfiguration.java @@ -8,10 +8,8 @@ import java.security.KeyStore; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; -import java.security.cert.X509Certificate; import javax.net.ssl.KeyManagerFactory; -import javax.net.ssl.X509TrustManager; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.webservices.client.WebServiceTemplateCustomizer; @@ -97,7 +95,8 @@ public class XtaRemoteServiceConfiguration { var messageSender1 = new HttpsUrlConnectionMessageSender(); messageSender1.setKeyManagers(keyManagerFactory.getKeyManagers()); - messageSender1.setHostnameVerifier((hostname, session) -> true); // NOSONAR only for test/local + messageSender1.setHostnameVerifier((hostname, session) -> true); // NOSONAR hostname verification is senseless due missing DNS for + // Dataport XTA Server return messageSender1; } catch (Exception e) { @@ -116,18 +115,4 @@ public class XtaRemoteServiceConfiguration { return keyStore; } - static class UnTrustworthyTrustManager implements X509TrustManager { - @Override - public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException { // NOSONAR only for test/local - } - - @Override - public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException { // NOSONAR only for test/local - } - - @Override - public X509Certificate[] getAcceptedIssuers() { - return new X509Certificate[0]; - } - } } diff --git a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRunner.java b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRunner.java index 65a292e9e1507f8ea1fb96e5ea5d5baed5ebd3cf..6b8ea3cc66bacd40ab00a0ddf0f8cc3cb11efbf8 100644 --- a/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRunner.java +++ b/xta-adapter/src/main/java/de/ozgcloud/eingang/xta/XtaRunner.java @@ -2,7 +2,6 @@ package de.ozgcloud.eingang.xta; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationListener; -import org.springframework.context.annotation.Profile; import org.springframework.context.event.ContextRefreshedEvent; import org.springframework.stereotype.Component; @@ -13,7 +12,6 @@ import lombok.extern.log4j.Log4j2; @Log4j2 @Component -@Profile("!itcase") class XtaRunner implements ApplicationListener<ContextRefreshedEvent> { @Autowired @@ -28,11 +26,16 @@ class XtaRunner implements ApplicationListener<ContextRefreshedEvent> { } void runGetXtaMessages() { - service.getMessagesAsFormData().forEach(this::processAndAcknowledge); + try { + service.getMessagesAsFormData().forEach(this::processAndAcknowledge); + } catch (RuntimeException e) { + LOG.error("Error fetch XTA Message List.", e); + } } private void processAndAcknowledge(@NonNull FormData formData) { try { + LOG.info("Process XTA-Message '{}'.", formData.getHeader().getRequestId()); semantikAdapter.processFormData(formData); service.acknowledgeReceive(XtaMessageId.from(formData.getHeader().getRequestId())); } catch (RuntimeException e) { diff --git a/xta-adapter/src/main/resources/application-local.yml b/xta-adapter/src/main/resources/application-local.yml index 366b836758532661c6a337c2cf9860f17e43d7e1..e5fa8058ac38cf3a5222cfdc9bb43f076c98353a 100644 --- a/xta-adapter/src/main/resources/application-local.yml +++ b/xta-adapter/src/main/resources/application-local.yml @@ -1,5 +1,6 @@ ozgcloud: xta: + identifier: gae:jens.reese@mgm-tp.com server: address: localhost:3000 name: LI33-0005 diff --git a/xta-adapter/src/main/resources/application.yml b/xta-adapter/src/main/resources/application.yml index 54136df49558fae4edcee297fdd42480214fc494..007ad91392b23fa67cbe88bdd87a2b187240198f 100644 --- a/xta-adapter/src/main/resources/application.yml +++ b/xta-adapter/src/main/resources/application.yml @@ -1,6 +1,6 @@ logging: level: - ROOT: INFO + ROOT: WARN '[de.ozgcloud]': INFO '[org.springframework.ws]': WARN config: classpath:log4j2-local.xml