Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package dev.vality.proxy.mocketbank.service.mpi;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import dev.vality.adapter.common.cds.model.CardDataProxyModel;
import dev.vality.proxy.mocketbank.configuration.properties.AdapterMockMpiProperties;
import dev.vality.proxy.mocketbank.service.mpi.model.*;
Expand All @@ -18,6 +20,7 @@ public class MpiApi {

private final RestClient restClient;
private final AdapterMockMpiProperties adapterMockMpiProperties;
private final ObjectMapper objectMapper;

public VerifyEnrollmentResponse verifyEnrollment(CardDataProxyModel cardData) {
VerifyEnrollmentRequest request = VerifyEnrollmentRequest.builder()
Expand Down Expand Up @@ -47,14 +50,22 @@ public ValidatePaResResponse validatePaRes(ValidatePaResRequest request) {
private <T> T sendMessage(String methodName, PrepareFieldsObject request, Class<T> responseClass) {
String prepareUrl = prepareUrl(adapterMockMpiProperties.getUrl(), methodName);
log.info("MockMpi {} url: {} with request: {}", methodName, prepareUrl, request);
ResponseEntity<T> responseEntity = restClient.post()
ResponseEntity<String> responseEntity = restClient.post()
.uri(prepareUrl)
.body(request.prepareFields())
.retrieve()
.toEntity(responseClass);
var response = responseEntity.getBody();
log.info("MockMpi {} url: {} with response: {}", methodName, prepareUrl, response);
return response;
.toEntity(String.class);
if (responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
var response = responseEntity.getBody();
log.info("MockMpi {} url: {} with response: {}", methodName, prepareUrl, response);
try {
return objectMapper.readValue(response, responseClass);
} catch (JsonProcessingException e) {
log.error("Error call mockMpi {} url: {} with response: {}", methodName, prepareUrl, response, e);
}
}
log.info("Error call mockMpi {} url: {} with response: {}", methodName, prepareUrl, responseEntity);
return null;
}

private String prepareUrl(String url, String path) {
Expand Down
Loading