Skip to content
Snippets Groups Projects
Commit 46445e3d authored by OZGCloud's avatar OZGCloud
Browse files

OZG-3665 code cleanup

parent e8dda569
Branches
Tags
No related merge requests found
......@@ -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";
......
......@@ -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>
......
......@@ -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;
}
......
......@@ -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];
}
}
}
......@@ -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() {
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) {
......
ozgcloud:
xta:
identifier: gae:jens.reese@mgm-tp.com
server:
address: localhost:3000
name: LI33-0005
......
logging:
level:
ROOT: INFO
ROOT: WARN
'[de.ozgcloud]': INFO
'[org.springframework.ws]': WARN
config: classpath:log4j2-local.xml
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment