0.14.1:

- Bugfixing: Pipeline-Operationen
sberg-net · Jun 22, 2023 · 3400771 · 3400771
1 parent 9581bf1
commit 3400771
Show file tree

Hide file tree

Showing 21 changed files with 852 additions and 625 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -19,6 +19,21 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ```
 ```
 
+## [0.14.1]
+
+### Added
+```
+```
+
+### Changed
+```
+```
+
+### Fixed
+```
+- Pipeline-Operationen
+```
+
 ## [0.14.0]
 
 ### Added

diff --git a/pom.xml b/pom.xml
@@ -10,7 +10,7 @@
     </parent>
     <groupId>net.sberg</groupId>
     <artifactId>openkim</artifactId>
-    <version>0.14.0</version>
+    <version>0.14.1</version>
     <name>openkim</name>
     <description>Open KIM Client Modul</description>
 

diff --git a/src/main/java/net/sberg/openkim/fachdienst/FachdienstService.java b/src/main/java/net/sberg/openkim/fachdienst/FachdienstService.java
@@ -138,6 +138,7 @@ private String aRequest(DefaultLogger logger, Konnektor konnektor, String domain
         DefaultPipelineOperationContext defaultPipelineOperationContext = new DefaultPipelineOperationContext(logger);
         defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_DOMAIN, domain);
         defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_RECORD_TYPE, Type.string(Type.A));
+
         dnsRequestOperation.execute(
             defaultPipelineOperationContext,
             context -> {
@@ -177,6 +178,7 @@ private Fachdienst fqdnRequest(DefaultLogger logger, Konnektor konnektor, Fachdi
         DefaultPipelineOperationContext defaultPipelineOperationContext = new DefaultPipelineOperationContext(logger);
         defaultPipelineOperationContext.setEnvironmentValue(DnsFqdnRequestOperation.NAME, DnsFqdnRequestOperation.ENV_DOMAIN, domain);
         defaultPipelineOperationContext.setEnvironmentValue(DnsFqdnRequestOperation.NAME, DnsFqdnRequestOperation.ENV_PTR_DOMAIN_SUFFIX, fachdienst.getTyp().getDomainSuffix());
+
         dnsFqdnRequestOperation.execute(
             defaultPipelineOperationContext,
             context -> {

diff --git a/src/main/java/net/sberg/openkim/gateway/pop3/cmdhandler/Pop3GatewayAuthCmdHandler.java b/src/main/java/net/sberg/openkim/gateway/pop3/cmdhandler/Pop3GatewayAuthCmdHandler.java
@@ -373,15 +373,16 @@ protected Response doAuthTest(POP3Session session, Username username, String pas
                     DefaultPipelineOperationContext defaultPipelineOperationContext = new DefaultPipelineOperationContext(((Pop3GatewaySession) session).getLogger());
                     defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_DOMAIN, ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost());
                     defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_RECORD_TYPE, Type.string(Type.A));
+
                     dnsRequestOperation.execute(
-                            defaultPipelineOperationContext,
-                            context -> {
-                                ((Pop3GatewaySession) session).log("dns request finished for: " + ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost());
-                            },
-                            (context, e) -> {
-                                log.error("dns request failed for: " + ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost(), e);
-                                failedCounter.incrementAndGet();
-                            }
+                        defaultPipelineOperationContext,
+                        context -> {
+                            ((Pop3GatewaySession) session).log("dns request finished for: " + ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost());
+                        },
+                        (context, e) -> {
+                            log.error("dns request failed for: " + ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost(), e);
+                            failedCounter.incrementAndGet();
+                        }
                     );
                     DnsResultContainer dnsResultContainer = (DnsResultContainer) defaultPipelineOperationContext.getEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_DNS_RESULT);
                     if (failedCounter.get() > 0 || dnsResultContainer == null || dnsResultContainer.isError()) {

diff --git a/src/main/java/net/sberg/openkim/gateway/pop3/cmdhandler/Pop3GatewayPassCmdHandler.java b/src/main/java/net/sberg/openkim/gateway/pop3/cmdhandler/Pop3GatewayPassCmdHandler.java
@@ -99,6 +99,7 @@ protected final Response doAuth(POP3Session session, Username user, String pass)
                     DefaultPipelineOperationContext defaultPipelineOperationContext = new DefaultPipelineOperationContext(((Pop3GatewaySession) session).getLogger());
                     defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_DOMAIN, ((Pop3GatewaySession) session).getLogger().getDefaultLoggerContext().getMailServerHost());
                     defaultPipelineOperationContext.setEnvironmentValue(DnsRequestOperation.NAME, DnsRequestOperation.ENV_RECORD_TYPE, Type.string(Type.A));
+
                     dnsRequestOperation.execute(
                             defaultPipelineOperationContext,
                             context -> {