1 files changed, 104 insertions, 0 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/scheme/MzsService.java b/src/main/java/at/gv/egiz/moazs/scheme/MzsService.java
new file mode 100644
index 0000000..f245b93
--- /dev/null
+++ b/src/main/java/at/gv/egiz/moazs/scheme/MzsService.java
@@ -0,0 +1,104 @@
+package at.gv.egiz.moazs.scheme;
+
+import at.gv.egiz.moazs.pipeline.DeliveryPipeline;
+import at.gv.egiz.moazs.preprocess.DeliveryRequestAugmenter;
+import at.gv.egiz.moazs.repository.DeliveryRepository;
+import at.gv.zustellung.app2mzs.xsd.App2MzsPortType;
+import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType;
+import at.gv.zustellung.app2mzs.xsd.DeliveryResponseType;
+import at.gv.zustellung.msg.xsd.DeliveryRequestStatusType;
+import org.apache.cxf.annotations.SchemaValidation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.jws.WebParam;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+import static at.gv.egiz.moazs.MoaZSException.moaZSException;
+import static at.gv.egiz.moazs.MoaZSException.moaZSExceptionBuilder;
+import static at.gv.zustellung.app2mzs.xsd.PartialSuccessType.partialSuccessTypeBuilder;
+import static java.util.concurrent.CompletableFuture.supplyAsync;
+
+//todo : validate Schema in both directions.
+@Service
+@SchemaValidation(type = SchemaValidation.SchemaValidationType.IN)
+public class MzsService implements App2MzsPortType {
+
+    private static final Logger logger = LoggerFactory.getLogger(MzsService.class);
+
+    //TODO move timeout and namespaces to config
+    private static final int TIMEOUT_FOR_ANWSER = 10;
+
+    private final DeliveryRepository repository;
+    private final DeliveryPipeline pipeline;
+    private final MzsClient appClient;
+    private final DeliveryRequestAugmenter augmenter;
+    private final Msg2MzsConverter converter;
+
+    @Autowired
+    public MzsService(DeliveryRepository repository, DeliveryPipeline pipeline, MzsClient appClient,
+                      DeliveryRequestAugmenter augmenter, Msg2MzsConverter converter) {
+        this.repository = repository;
+        this.pipeline = pipeline;
+        this.appClient = appClient;
+        this.augmenter = augmenter;
+        this.converter = converter;
+    }
+
+    @Override
+    public DeliveryResponseType app2Mzs(
+            @WebParam(partName = "DeliveryRequest",
+                      name = "DeliveryRequest")
+                    DeliveryRequestType deliveryRequest) {
+
+        var appDeliveryID = deliveryRequest.getMetaData().getAppDeliveryID();
+
+        var future = supplyAsync(() -> augmenter.augment(deliveryRequest))
+                .thenApply(this::process)
+                .thenApply(status -> converter.convert(status, repository.getSignedDeliveryRequestStatus(appDeliveryID)));
+
+        try {
+            return future.get(TIMEOUT_FOR_ANWSER, TimeUnit.SECONDS);
+        } catch (TimeoutException e) {
+            logger.info("Answer Timed Out", e);
+
+            future.thenAccept(appClient::sendNotification);
+            return generatePartialSuccessResponse(appDeliveryID);
+
+        } catch (Exception e) {
+            throw moaZSExceptionBuilder("An error occurred while processing DeliveryRequest " +
+                    "with AppDeliveryID=%s.", appDeliveryID)
+                    .withCause(e)
+                    .build();
+        }
+
+    }
+
+    private DeliveryRequestStatusType process(DeliveryRequestType deliveryRequest) {
+
+        var appDeliveryID = deliveryRequest.getMetaData().getAppDeliveryID();
+        logger.info("Receive request with appDeliveryID = {}.", appDeliveryID);
+
+        repository.add(deliveryRequest);
+        pipeline.processRequest(appDeliveryID);
+
+        return repository.getDeliveryRequestStatus(appDeliveryID)
+                .orElseThrow(() -> moaZSException("Could not get a response for AppDeliveryID=%s.", appDeliveryID));
+
+    }
+
+    private DeliveryResponseType generatePartialSuccessResponse(String appDeliveryId) {
+
+        var partial = partialSuccessTypeBuilder()
+                .withAppDeliveryID(appDeliveryId)
+                .build();
+
+        return DeliveryResponseType.deliveryResponseTypeBuilder()
+                .withPartialSuccess(partial)
+                .build();
+    }
+
+}