src/main/java/com/banesco/common/application/helper/MessageHelper.java

@@ -40,14 +40,6 @@ public class MessageHelper {
         this.errorMappings = initializeErrorMappings();
     }
 
-    public Response handleSuccess(Object data, String statusCode) {
-        log.info(
-            "Respuesta exitosa controlada: {}",
-            statusCode
-        );
-        return buildResponse(data, statusCode);
-    }
-
     public Response handleException(HttpStatusCodeException exception) {
         log.error(
             "Error interno controlado: {} -> {}",
@@ -114,27 +106,8 @@ public class MessageHelper {
         );
 
         return Response.status(mapping.getHttpCode())
-            .entity(new ApiResponse<>(status))
+                .entity(new ApiResponse<>(status))
-            .build();
+                .build();
-    }
-
-    private Response buildResponse(Object data, String statusCode) {
-        ErrorMapping mapping = errorMappings.getOrDefault(
-            statusCode, errorMappings.getOrDefault(
-                statusCode, createDefaultMapping()
-            )
-        );
-        StatusResponse status = createError(mapping, null);
-
-        log.error(
-            "[Success] Message {} -> {}",
-            statusCode,
-            status.getMessage()
-        );
-
-        return Response.status(mapping.getHttpCode())
-            .entity(new ApiResponse<>(data, status))
-            .build();
     }
 
     private Map<String, ErrorMapping> initializeErrorMappings() {

src/main/java/com/banesco/common/application/helper/RequestValidatorHelper.java

@@ -24,6 +24,7 @@ public class RequestValidatorHelper {
     ) {
         required(request.getId(), "paymentStatusId");
         required(request.getChannelCode(), "channelCode");
+        required(request.getSignatureIdentifier(), "signatureIdentifier");
         required(request.getCustomerReferenceFintechId(), "customerReferenceFintechId");
         required(request.getAppId(), "appId");
     }

src/main/java/com/banesco/common/application/service/HttpClientService.java

@@ -17,8 +17,6 @@ import lombok.extern.slf4j.Slf4j;
 
 import java.lang.reflect.ParameterizedType;
 import java.lang.reflect.Type;
-import java.net.URLEncoder;
-import java.nio.charset.StandardCharsets;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
@@ -36,61 +34,56 @@ public class HttpClientService implements HttpClientUseCase {
 
     @Override
     public <T> T execute(HttpRequest request) {
-        return executeRequest(request);
+        return executeInternal(request);
-    }
-
-    @Override
-    public <T, R> Either<T, R> executeEither(HttpRequest request) {
-        return executeEitherInternal(request, false);
-    }
-
-    @Override
-    public <T, R> Either<List<T>, R> executeEitherList(HttpRequest request) {
-        return executeEitherInternal(request, true);
     }
 
     @Override
     public <T> ApiResponse<T> executeApiResponse(HttpRequest request) {
-        return executeRequest(request);
+        return executeInternal(request);
     }
 
     @Override
-    public <T> ApiResponse<List<T>> executeApiResponseList(HttpRequest request) {
+    public <T> ApiResponse<List<T>> executeApiResponseList(
-        return executeRequest(request);
+        HttpRequest request
+    ) {
+        return executeInternal(request);
     }
 
     @Override
-    public <T> ApiPrivateResponse<Either<T, ApiPrivateError>> executeApiPrivateResponse(HttpRequest request) {
+    public <T> ApiPrivateResponse<Either<T, ApiPrivateError>> executeApiPrivateResponse(
-        return executeRequest(request);
+        HttpRequest request
+    ) {
+        return executeInternal(request);
     }
 
     @Override
-    public <T> ApiPrivateResponse<Either<List<T>, ApiPrivateError>> executeApiPrivateResponseList(HttpRequest request) {
+    public <T> ApiPrivateResponse<Either<List<T>, ApiPrivateError>> executeApiPrivateResponseList(
-        return executeRequest(request);
+        HttpRequest request
+    ) {
+        return executeInternal(request);
     }
 
-    private <T, R> Either<T, R> executeEitherInternal(HttpRequest request, boolean isList) {
+    private <T> T executeInternal(HttpRequest request) {
-        try (Client client = createClient(request.getConnectTimeout(), request.getReadTimeout())) {
+        String finalUrl = buildFinalUrl(request);
-            WebTarget target = client.target(buildFinalUrl(request));
-            Invocation.Builder builder = target.request(MediaType.APPLICATION_JSON);
 
-            if (request.getHeaders() != null) {
+        if (request.isLogRequestBody()) {
-                request.getHeaders().forEach(builder::header);
+            log.info("URL final: {}", finalUrl);
+
+            if (request.getHeaders() != null && !request.getHeaders().isEmpty()) {
+                log.info("Headers: {}", request.getHeaders());
             }
 
-            Response response = buildRequest(builder, request);
+            if (request.getQueryParams() != null && !request.getQueryParams().isEmpty()) {
-            return handleEitherResponse(request, response, isList);
+                log.info("Query params: {}", request.getQueryParams());
+            }
 
-        } catch (HttpStatusCodeException | HttpApiResponseException e) {
+            if (request.getBody() != null) {
-            throw e;
+                log.info("Body: {}", request.getBody());
-        } catch (Exception e) {
+            }
-            throw handleConnectionError(request, e);
         }
-    }
 
-    private <T> T executeRequest(HttpRequest request) {
         try (Client client = createClient(request.getConnectTimeout(), request.getReadTimeout())) {
-            WebTarget target = client.target(buildFinalUrl(request));
+            WebTarget target = client.target(finalUrl);
             Invocation.Builder builder = target.request(MediaType.APPLICATION_JSON);
 
             if (request.getHeaders() != null) {
@@ -102,122 +95,14 @@ public class HttpClientService implements HttpClientUseCase {
         } catch (HttpStatusCodeException | HttpApiResponseException e) {
             throw e;
         } catch (Exception e) {
-            throw handleConnectionError(request, e);
+            log.error("Error de conexion {}: {}", request.getMethod(), e.getMessage());
+            throw HttpStatusCodeException.serviceUnavailable(
+                "503",
+                "Error de conexion con el servicio externo: " + e.getMessage()
+            );
         }
     }
 
-    @SuppressWarnings("unchecked")
-    private <T, R> Either<T, R> handleEitherResponse(HttpRequest request, Response response, boolean isList) {
-        int statusCode = response.getStatus();
-
-        try (response) {
-            String responseBody = response.readEntity(String.class);
-            logResponse(request, statusCode, responseBody);
-
-            if (statusCode >= 200 && statusCode < 300) {
-                Object successData = isList
-                    ? parseSuccessListResponse(request, responseBody)
-                    : parseSuccessResponse(request, responseBody);
-                return Either.left((T) successData);
-            } else {
-                logErrorResponse(request, statusCode, responseBody);
-                R errorData = tryParseErrorResponse(request, responseBody);
-
-                if (errorData != null) {
-                    return Either.right(errorData);
-                }
-
-                throw mapHttpStatusToException(statusCode, responseBody);
-            }
-        } catch (HttpStatusCodeException | HttpApiResponseException e) {
-            throw e;
-        } catch (Exception e) {
-            throw handleProcessingError(request, e);
-        }
-    }
-
-    @SuppressWarnings("unchecked")
-    private <T> T parseSuccessResponse(HttpRequest request, String responseBody) throws JsonProcessingException {
-        Type successType = extractSuccessType(request);
-
-        if (successType != null) {
-            if (successType instanceof Class) {
-                return objectMapper.readValue(responseBody, (Class<T>) successType);
-            } else if (successType instanceof ParameterizedType) {
-                JavaType javaType = objectMapper.getTypeFactory().constructType(successType);
-                return objectMapper.readValue(responseBody, javaType);
-            }
-        }
-
-        if (request.getResponseType() != null && request.getResponseType() != Object.class) {
-            return objectMapper.readValue(responseBody, objectMapper.getTypeFactory().constructType(request.getResponseType()));
-        }
-
-        return (T) objectMapper.readValue(responseBody, Object.class);
-    }
-
-    @SuppressWarnings("unchecked")
-    private <T> List<T> parseSuccessListResponse(HttpRequest request, String responseBody) throws JsonProcessingException {
-        Type successType = extractSuccessType(request);
-
-        if (
-            successType instanceof ParameterizedType paramType &&
-            paramType.getRawType() == List.class &&
-            paramType.getActualTypeArguments().length > 0
-        ) {
-            Type elementType = paramType.getActualTypeArguments()[0];
-            if (elementType instanceof Class) {
-                JavaType javaType = objectMapper.getTypeFactory().constructCollectionType(
-                    List.class, (Class<T>) elementType
-                );
-                return objectMapper.readValue(responseBody, javaType);
-            }
-        }
-
-        return objectMapper.readValue(responseBody, List.class);
-    }
-
-    private Type extractSuccessType(HttpRequest request) {
-        if (
-            request.getComplexType() != null &&
-            request.getComplexType() instanceof ParameterizedType paramType &&
-            paramType.getRawType() == Either.class &&
-            paramType.getActualTypeArguments().length > 0
-        ) {
-            return paramType.getActualTypeArguments()[0];
-        }
-
-        if (request.getGenericType() != null) {
-            return request.getGenericType();
-        }
-
-        return request.getResponseType();
-    }
-
-    @SuppressWarnings("unchecked")
-    private <R> R tryParseErrorResponse(HttpRequest request, String responseBody) {
-        if (responseBody == null || responseBody.trim().isEmpty()) {
-            return null;
-        }
-
-        try {
-            if (request.getErrorType() != null) {
-                return (R) objectMapper.readValue(responseBody, request.getErrorType());
-            }
-
-            if (request.getComplexType() != null && request.getComplexType() instanceof ParameterizedType paramType) {
-                Type[] typeArgs = paramType.getActualTypeArguments();
-                if (typeArgs.length >= 2 && typeArgs[1] instanceof Class) {
-                    return objectMapper.readValue(responseBody, (Class<R>) typeArgs[1]);
-                }
-            }
-        } catch (Exception e) {
-            log.error("No se pudo parsear la respuesta como error type: {}", e.getMessage());
-        }
-
-        return null;
-    }
-
     private String buildFinalUrl(HttpRequest request) {
         String finalUrl = request.getUrl();
 
@@ -228,11 +113,7 @@ public class HttpClientService implements HttpClientUseCase {
             }
         }
 
-        String url = appendQueryParams(finalUrl, request.getQueryParams());
+        return appendQueryParams(finalUrl, request.getQueryParams());
-
-        log.info("Url Final: {}", url);
-
-        return url;
     }
 
     private String appendQueryParams(String url, Map<String, String> queryParams) {
@@ -251,24 +132,20 @@ public class HttpClientService implements HttpClientUseCase {
                 urlBuilder.append("&");
             }
 
-            String encodedKey = URLEncoder.encode(entry.getKey(), StandardCharsets.UTF_8);
+            urlBuilder.append(entry.getKey())
-            String encodedValue = entry.getValue() != null
+                .append("=")
-                ? URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8)
+                .append(entry.getValue() != null ? entry.getValue() : "");
-                : "";
-
-            urlBuilder.append(encodedKey).append("=").append(encodedValue);
         }
 
         return urlBuilder.toString();
     }
 
-    private Response buildRequest(Invocation.Builder builder, HttpRequest request) {
+    private Response buildRequest(
+        Invocation.Builder builder,
+        HttpRequest request
+    ) {
         log.info("Metodo HTTP: {}", request.getMethod().name());
 
-        if(request.getBody() != null) {
-            log.info("Peticion Cuerpo: {}", request.getBody());
-        }
-
         return switch (request.getMethod()) {
             case GET -> builder.get();
             case POST -> builder.post(Entity.entity(request.getBody(), MediaType.APPLICATION_JSON));
@@ -283,26 +160,43 @@ public class HttpClientService implements HttpClientUseCase {
 
     private Client createClient(int connectTimeout, int readTimeout) {
         return ClientBuilder.newBuilder()
-                .connectTimeout(connectTimeout, TimeUnit.MILLISECONDS)
+            .connectTimeout(connectTimeout, TimeUnit.MILLISECONDS)
-                .readTimeout(readTimeout, TimeUnit.MILLISECONDS)
+            .readTimeout(readTimeout, TimeUnit.MILLISECONDS)
-                .build();
+            .build();
     }
 
-    private <T> T handleResponse(HttpRequest request, Response response) {
+    private <T> T handleResponse(
+        HttpRequest request,
+        Response response
+    ) {
         int statusCode = response.getStatus();
+        log.info("Respuesta {} - Status: {}", request.getMethod(), statusCode);
 
         try (response) {
             String responseBody = response.readEntity(String.class);
-            logResponse(request, statusCode, responseBody);
+
+            if (request.isLogResponseBody()) {
+                log.info("Respuesta Cuerpo: {}", responseBody);
+            }
 
             if (statusCode >= 200 && statusCode < 300) {
                 if (request.getResponseType() == Void.class || request.getResponseType() == void.class) {
                     return null;
                 }
 
-                return responseResult(request, responseBody);
+                T result = responseResult(request, responseBody);
+
+                log.debug("Respuesta exitosa {} {}: {}", request.getMethod(), request.getUrl(), result);
+
+                return result;
             } else {
-                logErrorResponse(request, statusCode, responseBody);
+                log.error(
+                    "Error HTTP {} {} - Status: {} - Body: {}",
+                    request.getMethod(),
+                    request.getUrl(),
+                    statusCode,
+                    responseBody
+                );
 
                 if (isApiResponseFormat(responseBody)) {
                     ApiResponse<?> apiResponse = deserializeApiResponse(responseBody, request);
@@ -314,72 +208,53 @@ public class HttpClientService implements HttpClientUseCase {
         } catch (HttpStatusCodeException | HttpApiResponseException e) {
             throw e;
         } catch (Exception e) {
-            throw handleProcessingError(request, e);
+            log.error(
+                "Error procesando respuesta {} {}: {}",
+                request.getMethod(),
+                request.getUrl(),
+                e.getMessage()
+            );
+            throw HttpStatusCodeException.internalServer(
+                "500", "Error procesando respuesta del servicio externo: " + e.getMessage()
+            );
         }
     }
 
-    private void logResponse(HttpRequest request, int statusCode, String responseBody) {
+    private <T> T responseResult(
-        if (request.isLogResponseBody()) {
+        HttpRequest request,
-            log.info("Respuesta {} - Status: {}", request.getMethod(), statusCode);
+        String responseBody
-            log.info("Respuesta Cuerpo: {}", responseBody);
+    ) throws JsonProcessingException {
-        }
-    }
-
-    private void logErrorResponse(HttpRequest request, int statusCode, String responseBody) {
-        log.error(
-            "Error HTTP {} {} - Status: {} - Body: {}",
-            request.getMethod(),
-            request.getUrl(),
-            statusCode,
-            responseBody
-        );
-    }
-
-    private HttpStatusCodeException handleConnectionError(HttpRequest request, Exception e) {
-        log.error("Error de conexion {}: {}", request.getMethod(), e.getMessage());
-
-        return HttpStatusCodeException.serviceUnavailable(
-            "503", "Error de conexion con el servicio externo: " + e.getMessage()
-        );
-    }
-
-    private HttpStatusCodeException handleProcessingError(HttpRequest request, Exception e) {
-        log.error(
-            "Error procesando respuesta {} {}: {}",
-            request.getMethod(),
-            request.getUrl(),
-            e.getMessage()
-        );
-        return HttpStatusCodeException.internalServer(
-            "500", "Error procesando respuesta del servicio externo: " + e.getMessage()
-        );
-    }
-
-    private <T> T responseResult(HttpRequest request, String responseBody) throws JsonProcessingException {
         if (request.isApiPrivateResponse() && request.isEitherResponse()) {
             return handleApiPrivateResponseWithEither(request, responseBody);
         }
 
+        T result;
+
         if (request.getResponseType() == ApiResponse.class) {
-            return deserializeApiResponse(responseBody, request);
+            result = deserializeApiResponse(responseBody, request);
         } else if (request.getComplexType() != null) {
             JavaType javaType = objectMapper.getTypeFactory().constructParametricType(
                 request.getResponseType(), objectMapper.getTypeFactory().constructType(request.getComplexType())
             );
-            return objectMapper.readValue(responseBody, javaType);
+            result = objectMapper.readValue(responseBody, javaType);
         } else if (request.getGenericType() != null) {
             JavaType javaType = objectMapper.getTypeFactory().constructParametricType(
                 request.getResponseType(), objectMapper.getTypeFactory().constructType(request.getGenericType())
             );
-            return objectMapper.readValue(responseBody, javaType);
+            result = objectMapper.readValue(responseBody, javaType);
         } else {
-            return objectMapper.readValue(
+            result = objectMapper.readValue(
                 responseBody, objectMapper.getTypeFactory().constructType(request.getResponseType())
             );
         }
+
+        return result;
     }
 
-    private <T> T handleApiPrivateResponseWithEither(HttpRequest request, String responseBody) throws JsonProcessingException {
+    private <T> T handleApiPrivateResponseWithEither(
+        HttpRequest request,
+        String responseBody
+    ) throws JsonProcessingException {
         JsonNode rootNode = objectMapper.readTree(responseBody);
         String status = rootNode.has("estatus") ? rootNode.get("estatus").asText() : null;
         String message = rootNode.has("mensaje") ? rootNode.get("mensaje").asText() : null;
@@ -393,7 +268,12 @@ public class HttpClientService implements HttpClientUseCase {
     }
 
     @SuppressWarnings("unchecked")
-    private <T> T handleSuccessResponse(HttpRequest request, String status, String message, JsonNode detailNode) {
+    private <T> T handleSuccessResponse(
+        HttpRequest request,
+        String status,
+        String message,
+        JsonNode detailNode
+    ) {
         Object successData;
 
         if (request.isListResponse()) {
@@ -415,7 +295,10 @@ public class HttpClientService implements HttpClientUseCase {
         }
     }
 
-    private Object handleListSuccess(HttpRequest request, JsonNode detailNode) {
+    private Object handleListSuccess(
+        HttpRequest request,
+        JsonNode detailNode
+    ) {
         Class<?> elementType = getElementTypeFromRequest(request);
         JavaType listType = objectMapper.getTypeFactory().constructCollectionType(List.class, elementType);
 
@@ -426,7 +309,10 @@ public class HttpClientService implements HttpClientUseCase {
         return List.of();
     }
 
-    private Object handleObjectSuccess(HttpRequest request, JsonNode detailNode) {
+    private Object handleObjectSuccess(
+        HttpRequest request,
+        JsonNode detailNode
+    ) {
         Class<?> elementType = getElementTypeFromRequest(request);
 
         if (detailNode != null && !detailNode.isNull()) {
@@ -437,7 +323,11 @@ public class HttpClientService implements HttpClientUseCase {
     }
 
     @SuppressWarnings("unchecked")
-    private <T> T handleErrorResponse(String status, String message, JsonNode detailNode) {
+    private <T> T handleErrorResponse(
+        String status,
+        String message,
+        JsonNode detailNode
+    ) {
         ApiPrivateError error = buildApiPrivateError(detailNode, message);
         ApiPrivateResponse<Either<Object, ApiPrivateError>> response = new ApiPrivateResponse<>();
 
@@ -448,7 +338,10 @@ public class HttpClientService implements HttpClientUseCase {
         return (T) response;
     }
 
-    private ApiPrivateError buildApiPrivateError(JsonNode detailNode, String message) {
+    private ApiPrivateError buildApiPrivateError(
+        JsonNode detailNode,
+        String message
+    ) {
         if (detailNode != null && !detailNode.isNull()) {
             try {
                 return objectMapper.convertValue(detailNode, ApiPrivateError.class);
@@ -492,11 +385,15 @@ public class HttpClientService implements HttpClientUseCase {
     }
 
     @SuppressWarnings("unchecked")
-    private <T> T deserializeApiResponse(String responseBody, HttpRequest request) {
+    private <T> T deserializeApiResponse(
+        String responseBody,
+        HttpRequest request
+    ) {
         try {
             if (request.getGenericType() != null) {
                 JavaType javaType = objectMapper.getTypeFactory().constructParametricType(
-                    ApiResponse.class, objectMapper.getTypeFactory().constructType(request.getGenericType())
+                    ApiResponse.class,
+                    objectMapper.getTypeFactory().constructType(request.getGenericType())
                 );
                 return objectMapper.readValue(responseBody, javaType);
             } else {
@@ -530,7 +427,10 @@ public class HttpClientService implements HttpClientUseCase {
         }
     }
 
-    private HttpStatusCodeException mapHttpStatusToException(int statusCode, String errorBody) {
+    private HttpStatusCodeException mapHttpStatusToException(
+        int statusCode,
+        String errorBody
+    ) {
         String errorCode = "HTTP_" + statusCode;
         String defaultMessage = "Error en servicio externo: HTTP " + statusCode;
         String message = errorBody != null && !errorBody.isEmpty()

src/main/java/com/banesco/common/application/usecase/HttpClientUseCase.java

@@ -8,10 +8,6 @@ public interface HttpClientUseCase {
 
     <T> T execute(HttpRequest request);
 
-    <T, R> Either<T, R> executeEither(HttpRequest request);
-
-    <T, R> Either<List<T>, R> executeEitherList(HttpRequest request);
-
     <T> ApiResponse<T> executeApiResponse(HttpRequest request);
 
     <T> ApiResponse<List<T>> executeApiResponseList(HttpRequest request);

src/main/java/com/banesco/common/domain/exception/BusinessException.java

@@ -0,0 +1,11 @@
+package com.banesco.common.domain.exception;
+
+public class BusinessException extends BaseApiException {
+    public BusinessException(String errorCode, String message, String fieldPath) {
+        super(errorCode, message, fieldPath, "business");
+    }
+
+    public BusinessException(String errorCode, String fieldPath) {
+        super(errorCode, fieldPath, "business");
+    }
+}

src/main/java/com/banesco/common/domain/model/Device.java

@@ -1,17 +0,0 @@
-package com.banesco.common.domain.model;
-
-import io.quarkus.runtime.annotations.RegisterForReflection;
-import lombok.*;
-
-@Getter
-@ToString
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-@RegisterForReflection
-public class Device {
-    private String deviceType;
-    private String deviceDescription;
-    private String deviceIp;
-    private String deviceSessionReference;
-}

src/main/java/com/banesco/common/infrastructure/context/RequestContext.java

@@ -6,9 +6,7 @@ public class RequestContext {
 
     private RequestContext() {}
 
-    public static final String REQUEST_ID = "requestId";
+    private static final String REQUEST_ID = "requestId";
-    public static final String DEVICE = "device";
-    public static final String DEVICE_SESSION_REFERENCE = "deviceSessionReference";
 
     public static String getRequestId() {
         return MDC.get(REQUEST_ID);

src/main/java/com/banesco/common/infrastructure/filter/RequestIdFilter.java

@@ -6,88 +6,15 @@ import jakarta.ws.rs.container.ContainerRequestFilter;
 import jakarta.ws.rs.container.ContainerResponseContext;
 import jakarta.ws.rs.container.ContainerResponseFilter;
 import jakarta.ws.rs.ext.Provider;
-import lombok.extern.slf4j.Slf4j;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.nio.charset.StandardCharsets;
 import java.util.UUID;
 
-@Slf4j
 @Provider
 public class RequestIdFilter implements ContainerRequestFilter, ContainerResponseFilter {
 
     @Override
     public void filter(ContainerRequestContext requestContext) {
-        String requestId = requestContext.getHeaderString(RequestContext.DEVICE_SESSION_REFERENCE);
+        RequestContext.setRequestId(UUID.randomUUID().toString().substring(0, 13));
-
-        if (isEmpty(requestId)) {
-            requestId = requestContext.getUriInfo()
-                .getQueryParameters()
-                .getFirst(RequestContext.DEVICE_SESSION_REFERENCE);
-        }
-
-        if (isEmpty(requestId) && hasJsonBody(requestContext)) {
-            requestId = extractRequestIdFromBody(requestContext);
-        }
-
-        if (isEmpty(requestId)) {
-            requestId = UUID.randomUUID().toString().substring(0, 13);
-        }
-
-        RequestContext.setRequestId(requestId);
-    }
-
-    private boolean isEmpty(String value) {
-        return value == null || value.trim().isEmpty();
-    }
-
-    private boolean hasJsonBody(ContainerRequestContext context) {
-        try {
-            String method = context.getMethod();
-            String contentType = context.getHeaderString("Content-Type");
-
-            return ("POST".equals(method) || "PUT".equals(method))
-                && contentType != null
-                && contentType.contains("application/json");
-        } catch (Exception e) {
-            log.warn("La peticion no es un POST o PUT: {}", e.getMessage());
-            return false;
-        }
-    }
-
-    private String extractRequestIdFromBody(ContainerRequestContext context) {
-        try {
-            ByteArrayOutputStream buffer = new ByteArrayOutputStream();
-            context.getEntityStream().transferTo(buffer);
-            byte[] bodyBytes = buffer.toByteArray();
-
-            context.setEntityStream(new ByteArrayInputStream(bodyBytes));
-
-            String bodyString = new String(bodyBytes, StandardCharsets.UTF_8);
-            io.vertx.core.json.JsonObject jsonObject = new io.vertx.core.json.JsonObject(bodyString);
-
-            if (jsonObject.containsKey(RequestContext.DEVICE)) {
-                io.vertx.core.json.JsonObject device = jsonObject.getJsonObject(RequestContext.DEVICE);
-
-                if (device.containsKey(RequestContext.DEVICE_SESSION_REFERENCE)) {
-                    return device.getString(RequestContext.DEVICE_SESSION_REFERENCE);
-                }
-            }
-
-            if (jsonObject.containsKey(RequestContext.REQUEST_ID)) {
-                return jsonObject.getString(RequestContext.REQUEST_ID);
-            }
-
-            if (jsonObject.containsKey(RequestContext.DEVICE_SESSION_REFERENCE)) {
-                return jsonObject.getString(RequestContext.DEVICE_SESSION_REFERENCE);
-            }
-
-            return null;
-        } catch (Exception e) {
-            log.error("Error extrayendo el requestId del cuerpo de la peticion: {}", e.getMessage());
-            return null;
-        }
     }
 
     @Override
@@ -95,10 +22,6 @@ public class RequestIdFilter implements ContainerRequestFilter, ContainerRespons
         ContainerRequestContext requestContext,
         ContainerResponseContext responseContext
     ) {
-        try {
+        RequestContext.clear();
-            RequestContext.clear();
-        } catch (Exception e) {
-            log.error("Error limpiando el filtro: {}", e.getMessage());
-        }
     }
-}
+}

src/main/java/com/banesco/module/banking_product/domain/model/BankingProductType.java

@@ -7,5 +7,4 @@ public enum BankingProductType {
     BROKERED_PRODUCT,
     TERM_DEPOSIT_PRODUCT,
     MOBILE_PAYMENT,
-    NETUNO
 }

src/main/java/com/banesco/module/instruction/domain/model/Instruction.java

@@ -1,10 +1,14 @@
 package com.banesco.module.instruction.domain.model;
 
+import com.banesco.common.domain.exception.HttpStatusCodeException;
 import com.banesco.common.domain.model.Identifier;
 import com.fasterxml.jackson.annotation.JsonInclude;
 import io.quarkus.runtime.annotations.RegisterForReflection;
 import lombok.*;
 
+import java.util.Arrays;
+import java.util.Objects;
+
 @Getter
 @ToString
 @Builder
@@ -15,12 +19,21 @@ import lombok.*;
 public class Instruction {
     private InstructionIdentification instructionIdentifier;     // Request JSON: "id"
     private String instructionDescription;                       // Request JSON: "signature"
-    private String instructionPurposeType;                       // Request JSON: "channelOrigin" (BOLE)
+    private InstructionPurposeType instructionPurposeType;       // Request JSON: "channelOrigin" (BOLE)
 
     public static Instruction fromResource(
         String paymentStatusId,
-        String channelCode
+        String channelCode,
+        String signatureIdentifier
     ) {
+        boolean isChannelCodeValid = (Arrays.stream(
+            InstructionPurposeType.values()
+        ).anyMatch(type -> Objects.equals(type.name(), channelCode)));
+
+        if(!isChannelCodeValid) {
+            throw HttpStatusCodeException.badRequest("VDE02", "channelCode");
+        }
+
         return Instruction.builder()
                 .instructionIdentifier(
                     InstructionIdentification.builder()
@@ -32,7 +45,8 @@ public class Instruction {
                         .identificationType(InstructionIdentificationType.INSTRUCTION_NUMBER)
                         .build()
                 )
-                .instructionPurposeType(channelCode)
+                .instructionPurposeType(InstructionPurposeType.valueOf(channelCode))
+                .instructionDescription(signatureIdentifier)
                 .build();
     }
 }

src/main/java/com/banesco/module/instruction/domain/model/InstructionPurposeType.java

@@ -0,0 +1,6 @@
+package com.banesco.module.instruction.domain.model;
+
+public enum InstructionPurposeType {
+    BOLE,
+    BOL,
+}

src/main/java/com/banesco/module/service_issue_payment_status/application/service/ServiceIssuePaymentStatusService.java

@@ -3,16 +3,17 @@ package com.banesco.module.service_issue_payment_status.application.service;
 import com.banesco.common.application.helper.MessageHelper;
 import com.banesco.common.application.helper.RequestValidatorHelper;
 import com.banesco.common.domain.exception.HttpStatusCodeException;
-import com.banesco.common.domain.model.ApiResponse;
+import com.banesco.common.domain.model.*;
 import com.banesco.module.service_issue_payment_status.application.usecase.BusinessUseCase;
 import com.banesco.module.service_issue_payment_status.application.usecase.ServiceIssuePaymentStatusUseCase;
 import com.banesco.module.service_issue_payment_status.domain.dto.request.ServiceIssuePaymentStatusRequest;
 import com.banesco.module.service_issue_payment_status.domain.dto.response.ServiceIssuePaymentStatusResponse;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
-import jakarta.ws.rs.core.Response;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.Objects;
+
 @Slf4j
 @ApplicationScoped
 public class ServiceIssuePaymentStatusService implements ServiceIssuePaymentStatusUseCase {
@@ -33,31 +34,33 @@ public class ServiceIssuePaymentStatusService implements ServiceIssuePaymentStat
     }
 
     @Override
-    public Response execute(
+    public ApiResponse<ServiceIssuePaymentStatusResponse> execute(
         ServiceIssuePaymentStatusRequest request
     ) {
         log.info("Iniciando ejecucion para el transaccion: {}", request.getId());
 
-        Response response;
+        validate(request);
 
         try {
-            validate(request);
+            ApiResponse<ServiceIssuePaymentStatusResponse> response = business(request);
 
-            ApiResponse<ServiceIssuePaymentStatusResponse> apiResponse = business(request);
+            if (
+                !Objects.isNull(response.getData()) &&
+                messageHelper.isSuccessStatusCode(response.getStatusResponse())
+            ) {
+                return new ApiResponse<>(response.getData(), messageHelper.createStatusResponse(
+                    response.getStatusResponse().getStatusCode()
+                ));
+            }
 
-            response = messageHelper.handleSuccess(
+            throw HttpStatusCodeException.serviceUnavailable("503");
-                apiResponse.getData(),
-                apiResponse.getStatusResponse().getStatusCode()
-            );
         } catch (HttpStatusCodeException e) {
             log.error("Excepcion HTTP del api de negocio: {} - {}", e.getStatusCode(), e.getErrorCode());
-            response = messageHelper.handleException(e);
+            throw e;
         } catch (Exception e) {
             log.error("Excepcion generica del api de negocio: {}", e.getMessage());
-            response = messageHelper.handleGenericException(e);
+            throw e;
         }
-
-        return response;
     }
 
     private void validate(

src/main/java/com/banesco/module/service_issue_payment_status/application/usecase/ServiceIssuePaymentStatusUseCase.java

@@ -1,10 +1,11 @@
 package com.banesco.module.service_issue_payment_status.application.usecase;
 
+import com.banesco.common.domain.model.ApiResponse;
 import com.banesco.module.service_issue_payment_status.domain.dto.request.ServiceIssuePaymentStatusRequest;
-import jakarta.ws.rs.core.Response;
+import com.banesco.module.service_issue_payment_status.domain.dto.response.ServiceIssuePaymentStatusResponse;
 
 public interface ServiceIssuePaymentStatusUseCase {
-    Response execute(
+    ApiResponse<ServiceIssuePaymentStatusResponse> execute(
         ServiceIssuePaymentStatusRequest request
     );
 }

src/main/java/com/banesco/module/service_issue_payment_status/domain/dto/request/ServiceIssuePaymentStatusRequest.java

@@ -1,10 +1,6 @@
 package com.banesco.module.service_issue_payment_status.domain.dto.request;
 
-import com.banesco.common.domain.model.Device;
-import com.banesco.common.infrastructure.context.RequestContext;
 import com.banesco.module.instruction.domain.model.Instruction;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import io.netty.util.internal.StringUtil;
 import io.quarkus.runtime.annotations.RegisterForReflection;
 import lombok.*;
 
@@ -26,43 +22,23 @@ public class ServiceIssuePaymentStatusRequest {
     private String appId;
     @NonNull
     private Instruction procedureRequest;
-    @NonNull
-    private Device device;
 
-    @JsonIgnore
     public String getId() {
-        return procedureRequest
+        return getProcedureRequest().getInstructionIdentifier().getIdentification().getIdentifierValue();
-            .getInstructionIdentifier()
-            .getIdentification()
-            .getIdentifierValue();
     }
 
-    @JsonIgnore
     public String getChannelCode() {
-        return procedureRequest
+        return getProcedureRequest().getInstructionPurposeType().name();
-            .getInstructionPurposeType();
     }
 
-    @JsonIgnore
+    public String getSignatureIdentifier() {
-    public Map<String, String> toParams() {
+        return getProcedureRequest().getInstructionDescription();
-        return Map.ofEntries(
-            entry("paymentStatusId", Objects.toString(getId(), "")),
-            entry("channelCode", Objects.toString(getChannelCode(), ""))
-        );
     }
 
-    @JsonIgnore
     public Map<String, String> toQueryString() {
         return Map.ofEntries(
             entry("appId", Objects.toString(getAppId(), "")),
-            entry("customerReferenceFintechId", Objects.toString(getCustomerReferenceFintechId(), "")),
+            entry("customerReferenceFintechId", Objects.toString(getCustomerReferenceFintechId(), ""))
-            entry("deviceType", Objects.toString(getDevice().getDeviceType(), "")),
-            entry("deviceDescription", Objects.toString(getDevice().getDeviceDescription(), "")),
-            entry("deviceIp", Objects.toString(getDevice().getDeviceIp(), "")),
-            entry("deviceSessionReference", (!StringUtil.isNullOrEmpty(getDevice().getDeviceSessionReference()))
-                ? getDevice().getDeviceSessionReference()
-                : RequestContext.getRequestId()
-            )
         );
     }
 }

src/main/java/com/banesco/module/service_issue_payment_status/infrastructure/client/BusServiceIssuePaymentStatusClient.java

@@ -13,6 +13,8 @@ import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.Map;
+
 @Slf4j
 @ApplicationScoped
 public class BusServiceIssuePaymentStatusClient implements BusinessUseCase {
@@ -35,20 +37,27 @@ public class BusServiceIssuePaymentStatusClient implements BusinessUseCase {
         Class<T> responseType
     ) {
         String paymentStatusId = params.getId();
-        HttpRequest request = HttpRequest.forApiResponse(
+        String channelCode = params.getChannelCode();
-                businessConfig.getUrl(),
+        String signatureIdentifier = params.getSignatureIdentifier();
-                HttpRequest.HttpMethod.GET,
+        HttpRequest request = HttpRequest.builder()
-                responseType
+            .url(businessConfig.getUrl())
-            )
+            .method(HttpRequest.HttpMethod.GET)
-            .withPathParams(params.toParams())
+            .pathParams(Map.of(
-            .withQueryParams(params.toQueryString())
+                "paymentStatusId", paymentStatusId,
-            .withTimeout(
+                "channelCode", channelCode,
-                businessConfig.getTimeout().getConnect(),
+                "signatureIdentifier", signatureIdentifier
-                businessConfig.getTimeout().getResponse()
+            ))
-            );
+            .queryParams(params.toQueryString())
+            .responseType(ApiResponse.class)
+            .genericType(responseType)
+            .connectTimeout(businessConfig.getTimeout().getConnect())
+            .readTimeout(businessConfig.getTimeout().getResponse())
+            .build();
+
+        log.debug("Request configurado: {}", request);
 
         try {
-            ApiResponse<T> response = httpClientUseCase.executeApiResponse(request);
+            ApiResponse<T> response = httpClientUseCase.execute(request);
 
             log.info(
                 "Solicitud del api de negocio exitoso: {}",

src/main/java/com/banesco/module/service_issue_payment_status/infrastructure/resource/ServiceIssuePaymentStatusResource.java

@@ -1,8 +1,8 @@
 package com.banesco.module.service_issue_payment_status.infrastructure.resource;
 
 import com.banesco.common.application.helper.MessageHelper;
+import com.banesco.common.domain.exception.HttpStatusCodeException;
 import com.banesco.common.domain.model.ApiResponse;
-import com.banesco.common.domain.model.Device;
 import com.banesco.common.domain.model.StatusResponse;
 import com.banesco.module.instruction.domain.model.Instruction;
 import com.banesco.module.service_issue_payment_status.application.usecase.ServiceIssuePaymentStatusUseCase;
@@ -31,17 +31,19 @@ import java.util.Objects;
 public class ServiceIssuePaymentStatusResource {
 
     private final ServiceIssuePaymentStatusUseCase useCase;
+    private final MessageHelper messageHelper;
 
     @Inject
     public ServiceIssuePaymentStatusResource(
         MessageHelper messageHelper,
         ServiceIssuePaymentStatusUseCase useCase
     ) {
+        this.messageHelper = messageHelper;
         this.useCase = useCase;
     }
 
     @GET
-    @Path("/retrieve/{paymentStatusId}/{channelCode}")
+    @Path("/retrieve/{paymentStatusId}/{channelCode}/{signatureIdentifier}")
     @Operation(
         summary = "Recuperar informacion de la transaccion",
         description = "Consulta de una trasanccion de pago por id de archivo"
@@ -318,40 +320,26 @@ public class ServiceIssuePaymentStatusResource {
         @Parameter(description = "Codigo del canal (BOL, BOLE)", required = true, example = "BOLE")
         String channelCode,
 
-        @QueryParam("deviceType")
+        @PathParam("signatureIdentifier")
-        @Parameter(description = "Tipo de dispositivo", example = "Mobile")
+        @Parameter(description = "Firma del archivo", required = true, example = "add7c6375b8659a798a998258fb049b98119ea97d8116b95e1ee00cc9ffafa84")
-        String deviceType,
+        String signatureIdentifier
-
-        @QueryParam("deviceDescription")
-        @Parameter(description = "Descripcion del dispositivo", example = "Xiaomi Note 11 PRO")
-        String deviceDescription,
-
-        @QueryParam("deviceIp")
-        @Parameter(description = "Direccion IP del dispositivo", example = "127.0.0.1")
-        String deviceIp,
-
-        @QueryParam("deviceSessionReference")
-        @Parameter(description = "Referencia de la peticion del dispositivo", example = "12345678901304")
-        String deviceSessionReference
     ) {
         log.info("Iniciando consulta para instruccion de archivo id: {}", paymentStatusId);
 
-        return useCase.execute(
+        try {
-            ServiceIssuePaymentStatusRequest.builder()
+            return Response.ok(useCase.execute(
-                .customerReferenceFintechId(Objects.toString(customerReferenceFintechId, ""))
+                ServiceIssuePaymentStatusRequest.builder()
-                .appId(Objects.toString(appId, ""))
+                    .customerReferenceFintechId(Objects.toString(customerReferenceFintechId, ""))
-                .procedureRequest(Instruction.fromResource(
+                    .appId(Objects.toString(appId, ""))
-                    paymentStatusId, channelCode
+                    .procedureRequest(Instruction.fromResource(
-                ))
+                        paymentStatusId, channelCode, signatureIdentifier
-                .device(
+                    ))
-                    Device.builder()
+                    .build()
-                        .deviceType(deviceType)
+            )).build();
-                        .deviceDescription(deviceDescription)
+        } catch (HttpStatusCodeException e) {
-                        .deviceIp(deviceIp)
+            return messageHelper.handleException(e);
-                        .deviceSessionReference(deviceSessionReference)
+        } catch (Exception e) {
-                        .build()
+            return messageHelper.handleGenericException(e);
-                )
+        }
-                .build()
-        );
     }
 }

src/main/java/com/banesco/module/transaction/domain/model/TransactionStatusType.java

@@ -7,7 +7,6 @@ public enum TransactionStatusType {
     EXECUTED,
     CANCELLED,
     CONFIRMED,
-    APPROVED,
     SUSPENDED,
     PENDING,
     COMPLETED,
@@ -16,9 +15,4 @@ public enum TransactionStatusType {
     REJECTED,
     EXPIRED,
     SENT,
-    RECEIVED,
-    ACTIVE,
-    READ,
-    PROGRAMED,
-    ATYPICAL_TRANSACTION,
 }

src/main/resources/application-dev.yml

@@ -17,6 +17,6 @@ api:
   rec-service-issue-payment-status:
     messages:
       key: 'rec-service-issue-payment-status'
-      content: '[{"backendCode":"200","httpCode":200,"statusCode":"200","description":"Operacion exitosa"},{"backendCode":"R404","httpCode":404,"statusCode":"404","description":"Datos de validacion no encontrado."},{"backendCode":"503","httpCode":503,"statusCode":"503","description":"Uso interno"},{"backendCode":"422","httpCode":422,"statusCode":"422","description":"Uso interno"},{"backendCode":"500","httpCode":500,"statusCode":"500","description":"Uso interno"},{"backendCode":"100","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"OSB-382505","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"OSB-380002","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"ERROR","httpCode":400,"statusCode":"400","description":"Uso interno"},{"backendCode":"400","httpCode":400,"statusCode":"400","description":"Uso interno"},{"backendCode":"401","httpCode":401,"statusCode":"401","description":"Uso interno"},{"backendCode":"403","httpCode":403,"statusCode":"403","description":"Uso interno"},{"backendCode":"404","httpCode":404,"statusCode":"404","description":"Uso interno"},{"backendCode":"default","httpCode":409,"statusCode":"409","description":"Conflicto"},{"backendCode":"424","httpCode":424,"statusCode":"424","description":"Error de dependencia"},{"backendCode":"VDE01","httpCode":400,"statusCode":"VDE01","description":"VDE01 - Error en dato de entrada obligatorio: %s"},{"backendCode":"VDE02","httpCode":400,"statusCode":"VDE02","description":"VDE02 - Error en valor permitido para campo: %s"},{"backendCode":"VRN04","httpCode":"503","statusCode":"VRN04","description":"Servicio en horario de mantenimiento","status":"error"},{"backendCode":"VRN02","httpCode":"204","statusCode":"VRN02","description":"Cliente sin productos"}]'
+      content: '[{"backendCode":"200","httpCode":200,"statusCode":"200","description":"Operacion exitosa"},{"backendCode":"R404","httpCode":404,"statusCode":"404","description":"Datos de validacion no encontrado."},{"backendCode":"503","httpCode":503,"statusCode":"503","description":"Uso interno"},{"backendCode":"422","httpCode":422,"statusCode":"422","description":"Uso interno"},{"backendCode":"500","httpCode":500,"statusCode":"500","description":"Uso interno"},{"backendCode":"100","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"OSB-382505","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"OSB-380002","httpCode":503,"statusCode":"503","description":"VDR13 - OSB Disponible"},{"backendCode":"ERROR","httpCode":400,"statusCode":"400","description":"Uso interno"},{"backendCode":"400","httpCode":400,"statusCode":"400","description":"Uso interno"},{"backendCode":"401","httpCode":401,"statusCode":"401","description":"Uso interno"},{"backendCode":"403","httpCode":403,"statusCode":"403","description":"Uso interno"},{"backendCode":"404","httpCode":404,"statusCode":"404","description":"Uso interno"},{"backendCode":"default","httpCode":409,"statusCode":"409","description":"Conflicto"},{"backendCode":"424","httpCode":424,"statusCode":"424","description":"Error de dependencia"},{"backendCode":"VDE01","httpCode":400,"statusCode":"VDE01","description":"VDE01 - Error en dato de entrada obligatorio: %s"},{"backendCode":"VDE02","httpCode":400,"statusCode":"VDE02","description":"VDE02 - Error en valor permitido para campo: %s"},{"backendCode":"VRN04","httpCode":"503","statusCode":"VRN04","description":"Servicio en horario de mantenimiento","status":"error"},{"backendCode":"204","httpCode":"200","statusCode":"200","description":"Cliente sin productos","status":"ok"}]'
   rest-client:
-    bus-service-issue-payment-status: '{"url":"http://localhost:8082/service-issue-payment-status/retrieve/{paymentStatusId}/{channelCode}","timeout":{"connect":15000,"response":15000},"config":{}}'
+    bus-service-issue-payment-status: '{"url":"http://localhost:8082/service-issue-payment-status/retrieve/{paymentStatusId}/{channelCode}/{signatureIdentifier}","timeout":{"connect":15000,"response":15000},"config":{}}'