1 files changed, 74 insertions, 0 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/service/MsgService.java b/src/main/java/at/gv/egiz/moazs/service/MsgService.java
new file mode 100644
index 0000000..93f1ed5
--- /dev/null
+++ b/src/main/java/at/gv/egiz/moazs/service/MsgService.java
@@ -0,0 +1,74 @@
+package at.gv.egiz.moazs.service;
+import at.gv.egiz.moazs.process.MsgResponseHandler;
+import at.gv.egiz.moazs.repository.DeliveryRepository;
+import at.gv.egiz.moazs.scheme.MsgResponse;
+import at.gv.egiz.moazs.scheme.NameSpace;
+import at.gv.egiz.moazs.scheme.NotificationResponse;
+import at.gv.egiz.moazs.scheme.RequestStatusResponse;
+import at.gv.zustellung.msg.xsd.*;
+import org.apache.cxf.annotations.SchemaValidation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import static at.gv.zustellung.msg.xsd.DeliveryNotificationACKType.deliveryNotificationACKTypeBuilder;
+import static at.gv.zustellung.msg.xsd.DeliveryRequestStatusACKType.deliveryRequestStatusACKTypeBuilder;
+import static at.gv.zustellung.msg.xsd.GetVersionResponse.getVersionResponseBuilder;
+import static java.util.concurrent.CompletableFuture.runAsync;
+
+@Service
+@SchemaValidation(type = SchemaValidation.SchemaValidationType.BOTH)
+public class MsgService implements Zuse2AppPort {
+
+    private final DeliveryRepository repository;
+    private final MsgResponseHandler handler;
+
+    @Autowired
+    public MsgService(DeliveryRepository repository, MsgResponseHandler handler) {
+        this.repository = repository;
+        this.handler = handler;
+    }
+
+    @Override
+    public GetVersionResponse getVersion(SimpleRequestType getVersionRequest) {
+        return getVersionResponseBuilder()
+                .withVersion(NameSpace.MSG_VERSION)
+                .build();
+    }
+
+    @Override
+    public DeliveryRequestStatusACKType status(DeliveryRequestStatusType status) {
+        var response = new RequestStatusResponse(status);
+        sendToWork(response);
+        return statusAck(response.getAppDeliveryID(), response.getZSDeliveryID());
+    }
+
+    private DeliveryRequestStatusACKType statusAck(String appDeliveryID, String zsDeliveryID) {
+        return deliveryRequestStatusACKTypeBuilder()
+                .withAppDeliveryID(appDeliveryID)
+                .withZSDeliveryID(zsDeliveryID)
+                .withVersion(NameSpace.MSG_VERSION)
+                .build();
+    }
+
+    @Override
+    public DeliveryNotificationACKType notification(DeliveryNotificationType notification) {
+        var response = new NotificationResponse(notification);
+        sendToWork(response);
+        return notificationAck(response.getAppDeliveryID(), response.getZSDeliveryID());
+    }
+
+    private void sendToWork(MsgResponse response) {
+        runAsync(() -> repository.add(response))
+            .thenRunAsync(() -> handler.handle(response.getResponseID()));
+    }
+
+    private DeliveryNotificationACKType notificationAck(String appDeliveryID, String zsDeliveryID) {
+        return deliveryNotificationACKTypeBuilder()
+                .withAppDeliveryID(appDeliveryID)
+                .withZSDeliveryID(zsDeliveryID)
+                .withVersion(NameSpace.MSG_VERSION)
+                .build();
+    }
+
+
+}