Merge pull request #146 from com-pas/develop

New release

Author: Dennis Labordus

app/pom.xml

@@ -38,7 +38,11 @@ SPDX-License-Identifier: Apache-2.0
 
         <dependency>
             <groupId>org.lfenergy.compas.core</groupId>
-            <artifactId>jaxrs-commons</artifactId>
+            <artifactId>rest-commons</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.lfenergy.compas.core</groupId>
+            <artifactId>websocket-commons</artifactId>
         </dependency>
 
         <dependency>

app/src/main/docker/Dockerfile.jvm

@@ -21,7 +21,7 @@
 # docker run -i --rm -p 8080:8080 -p 5005:5005 -e JAVA_ENABLE_DEBUG="true" quarkus/app-jvm
 #
 ###
-FROM registry.access.redhat.com/ubi8/ubi-minimal:8.6 
+FROM registry.access.redhat.com/ubi8/ubi-minimal:8.7 
 
 ARG JAVA_PACKAGE=java-17-openjdk-headless
 ARG RUN_JAVA_VERSION=1.3.8

app/src/main/docker/Dockerfile.native

@@ -14,7 +14,7 @@
 # docker run -i --rm -p 8080:8080 quarkus/app
 #
 ###
-FROM registry.access.redhat.com/ubi8/ubi-minimal:8.6
+FROM registry.access.redhat.com/ubi8/ubi-minimal:8.7
 WORKDIR /work/
 RUN chown 1001 /work \
     && chmod "g+rwX" /work \

app/src/main/java/org/lfenergy/compas/scl/validator/rest/exception/NsdocNotFoundExceptionHandler.java

@@ -3,7 +3,7 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.lfenergy.compas.scl.validator.rest.exception;
 
-import org.lfenergy.compas.core.jaxrs.model.ErrorResponse;
+import org.lfenergy.compas.core.commons.model.ErrorResponse;
 import org.lfenergy.compas.scl.validator.exception.NsdocFileNotFoundException;
 
 import javax.ws.rs.core.Response;

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

@@ -5,6 +5,7 @@
 
 import io.quarkus.security.Authenticated;
 import io.vertx.mutiny.core.eventbus.EventBus;
+import org.lfenergy.compas.core.websocket.ErrorResponseEncoder;
 import org.lfenergy.compas.scl.extensions.model.SclFileType;
 import org.lfenergy.compas.scl.validator.rest.v1.event.SclValidatorEventRequest;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateRequest;
@@ -21,13 +22,14 @@
 import javax.websocket.server.PathParam;
 import javax.websocket.server.ServerEndpoint;
 
+import static org.lfenergy.compas.core.websocket.WebsocketSupport.handleException;
 import static org.lfenergy.compas.scl.validator.rest.SclResourceConstants.TYPE_PATH_PARAM;
 
 @Authenticated
 @ApplicationScoped
 @ServerEndpoint(value = "/validate-ws/v1/{" + TYPE_PATH_PARAM + "}",
         decoders = {SclValidateRequestDecoder.class, SclValidateResponseDecoder.class},
-        encoders = {SclValidateRequestEncoder.class, SclValidateResponseEncoder.class})
+        encoders = {SclValidateRequestEncoder.class, SclValidateResponseEncoder.class, ErrorResponseEncoder.class})
 public class SclValidatorServerEndpoint {
     private static final Logger LOGGER = LoggerFactory.getLogger(SclValidatorServerEndpoint.class);
 
@@ -53,6 +55,7 @@ public void onMessage(Session session, SclValidateRequest request, @PathParam(TY
     @OnError
     public void onError(Session session, @PathParam(TYPE_PATH_PARAM) String type, Throwable throwable) {
         LOGGER.warn("Error with session {} for type {}.", session.getId(), type, throwable);
+        handleException(session, throwable);
     }
 
     @OnClose

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

@@ -4,6 +4,7 @@
 package org.lfenergy.compas.scl.validator.rest.v1.event;
 
 import io.quarkus.vertx.ConsumeEvent;
+import org.lfenergy.compas.core.websocket.WebsocketHandler;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateResponse;
 import org.lfenergy.compas.scl.validator.service.SclValidatorService;
 
@@ -24,10 +25,10 @@ public SclValidatorEventHandler(SclValidatorService sclValidatorService) {
 
     @ConsumeEvent(value = "validate-ws", blocking = true)
     public void validateWebsocketsEvent(SclValidatorEventRequest request) {
-        var response = new SclValidateResponse();
-        response.setValidationErrorList(sclValidatorService.validate(request.getType(), request.getSclData()));
-
-        var session = request.getSession();
-        session.getAsyncRemote().sendObject(response);
+        new WebsocketHandler<SclValidateResponse>().execute(request.getSession(), () -> {
+            var response = new SclValidateResponse();
+            response.setValidationErrorList(sclValidatorService.validate(request.getType(), request.getSclData()));
+            return response;
+        });
     }
 }

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

@@ -3,43 +3,18 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.lfenergy.compas.scl.validator.rest.v1.websocket;
 
-import org.lfenergy.compas.scl.validator.exception.SclValidatorException;
+import org.lfenergy.compas.core.websocket.AbstractDecoder;
+import org.lfenergy.compas.core.websocket.WebsocketSupport;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateRequest;
 
-import javax.websocket.Decoder;
-import javax.websocket.EndpointConfig;
-import javax.xml.bind.JAXBContext;
-import java.io.StringReader;
-
-import static org.lfenergy.compas.scl.validator.exception.SclValidatorErrorCode.WEBSOCKET_DECODER_ERROR_CODE;
-
-public class SclValidateRequestDecoder implements Decoder.Text<SclValidateRequest> {
-    @Override
-    public void init(EndpointConfig endpointConfig) {
-        // do nothing.
-    }
-
+public class SclValidateRequestDecoder extends AbstractDecoder<SclValidateRequest> {
     @Override
     public boolean willDecode(String message) {
         return (message != null);
     }
 
     @Override
     public SclValidateRequest decode(String message) {
-        try {
-            var jaxbContext = JAXBContext.newInstance(SclValidateRequest.class);
-            var unmarshaller = jaxbContext.createUnmarshaller();
-            var reader = new StringReader(message);
-            return (SclValidateRequest) unmarshaller.unmarshal(reader);
-        } catch (Exception exp) {
-            throw new SclValidatorException(WEBSOCKET_DECODER_ERROR_CODE,
-                    "Error unmarshalling SCL Validate Request from Websockets.",
-                    exp);
-        }
-    }
-
-    @Override
-    public void destroy() {
-        // do nothing.
+        return WebsocketSupport.decode(message, SclValidateRequest.class);
     }
 }

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

@@ -3,40 +3,13 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.lfenergy.compas.scl.validator.rest.v1.websocket;
 
-import org.lfenergy.compas.scl.validator.exception.SclValidatorException;
+import org.lfenergy.compas.core.websocket.AbstractEncoder;
+import org.lfenergy.compas.core.websocket.WebsocketSupport;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateRequest;
 
-import javax.websocket.Encoder;
-import javax.websocket.EndpointConfig;
-import javax.xml.bind.JAXBContext;
-import java.io.StringWriter;
-
-import static org.lfenergy.compas.scl.validator.exception.SclValidatorErrorCode.WEBSOCKET_ENCODER_ERROR_CODE;
-
-public class SclValidateRequestEncoder implements Encoder.Text<SclValidateRequest> {
-    @Override
-    public void init(EndpointConfig endpointConfig) {
-        // do nothing.
-    }
-
-    @Override
-    public String encode(SclValidateRequest request) {
-        try {
-            var jaxbContext = JAXBContext.newInstance(SclValidateRequest.class);
-            var marshaller = jaxbContext.createMarshaller();
-
-            var st = new StringWriter();
-            marshaller.marshal(request, st);
-            return st.toString();
-        } catch (Exception exp) {
-            throw new SclValidatorException(WEBSOCKET_ENCODER_ERROR_CODE,
-                    "Error marshalling SCL Validate Request from Websockets.",
-                    exp);
-        }
-    }
-
+public class SclValidateRequestEncoder extends AbstractEncoder<SclValidateRequest> {
     @Override
-    public void destroy() {
-        // do nothing.
+    public String encode(SclValidateRequest jaxbObject) {
+        return WebsocketSupport.encode(jaxbObject, SclValidateRequest.class);
     }
 }

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

@@ -3,43 +3,18 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.lfenergy.compas.scl.validator.rest.v1.websocket;
 
-import org.lfenergy.compas.scl.validator.exception.SclValidatorException;
+import org.lfenergy.compas.core.websocket.AbstractDecoder;
+import org.lfenergy.compas.core.websocket.WebsocketSupport;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateResponse;
 
-import javax.websocket.Decoder;
-import javax.websocket.EndpointConfig;
-import javax.xml.bind.JAXBContext;
-import java.io.StringReader;
-
-import static org.lfenergy.compas.scl.validator.exception.SclValidatorErrorCode.WEBSOCKET_DECODER_ERROR_CODE;
-
-public class SclValidateResponseDecoder implements Decoder.Text<SclValidateResponse> {
-    @Override
-    public void init(EndpointConfig endpointConfig) {
-        // do nothing.
-    }
-
+public class SclValidateResponseDecoder extends AbstractDecoder<SclValidateResponse> {
     @Override
     public boolean willDecode(String message) {
         return (message != null);
     }
 
     @Override
     public SclValidateResponse decode(String message) {
-        try {
-            var jaxbContext = JAXBContext.newInstance(SclValidateResponse.class);
-            var unmarshaller = jaxbContext.createUnmarshaller();
-            var reader = new StringReader(message);
-            return (SclValidateResponse) unmarshaller.unmarshal(reader);
-        } catch (Exception exp) {
-            throw new SclValidatorException(WEBSOCKET_DECODER_ERROR_CODE,
-                    "Error unmarshalling SCL Validate Response from Websockets.",
-                    exp);
-        }
-    }
-
-    @Override
-    public void destroy() {
-        // do nothing.
+        return WebsocketSupport.decode(message, SclValidateResponse.class);
     }
 }

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

@@ -3,40 +3,13 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.lfenergy.compas.scl.validator.rest.v1.websocket;
 
-import org.lfenergy.compas.scl.validator.exception.SclValidatorException;
+import org.lfenergy.compas.core.websocket.AbstractEncoder;
+import org.lfenergy.compas.core.websocket.WebsocketSupport;
 import org.lfenergy.compas.scl.validator.rest.v1.model.SclValidateResponse;
 
-import javax.websocket.Encoder;
-import javax.websocket.EndpointConfig;
-import javax.xml.bind.JAXBContext;
-import java.io.StringWriter;
-
-import static org.lfenergy.compas.scl.validator.exception.SclValidatorErrorCode.WEBSOCKET_ENCODER_ERROR_CODE;
-
-public class SclValidateResponseEncoder implements Encoder.Text<SclValidateResponse> {
-    @Override
-    public void init(EndpointConfig endpointConfig) {
-        // do nothing.
-    }
-
-    @Override
-    public String encode(SclValidateResponse response) {
-        try {
-            var jaxbContext = JAXBContext.newInstance(SclValidateResponse.class);
-            var marshaller = jaxbContext.createMarshaller();
-
-            var st = new StringWriter();
-            marshaller.marshal(response, st);
-            return st.toString();
-        } catch (Exception exp) {
-            throw new SclValidatorException(WEBSOCKET_ENCODER_ERROR_CODE,
-                    "Error marshalling SCL Validate Response from Websockets.",
-                    exp);
-        }
-    }
-
+public class SclValidateResponseEncoder extends AbstractEncoder<SclValidateResponse> {
     @Override
-    public void destroy() {
-        // do nothing.
+    public String encode(SclValidateResponse jaxbObject) {
+        return WebsocketSupport.encode(jaxbObject, SclValidateResponse.class);
     }
 }