Websocket version. Removed other Async solutions.

Signed-off-by: Dennis Labordus <[email protected]>

Author: Dennis Labordus

app/pom.xml

@@ -65,10 +65,6 @@ SPDX-License-Identifier: Apache-2.0
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-resteasy-jaxb</artifactId>
         </dependency>
-        <dependency>
-            <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-resteasy-mutiny</artifactId>
-        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-vertx</artifactId>

app/src/main/java/org/lfenergy/compas/scl/validator/rest/v1/AsyncEventBusHandler.java

@@ -0,0 +1,54 @@
+// SPDX-FileCopyrightText: 2022 Alliander N.V.
+//
+// SPDX-License-Identifier: Apache-2.0
+package org.lfenergy.compas.scl.validator.rest.v1;
+
+import io.quarkus.security.Authenticated;
+import io.vertx.mutiny.core.eventbus.EventBus;
+import org.lfenergy.compas.scl.extensions.model.SclFileType;
+import org.lfenergy.compas.scl.validator.rest.v1.event.AsyncWebsocketEventRequest;
+import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateRequest;
+import org.lfenergy.compas.scl.validator.rest.v1.websocket.AsyncWebsocketRequestDecoder;
+import org.lfenergy.compas.scl.validator.rest.v1.websocket.AsyncWebsocketResponseEncoder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+import javax.websocket.OnError;
+import javax.websocket.OnMessage;
+import javax.websocket.Session;
+import javax.websocket.server.PathParam;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+
+import static org.lfenergy.compas.scl.validator.rest.SclResourceConstants.TYPE_PATH_PARAM;
+
+@Authenticated
+@ApplicationScoped
+@ServerEndpoint(value = "/validate-ws/v1/{" + TYPE_PATH_PARAM + "}",
+        decoders = AsyncWebsocketRequestDecoder.class,
+        encoders = AsyncWebsocketResponseEncoder.class)
+public class AsyncWebsocketResource {
+    private static final Logger LOGGER = LoggerFactory.getLogger(AsyncWebsocketResource.class);
+
+    private final EventBus bus;
+
+    @Inject
+    public AsyncWebsocketResource(EventBus bus) {
+        this.bus = bus;
+    }
+
+    @OnError
+    public void onError(Session session, @PathParam(TYPE_PATH_PARAM) String type, Throwable throwable) throws IOException {
+        LOGGER.info("Error with session {} for type {}.", session.getId(), type, throwable);
+        session.close();
+    }
+
+    @OnMessage
+    public void validateSCL(Session session, SclValidateRequest request, @PathParam(TYPE_PATH_PARAM) String type) {
+        LOGGER.info("Message from session {} for type {}.", session.getId(), type);
+        bus.send("validate-ws", new AsyncWebsocketEventRequest(
+                session, SclFileType.valueOf(type), request.getSclData()));
+    }
+}

app/src/main/java/org/lfenergy/compas/scl/validator/rest/v1/AsyncEventBusResource.java

@@ -0,0 +1,32 @@
+// SPDX-FileCopyrightText: 2022 Alliander N.V.
+//
+// SPDX-License-Identifier: Apache-2.0
+package org.lfenergy.compas.scl.validator.rest.v1.event;
+
+import io.quarkus.vertx.ConsumeEvent;
+import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateResponse;
+import org.lfenergy.compas.scl.validator.service.SclValidatorService;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+import java.io.IOException;
+
+@ApplicationScoped
+public class AsyncWebsocketEventHandler {
+    private final SclValidatorService sclValidatorService;
+
+    @Inject
+    public AsyncWebsocketEventHandler(SclValidatorService sclValidatorService) {
+        this.sclValidatorService = sclValidatorService;
+    }
+
+    @ConsumeEvent(value = "validate-ws", blocking = true)
+    public void validateEvent(AsyncWebsocketEventRequest request) throws IOException {
+        var response = new SclValidateResponse();
+        response.setValidationErrorList(sclValidatorService.validate(request.getType(), request.getSclData()));
+
+        var session = request.getSession();
+        session.getAsyncRemote().sendObject(response);
+        session.close();
+    }
+}

app/src/main/java/org/lfenergy/compas/scl/validator/rest/v1/AsyncJaxrsResource.java

@@ -0,0 +1,32 @@
+// SPDX-FileCopyrightText: 2022 Alliander N.V.
+//
+// SPDX-License-Identifier: Apache-2.0
+package org.lfenergy.compas.scl.validator.rest.v1.event;
+
+import org.lfenergy.compas.scl.extensions.model.SclFileType;
+
+import javax.websocket.Session;
+
+public class AsyncWebsocketEventRequest {
+    private final Session session;
+    private final SclFileType type;
+    private final String sclData;
+
+    public AsyncWebsocketEventRequest(Session session, SclFileType type, String sclData) {
+        this.session = session;
+        this.type = type;
+        this.sclData = sclData;
+    }
+
+    public Session getSession() {
+        return session;
+    }
+
+    public SclFileType getType() {
+        return type;
+    }
+
+    public String getSclData() {
+        return sclData;
+    }
+}

app/src/main/java/org/lfenergy/compas/scl/validator/rest/v1/AsyncMutinyResource.java

@@ -0,0 +1,43 @@
+// SPDX-FileCopyrightText: 2022 Alliander N.V.
+//
+// SPDX-License-Identifier: Apache-2.0
+package org.lfenergy.compas.scl.validator.rest.v1.websocket;
+
+import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateRequest;
+
+import javax.websocket.Decoder;
+import javax.websocket.EndpointConfig;
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.Unmarshaller;
+import java.io.StringReader;
+
+public class AsyncWebsocketRequestDecoder implements Decoder.Text<SclValidateRequest> {
+    @Override
+    public SclValidateRequest decode(String message) {
+        SclValidateRequest request = null;
+        try {
+            JAXBContext jaxbContext = JAXBContext.newInstance(SclValidateRequest.class);
+            Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
+            StringReader reader = new StringReader(message);
+            request = (SclValidateRequest) unmarshaller.unmarshal(reader);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+        return request;
+    }
+
+    @Override
+    public boolean willDecode(String message) {
+        return (message != null);
+    }
+
+    @Override
+    public void init(EndpointConfig endpointConfig) {
+        // do nothing.
+    }
+
+    @Override
+    public void destroy() {
+        // do nothing.
+    }
+}