diff --git a/pom.xml b/pom.xml index 7381f8b..dd59253 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ dom-docservice-file-audit-trace 1.0-native-quarkus-jdk17 dom-docservice-file-audit-trace - API Domain - Read payment statuses of the file by ID + API Domain - Create payment file audit trace 17 diff --git a/scripts/native/file/dom-docservice-file-audit-trace-1.0-native-quarkus-jdk17-runner b/scripts/native/file/dom-docservice-file-audit-trace-1.0-native-quarkus-jdk17-runner index 075c192..7b92e81 100644 Binary files a/scripts/native/file/dom-docservice-file-audit-trace-1.0-native-quarkus-jdk17-runner and b/scripts/native/file/dom-docservice-file-audit-trace-1.0-native-quarkus-jdk17-runner differ diff --git a/src/main/java/com/banesco/common/application/helper/SerializationHelper.java b/src/main/java/com/banesco/common/application/helper/SerializationHelper.java index 80cfa89..9beacb7 100644 --- a/src/main/java/com/banesco/common/application/helper/SerializationHelper.java +++ b/src/main/java/com/banesco/common/application/helper/SerializationHelper.java @@ -22,7 +22,7 @@ public class SerializationHelper { @Inject public SerializationHelper( - ObjectMapper objectMapper + ObjectMapper objectMapper ) { this.objectMapper = objectMapper; } @@ -156,4 +156,17 @@ public class SerializationHelper { return encodeSha256(finalString); } + + public String generateSignature( + Long id, + String channelOrigin + ) { + String channelBase64 = encodeStringToBase64(channelOrigin); + String finalString = id + channelBase64; + + log.info("1. Operation concatenando valores: {}", finalString); + log.info("2. Channel Origin codificado: {}", channelBase64); + + return encodeSha256(finalString); + } } diff --git a/src/main/java/com/banesco/common/application/service/HttpClientService.java b/src/main/java/com/banesco/common/application/service/HttpClientService.java index fb42a5c..416a6a2 100644 --- a/src/main/java/com/banesco/common/application/service/HttpClientService.java +++ b/src/main/java/com/banesco/common/application/service/HttpClientService.java @@ -36,56 +36,61 @@ public class HttpClientService implements HttpClientUseCase { @Override public T execute(HttpRequest request) { - return executeInternal(request); + return executeRequest(request); + } + + @Override + public Either executeEither(HttpRequest request) { + return executeEitherInternal(request, false); + } + + @Override + public Either, R> executeEitherList(HttpRequest request) { + return executeEitherInternal(request, true); } @Override public ApiResponse executeApiResponse(HttpRequest request) { - return executeInternal(request); + return executeRequest(request); } @Override - public ApiResponse> executeApiResponseList( - HttpRequest request - ) { - return executeInternal(request); + public ApiResponse> executeApiResponseList(HttpRequest request) { + return executeRequest(request); } @Override - public ApiPrivateResponse> executeApiPrivateResponse( - HttpRequest request - ) { - return executeInternal(request); + public ApiPrivateResponse> executeApiPrivateResponse(HttpRequest request) { + return executeRequest(request); } @Override - public ApiPrivateResponse, ApiPrivateError>> executeApiPrivateResponseList( - HttpRequest request - ) { - return executeInternal(request); + public ApiPrivateResponse, ApiPrivateError>> executeApiPrivateResponseList(HttpRequest request) { + return executeRequest(request); } - private T executeInternal(HttpRequest request) { - String finalUrl = buildFinalUrl(request); - - if (request.isLogRequestBody()) { - log.info("URL final: {}", finalUrl); - - if (request.getHeaders() != null && !request.getHeaders().isEmpty()) { - log.info("Headers: {}", request.getHeaders()); - } - - if (request.getQueryParams() != null && !request.getQueryParams().isEmpty()) { - log.info("Query params: {}", request.getQueryParams()); - } - - if (request.getBody() != null) { - log.info("Body: {}", request.getBody()); - } - } - + private Either executeEitherInternal(HttpRequest request, boolean isList) { try (Client client = createClient(request.getConnectTimeout(), request.getReadTimeout())) { - WebTarget target = client.target(finalUrl); + WebTarget target = client.target(buildFinalUrl(request)); + Invocation.Builder builder = target.request(MediaType.APPLICATION_JSON); + + if (request.getHeaders() != null) { + request.getHeaders().forEach(builder::header); + } + + Response response = buildRequest(builder, request); + return handleEitherResponse(request, response, isList); + + } catch (HttpStatusCodeException | HttpApiResponseException e) { + throw e; + } catch (Exception e) { + throw handleConnectionError(request, e); + } + } + + private T executeRequest(HttpRequest request) { + try (Client client = createClient(request.getConnectTimeout(), request.getReadTimeout())) { + WebTarget target = client.target(buildFinalUrl(request)); Invocation.Builder builder = target.request(MediaType.APPLICATION_JSON); if (request.getHeaders() != null) { @@ -97,14 +102,122 @@ public class HttpClientService implements HttpClientUseCase { } catch (HttpStatusCodeException | HttpApiResponseException e) { throw e; } catch (Exception e) { - log.error("Error de conexion {}: {}", request.getMethod(), e.getMessage()); - throw HttpStatusCodeException.serviceUnavailable( - "503", - "Error de conexion con el servicio externo: " + e.getMessage() - ); + throw handleConnectionError(request, e); } } + @SuppressWarnings("unchecked") + private Either 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 parseSuccessResponse(HttpRequest request, String responseBody) throws JsonProcessingException { + Type successType = extractSuccessType(request); + + if (successType != null) { + if (successType instanceof Class) { + return objectMapper.readValue(responseBody, (Class) 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 List 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) 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 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) 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(); @@ -115,7 +228,11 @@ public class HttpClientService implements HttpClientUseCase { } } - return appendQueryParams(finalUrl, request.getQueryParams()); + String url = appendQueryParams(finalUrl, request.getQueryParams()); + + log.info("Url Final: {}", url); + + return url; } private String appendQueryParams(String url, Map queryParams) { @@ -145,12 +262,13 @@ public class HttpClientService implements HttpClientUseCase { 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)); @@ -165,43 +283,26 @@ public class HttpClientService implements HttpClientUseCase { private Client createClient(int connectTimeout, int readTimeout) { return ClientBuilder.newBuilder() - .connectTimeout(connectTimeout, TimeUnit.MILLISECONDS) - .readTimeout(readTimeout, TimeUnit.MILLISECONDS) - .build(); + .connectTimeout(connectTimeout, TimeUnit.MILLISECONDS) + .readTimeout(readTimeout, TimeUnit.MILLISECONDS) + .build(); } - private T handleResponse( - HttpRequest request, - Response response - ) { + private 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); - - if (request.isLogResponseBody()) { - log.info("Respuesta Cuerpo: {}", responseBody); - } + logResponse(request, statusCode, responseBody); if (statusCode >= 200 && statusCode < 300) { if (request.getResponseType() == Void.class || request.getResponseType() == void.class) { return null; } - T result = responseResult(request, responseBody); - - log.debug("Respuesta exitosa {} {}: {}", request.getMethod(), request.getUrl(), result); - - return result; + return responseResult(request, responseBody); } else { - log.error( - "Error HTTP {} {} - Status: {} - Body: {}", - request.getMethod(), - request.getUrl(), - statusCode, - responseBody - ); + logErrorResponse(request, statusCode, responseBody); if (isApiResponseFormat(responseBody)) { ApiResponse apiResponse = deserializeApiResponse(responseBody, request); @@ -213,53 +314,72 @@ public class HttpClientService implements HttpClientUseCase { } catch (HttpStatusCodeException | HttpApiResponseException e) { throw e; } catch (Exception e) { - log.error( - "Error procesando respuesta {} {}: {}", - request.getMethod(), - request.getUrl(), - e.getMessage() - ); - throw HttpStatusCodeException.internalServer( - "500", "Error procesando respuesta del servicio externo: " + e.getMessage() - ); + throw handleProcessingError(request, e); } } - private T responseResult( - HttpRequest request, - String responseBody - ) throws JsonProcessingException { + private void logResponse(HttpRequest request, int statusCode, String responseBody) { + if (request.isLogResponseBody()) { + log.info("Respuesta {} - Status: {}", request.getMethod(), statusCode); + log.info("Respuesta Cuerpo: {}", responseBody); + } + } + + 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 responseResult(HttpRequest request, String responseBody) throws JsonProcessingException { if (request.isApiPrivateResponse() && request.isEitherResponse()) { return handleApiPrivateResponseWithEither(request, responseBody); } - T result; - if (request.getResponseType() == ApiResponse.class) { - result = deserializeApiResponse(responseBody, request); + return deserializeApiResponse(responseBody, request); } else if (request.getComplexType() != null) { JavaType javaType = objectMapper.getTypeFactory().constructParametricType( request.getResponseType(), objectMapper.getTypeFactory().constructType(request.getComplexType()) ); - result = objectMapper.readValue(responseBody, javaType); + return objectMapper.readValue(responseBody, javaType); } else if (request.getGenericType() != null) { JavaType javaType = objectMapper.getTypeFactory().constructParametricType( request.getResponseType(), objectMapper.getTypeFactory().constructType(request.getGenericType()) ); - result = objectMapper.readValue(responseBody, javaType); + return objectMapper.readValue(responseBody, javaType); } else { - result = objectMapper.readValue( + return objectMapper.readValue( responseBody, objectMapper.getTypeFactory().constructType(request.getResponseType()) ); } - - return result; } - private T handleApiPrivateResponseWithEither( - HttpRequest request, - String responseBody - ) throws JsonProcessingException { + private 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; @@ -273,12 +393,7 @@ public class HttpClientService implements HttpClientUseCase { } @SuppressWarnings("unchecked") - private T handleSuccessResponse( - HttpRequest request, - String status, - String message, - JsonNode detailNode - ) { + private T handleSuccessResponse(HttpRequest request, String status, String message, JsonNode detailNode) { Object successData; if (request.isListResponse()) { @@ -300,10 +415,7 @@ 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); @@ -314,10 +426,7 @@ 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()) { @@ -328,11 +437,7 @@ public class HttpClientService implements HttpClientUseCase { } @SuppressWarnings("unchecked") - private T handleErrorResponse( - String status, - String message, - JsonNode detailNode - ) { + private T handleErrorResponse(String status, String message, JsonNode detailNode) { ApiPrivateError error = buildApiPrivateError(detailNode, message); ApiPrivateResponse> response = new ApiPrivateResponse<>(); @@ -343,10 +448,7 @@ 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); @@ -390,15 +492,11 @@ public class HttpClientService implements HttpClientUseCase { } @SuppressWarnings("unchecked") - private T deserializeApiResponse( - String responseBody, - HttpRequest request - ) { + private 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 { @@ -432,10 +530,7 @@ 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() diff --git a/src/main/java/com/banesco/common/application/usecase/HttpClientUseCase.java b/src/main/java/com/banesco/common/application/usecase/HttpClientUseCase.java index c7a0b7b..b55922c 100644 --- a/src/main/java/com/banesco/common/application/usecase/HttpClientUseCase.java +++ b/src/main/java/com/banesco/common/application/usecase/HttpClientUseCase.java @@ -8,6 +8,10 @@ public interface HttpClientUseCase { T execute(HttpRequest request); + Either executeEither(HttpRequest request); + + Either, R> executeEitherList(HttpRequest request); + ApiResponse executeApiResponse(HttpRequest request); ApiResponse> executeApiResponseList(HttpRequest request); diff --git a/src/main/java/com/banesco/module/docservice_file_audit_trace/application/service/DocserviceFileAuditTraceService.java b/src/main/java/com/banesco/module/docservice_file_audit_trace/application/service/DocserviceFileAuditTraceService.java index 3e21179..0173e9a 100644 --- a/src/main/java/com/banesco/module/docservice_file_audit_trace/application/service/DocserviceFileAuditTraceService.java +++ b/src/main/java/com/banesco/module/docservice_file_audit_trace/application/service/DocserviceFileAuditTraceService.java @@ -43,6 +43,9 @@ public class DocserviceFileAuditTraceService implements DocserviceFileAuditTrace apiResponse.getData(), apiResponse.getStatusResponse().getStatusCode() ); + } catch (ApiPrivateException e) { + log.warn("Excepcion de la api privada: {} -> {}", e.getStatusCode(), e.getMessage()); + response = messageHelper.handleException(HttpStatusCodeException.badRequest("400")); } catch (HttpStatusCodeException e) { log.error("Excepcion HTTP del api privada: {} - {}", e.getStatusCode(), e.getErrorCode()); response = messageHelper.handleException(e); diff --git a/src/main/java/com/banesco/module/docservice_file_audit_trace/domain/dto/request/DocserviceFileAuditTraceRequest.java b/src/main/java/com/banesco/module/docservice_file_audit_trace/domain/dto/request/DocserviceFileAuditTraceRequest.java index 06271b5..b661eb2 100644 --- a/src/main/java/com/banesco/module/docservice_file_audit_trace/domain/dto/request/DocserviceFileAuditTraceRequest.java +++ b/src/main/java/com/banesco/module/docservice_file_audit_trace/domain/dto/request/DocserviceFileAuditTraceRequest.java @@ -46,8 +46,7 @@ public class DocserviceFileAuditTraceRequest { @JsonIgnore public String getChannelCode() { return procedureRequest - .getInstructionPurposeType() - .name(); + .getInstructionPurposeType(); } @JsonIgnore diff --git a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/adapter/ApiPrivateAdapter.java b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/adapter/ApiPrivateAdapter.java index 69d7024..ed06e44 100644 --- a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/adapter/ApiPrivateAdapter.java +++ b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/adapter/ApiPrivateAdapter.java @@ -16,21 +16,22 @@ import java.util.Objects; @Slf4j @ApplicationScoped public class ApiPrivateAdapter implements ApiPrivateRepository { - private final PaymentFileUseCase paymentStatusUseCase; + private final PaymentFileUseCase paymentFileUseCase; @Inject public ApiPrivateAdapter( - PaymentFileUseCase paymentStatusUseCase + PaymentFileUseCase paymentFileUseCase ) { - this.paymentStatusUseCase = paymentStatusUseCase; + this.paymentFileUseCase = paymentFileUseCase; } @Override public DocumentService execute( DocserviceFileAuditTraceRequest request ) { - PaymentFile response = paymentStatusUseCase.execute( - ServicingIssueMapper.toPaymentRequest(request), PaymentFile.class + PaymentFile response = paymentFileUseCase.execute( + ServicingIssueMapper.toPaymentRequest(request), + PaymentFile.class ); if(Objects.isNull(response) || Objects.isNull(response.getId())) { diff --git a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/mapper/ServicingIssueMapper.java b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/mapper/ServicingIssueMapper.java index b3e1e36..723d711 100644 --- a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/mapper/ServicingIssueMapper.java +++ b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/mapper/ServicingIssueMapper.java @@ -25,7 +25,7 @@ public class ServicingIssueMapper { .directorio(request.getDocumentDirectory()) .build() ) - .channelOrigin(request.getProcedureRequest().getInstructionPurposeType().name()) + .channelOrigin(request.getChannelCode()) .build(); } diff --git a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/resource/DocserviceFileAuditTraceResource.java b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/resource/DocserviceFileAuditTraceResource.java index e197063..1a0eb0f 100644 --- a/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/resource/DocserviceFileAuditTraceResource.java +++ b/src/main/java/com/banesco/module/docservice_file_audit_trace/infrastructure/resource/DocserviceFileAuditTraceResource.java @@ -217,7 +217,6 @@ public class DocserviceFileAuditTraceResource { public Response provide( @RequestBody( description = "Request para la notificación del archivo", - required = true, content = @Content( mediaType = MediaType.APPLICATION_JSON, schema = @Schema(implementation = DocserviceFileAuditTraceRequest.class), diff --git a/src/main/java/com/banesco/module/instruction/domain/model/Instruction.java b/src/main/java/com/banesco/module/instruction/domain/model/Instruction.java index 4a99396..1361379 100644 --- a/src/main/java/com/banesco/module/instruction/domain/model/Instruction.java +++ b/src/main/java/com/banesco/module/instruction/domain/model/Instruction.java @@ -12,5 +12,5 @@ import lombok.*; @RegisterForReflection @JsonInclude(JsonInclude.Include.NON_NULL) public class Instruction { - private InstructionPurposeType instructionPurposeType; // Request JSON: "channelOrigin" (BOLE) + private String instructionPurposeType; // Request JSON: "channelOrigin" (BOLE) } diff --git a/src/main/java/com/banesco/module/instruction/domain/model/InstructionPurposeType.java b/src/main/java/com/banesco/module/instruction/domain/model/InstructionPurposeType.java deleted file mode 100644 index acf15e5..0000000 --- a/src/main/java/com/banesco/module/instruction/domain/model/InstructionPurposeType.java +++ /dev/null @@ -1,6 +0,0 @@ -package com.banesco.module.instruction.domain.model; - -public enum InstructionPurposeType { - BOLE, - BOL, -} diff --git a/src/main/java/com/banesco/module/payment_file/infrastructure/client/PaymentFileClient.java b/src/main/java/com/banesco/module/payment_file/infrastructure/client/PaymentFileClient.java index ada8d64..919905f 100644 --- a/src/main/java/com/banesco/module/payment_file/infrastructure/client/PaymentFileClient.java +++ b/src/main/java/com/banesco/module/payment_file/infrastructure/client/PaymentFileClient.java @@ -19,7 +19,7 @@ import java.util.Map; public class PaymentFileClient implements PaymentFileUseCase { private final SerializationHelper serializationHelper; private final HttpClientUseCase httpClientUseCase; - private final PaymentFileConfig paymentStatusConfig; + private final PaymentFileConfig paymentFileConfig; @Inject public PaymentFileClient( @@ -29,8 +29,8 @@ public class PaymentFileClient implements PaymentFileUseCase { ) { this.serializationHelper = serializationHelper; this.httpClientUseCase = httpClientUseCase; - this.paymentStatusConfig = restClientConfig.getPaymentFileConfig(); - log.info("Configuracion cargada para payment-status: {}", paymentStatusConfig); + this.paymentFileConfig = restClientConfig.getPaymentFileConfig(); + log.info("Configuracion cargada para docservice-file: {}", paymentFileConfig); } @Override @@ -42,16 +42,16 @@ public class PaymentFileClient implements PaymentFileUseCase { String fileName = params.getOperation().getName(); Map payload = getPayload(params); HttpRequest request = HttpRequest.forApiPrivateResponse( - paymentStatusConfig.getUrl(), - paymentStatusConfig.getStatusSuccess(), + paymentFileConfig.getUrl(), + paymentFileConfig.getStatusSuccess(), HttpRequest.HttpMethod.POST, responseType ) .withBody(payload) .withHeaders(Map.of("fintechId", fintechId)) .withTimeout( - paymentStatusConfig.getTimeout().getConnect(), - paymentStatusConfig.getTimeout().getResponse() + paymentFileConfig.getTimeout().getConnect(), + paymentFileConfig.getTimeout().getResponse() ); try { @@ -63,7 +63,7 @@ public class PaymentFileClient implements PaymentFileUseCase { log.error( "API retorno exitoso pero con detalle vacio. Codigo: {}, Mensaje: {}", response.getEstatus(), - response.getMensaje() + response.getMensaje() ); throw ApiPrivateException.builder() @@ -89,8 +89,8 @@ public class PaymentFileClient implements PaymentFileUseCase { throw ApiPrivateException.builder() .statusCode(response.getEstatus()) .message((error.getCodError() != null) - ? error.getCodError() + ":" + error.getMensajeError() - : "EMPTY_MESSAGE" + ? error.getCodError() + ":" + error.getMensajeError() + : "EMPTY_MESSAGE" ) .build(); } catch (ApiPrivateException e) { @@ -110,21 +110,21 @@ public class PaymentFileClient implements PaymentFileUseCase { } private Map getPayload(PaymentFileRequest params) { - Map paymentStatusRequest = serializationHelper.toMap(params); + Map paymentFileRequest = serializationHelper.toMap(params); Map operation = serializationHelper.toMap(params.getOperation()); String signature = serializationHelper.generateSignature( params.getOperation(), params.getChannelOrigin() ); - paymentStatusRequest.put("signature", signature); - paymentStatusRequest.put("operation", operation); + paymentFileRequest.put("signature", signature); + paymentFileRequest.put("operation", operation); - paymentStatusRequest.remove("fintechId"); + paymentFileRequest.remove("fintechId"); log.info("3. Firma generada: {}", signature); - log.info("4. Parametros de la solicitud: {}", paymentStatusRequest); - log.info("5. Solicitud final: {}", paymentStatusRequest); + log.info("4. Parametros de la solicitud: {}", paymentFileRequest); + log.info("5. Solicitud final: {}", paymentFileRequest); - return paymentStatusRequest; + return paymentFileRequest; } } \ No newline at end of file