Support REST for despatchAdvice (#55)

Author: carlosthe19916

core/pom.xml

@@ -71,6 +71,10 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-bean</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-log</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.apache.camel</groupId>
@@ -80,6 +84,14 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-cxf-soap</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-http</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jackson</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.apache.camel</groupId>

core/src/main/java/io/github/project/openubl/xsender/Constants.java

@@ -22,4 +22,5 @@ public class Constants {
     public static final String XSENDER_BILL_CONSULT_SERVICE_URI = "direct:xsender-billConsultService";
     public static final String XSENDER_BILL_VALID_SERVICE_URI = "direct:xsender-billValidService";
 
+    public static final String XSENDER_CREDENTIALS_API_URI = "direct:xsender-credentialsApi";
 }

core/src/main/java/io/github/project/openubl/xsender/camel/routes/CxfRouteBuilder.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2019 Project OpenUBL, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License - 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.project.openubl.xsender.camel.routes;
+
+import io.github.project.openubl.xsender.models.Metadata;
+import io.github.project.openubl.xsender.models.Status;
+import io.github.project.openubl.xsender.models.SunatResponse;
+import io.github.project.openubl.xsender.models.rest.ResponseDocumentErrorDto;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.http.base.HttpOperationFailedException;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class RestSunatErrorResponseProcessor implements Processor {
+
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        HttpOperationFailedException httpException = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, HttpOperationFailedException.class);
+        ResponseDocumentErrorDto responseDocumentErrorDto = exchange.getIn().getBody(ResponseDocumentErrorDto.class);
+
+        int errorCodeInt = Integer.parseInt(responseDocumentErrorDto.getCod());
+        List<String> notes = responseDocumentErrorDto.getErrors().stream()
+                .map(error -> error.getCod() + " - " + error.getMsg())
+                .collect(Collectors.toList());
+
+        Metadata metadata = Metadata.builder()
+                .notes(notes)
+                .responseCode(Integer.parseInt(responseDocumentErrorDto.getCod()))
+                .description(responseDocumentErrorDto.getMsg())
+                .build();
+
+        SunatResponse sunatResponse = SunatResponse.builder()
+                .status(Status.fromCode(errorCodeInt))
+                .metadata(metadata)
+                .build();
+        exchange.getIn().setBody(sunatResponse);
+    }
+
+}

core/src/main/java/io/github/project/openubl/xsender/camel/routes/RestSunatErrorResponseProcessor.java

@@ -0,0 +1,84 @@
+/*
+ * Copyright 2019 Project OpenUBL, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License - 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.project.openubl.xsender.camel.routes;
+
+import io.github.project.openubl.xsender.models.Metadata;
+import io.github.project.openubl.xsender.models.Status;
+import io.github.project.openubl.xsender.models.Sunat;
+import io.github.project.openubl.xsender.models.SunatResponse;
+import io.github.project.openubl.xsender.models.rest.ResponseDocumentSuccessDto;
+import io.github.project.openubl.xsender.utils.CdrReader;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.commons.codec.binary.Hex;
+
+import java.util.Base64;
+import java.util.Collections;
+import java.util.Optional;
+
+public class RestSunatResponseProcessor implements Processor {
+
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        ResponseDocumentSuccessDto responseDto = exchange.getIn().getBody(ResponseDocumentSuccessDto.class);
+        if (responseDto != null) {
+            SunatResponse sunatResponse = null;
+
+            if (responseDto.getNumTicket() != null) {
+                sunatResponse = SunatResponse.builder()
+                        .sunat(Sunat.builder()
+                                .ticket(responseDto.getNumTicket())
+                                .build()
+                        )
+                        .build();
+            } else if (responseDto.getArcCdr() != null) {
+                String cdrBase64Hex = responseDto.getArcCdr();
+                byte[] bytes = Hex.decodeHex(cdrBase64Hex);
+                byte[] cdrBytes = Base64.getDecoder().decode(bytes);
+                CdrReader cdrReader = new CdrReader(cdrBytes);
+
+                SunatResponse.builder()
+                        .status(cdrReader.getStatus())
+                        .metadata(cdrReader.getMetadata())
+                        .sunat(Sunat.builder()
+                                .cdr(cdrBytes)
+                                .build()
+                        );
+            } else if (responseDto.getCodRespuesta() != null) {
+                int statusCode = Integer.parseInt(responseDto.getCodRespuesta());
+
+                Optional<String> responseErrorCode = responseDto.getError() != null ? Optional.ofNullable(responseDto.getError().getNumError()) : Optional.empty();
+                Optional<String> responseErrorDescription = responseDto.getError() != null ? Optional.ofNullable(responseDto.getError().getDesError()) : Optional.empty();
+
+                Metadata metadata = Metadata.builder()
+                        .responseCode(responseErrorCode.map(Integer::parseInt).orElse(statusCode))
+                        .description(responseErrorDescription.orElseGet(null))
+                        .notes(Collections.emptyList())
+                        .build();
+
+                sunatResponse = SunatResponse.builder()
+                        .status(Status.fromCode(statusCode))
+                        .metadata(metadata)
+                        .sunat(null)
+                        .build();
+            }
+
+            exchange.getIn().setBody(sunatResponse);
+        }
+    }
+
+}

core/src/main/java/io/github/project/openubl/xsender/camel/routes/RestSunatResponseProcessor.java

@@ -28,7 +28,7 @@
 import java.util.Collections;
 import java.util.regex.Pattern;
 
-public class SunatErrorResponseProcessor implements Processor {
+public class SoapSunatErrorResponseProcessor implements Processor {
     private static Pattern pattern = Pattern.compile("-?\\d+(\\.\\d+)?");
 
     public boolean isNumeric(String strNum) {

core/src/main/java/io/github/project/openubl/xsender/camel/routes/SunatErrorResponseProcessor.java renamed to core/src/main/java/io/github/project/openubl/xsender/camel/routes/SoapSunatErrorResponseProcessor.java

@@ -29,11 +29,11 @@
 import java.util.Collections;
 import java.util.Optional;
 
-public class SunatResponseProcessor implements Processor {
+public class SoapSunatResponseProcessor implements Processor {
 
     @Override
     public void process(Exchange exchange) throws Exception {
-        MessageContentsList messageContentsList = (MessageContentsList) exchange.getIn().getBody();
+        MessageContentsList messageContentsList = exchange.getIn().getBody(MessageContentsList.class);
         if (messageContentsList != null && !messageContentsList.isEmpty()) {
             Object messageContent = messageContentsList.get(0);
 

core/src/main/java/io/github/project/openubl/xsender/camel/routes/SunatResponseProcessor.java renamed to core/src/main/java/io/github/project/openubl/xsender/camel/routes/SoapSunatResponseProcessor.java

@@ -0,0 +1,142 @@
+/*
+ * Copyright 2019 Project OpenUBL, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License - 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.project.openubl.xsender.camel.routes;
+
+import io.github.project.openubl.xsender.Constants;
+import io.github.project.openubl.xsender.models.rest.ResponseAccessTokenSuccessDto;
+import io.github.project.openubl.xsender.models.rest.ResponseDocumentErrorDto;
+import io.github.project.openubl.xsender.models.rest.ResponseDocumentSuccessDto;
+import org.apache.camel.Exchange;
+import org.apache.camel.LoggingLevel;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.cxf.common.message.CxfConstants;
+import org.apache.camel.component.http.HttpConstants;
+import org.apache.camel.component.http.HttpMethods;
+import org.apache.camel.http.base.HttpOperationFailedException;
+import org.apache.camel.model.dataformat.JsonLibrary;
+import org.apache.camel.util.URISupport;
+import org.apache.cxf.binding.soap.SoapFault;
+
+import java.net.URISyntaxException;
+import java.time.ZonedDateTime;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+public class SunatRouteBuilder extends RouteBuilder {
+
+    @Override
+    public void configure() {
+        from(Constants.XSENDER_BILL_SERVICE_URI)
+                .id("xsender-billService")
+                .choice()
+                    // SOAP
+                    .when(header(CxfConstants.OPERATION_NAME).isNotNull())
+                        .to("cxf://bean:cxfBillServiceEndpoint?dataFormat=POJO")
+                        .process(new SoapSunatResponseProcessor())
+                    .endChoice()
+                    // REST
+                    .when(header(HttpConstants.HTTP_METHOD).isNotNull())
+                        .marshal().json(JsonLibrary.Jackson)
+                        .to("https://api-cpe.sunat.gob.pe")
+                        .convertBodyTo(ResponseDocumentSuccessDto.class)
+                        .process(new RestSunatResponseProcessor())
+                    .endChoice()
+                    // Otherwise
+                    .otherwise()
+                        .throwException(new RuntimeException("Not supported protocol identified"))
+                    .endChoice()
+                .end()
+
+                // SOAP Exception
+                .onException(SoapFault.class)
+                    .handled(true)
+                    .process(new SoapSunatErrorResponseProcessor())
+                .end()
+                // REST exception
+                .onException(HttpOperationFailedException.class)
+                    .handled(exchange -> {
+                        HttpOperationFailedException httpException = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, HttpOperationFailedException.class);
+                        String contentType = httpException.getResponseHeaders().getOrDefault("Content-Type", "");
+
+                        exchange.getIn().setHeader("HttpResponseHeader_ContentType", contentType);
+                        return Objects.equals(contentType, "application/json");
+                    })
+                    .choice()
+                        .when(header("HttpResponseHeader_ContentType").isEqualTo("application/json"))
+                            .convertBodyTo(ResponseDocumentErrorDto.class)
+                            .process(new RestSunatErrorResponseProcessor())
+                        .endChoice()
+                        .otherwise()
+                            .log(LoggingLevel.WARN, "Response from server is not JSON, something went wrong while connecting to the remote server")
+                        .endChoice()
+                    .end()
+                .end();
+
+        from(Constants.XSENDER_BILL_CONSULT_SERVICE_URI)
+                .id("xsender-billConsultService")
+                .to("cxf://bean:cxfBillConsultServiceEndpoint?dataFormat=POJO");
+
+        from(Constants.XSENDER_BILL_VALID_SERVICE_URI)
+                .id("xsender-billValidService")
+                .to("cxf://bean:cxfBillValidServiceEndpoint?dataFormat=POJO");
+
+        // Requires a List as body.
+        // Where the first element (List(0)) is the prev AccessTokenDto (NULL if there is no prev value)
+        // Second element of the list (List(1)) is the 'x-www-form-urlencoded' form as a Map object
+        from(Constants.XSENDER_CREDENTIALS_API_URI)
+                .id("xsender-credentialsApi")
+                .choice()
+                    // Refresh token
+                    .when(exchange -> {
+                        List<?> body = exchange.getIn().getBody(List.class);
+                        ResponseAccessTokenSuccessDto prevToken = (ResponseAccessTokenSuccessDto) body.get(0);
+
+                        ZonedDateTime prevTokenCreatedIn = prevToken.getCreated_in();
+                        ZonedDateTime expirationDate = prevTokenCreatedIn.plusSeconds(prevToken.getExpires_in())
+                                .plusSeconds(30); // adding seconds to give time to the next operation to perform
+
+                        return ZonedDateTime.now().compareTo(expirationDate) >= 0;
+                    })
+                        .setHeader(HttpConstants.HTTP_METHOD, constant(HttpMethods.POST))
+                        .setHeader(HttpConstants.CONTENT_TYPE, constant("application/x-www-form-urlencoded"))
+                        .setBody(exchange -> {
+                            List<?> body = exchange.getIn().getBody(List.class);
+                            Map<String, Object> map = (Map<String, Object>) body.get(1);
+                            try {
+                                return URISupport.createQueryString(map);
+                            } catch (URISyntaxException e) {
+                                throw new RuntimeException(e);
+                            }
+                        })
+                        .to("https://api-seguridad.sunat.gob.pe")
+                        .convertBodyTo(ResponseAccessTokenSuccessDto.class)
+                        .process(exchange -> {
+                            ResponseAccessTokenSuccessDto response = exchange.getIn().getBody(ResponseAccessTokenSuccessDto.class);
+                            response.setCreated_in(ZonedDateTime.now());
+                        })
+                    .endChoice()
+                    // Reuse previous token
+                    .otherwise()
+                        .setBody(exchange -> {
+                            List<?> body = exchange.getIn().getBody(List.class);
+                            return (ResponseAccessTokenSuccessDto) body.get(0);
+                        })
+                    .endChoice()
+                .end();
+    }
+}