diff --git a/src/main/java/it/gov/pagopa/onboarding/citizen/repository/CitizenSpecificRepositoryImpl.java b/src/main/java/it/gov/pagopa/onboarding/citizen/repository/CitizenSpecificRepositoryImpl.java index a68c749..a4e422f 100644 --- a/src/main/java/it/gov/pagopa/onboarding/citizen/repository/CitizenSpecificRepositoryImpl.java +++ b/src/main/java/it/gov/pagopa/onboarding/citizen/repository/CitizenSpecificRepositoryImpl.java @@ -55,4 +55,5 @@ public static class ConsentKeyWrapper { private String k; } + } diff --git a/src/main/java/it/gov/pagopa/onboarding/citizen/validation/CitizenConsentValidationServiceImpl.java b/src/main/java/it/gov/pagopa/onboarding/citizen/validation/CitizenConsentValidationServiceImpl.java index d2e8fd5..85ffdfd 100644 --- a/src/main/java/it/gov/pagopa/onboarding/citizen/validation/CitizenConsentValidationServiceImpl.java +++ b/src/main/java/it/gov/pagopa/onboarding/citizen/validation/CitizenConsentValidationServiceImpl.java @@ -38,7 +38,7 @@ public CitizenConsentValidationServiceImpl(CitizenRepository citizenRepository, @Override public Mono handleExistingConsent(CitizenConsent existingConsent, String tppId, CitizenConsent citizenConsent) { if (existingConsent.getConsents().containsKey(tppId)) { - return Mono.just(mapperToDTO.map(existingConsent)); + return Mono.just(mapperToDTO.map(citizenConsent)); } else { return validateTppAndUpdateConsent(existingConsent, tppId, citizenConsent); } @@ -55,7 +55,7 @@ public Mono validateTppAndSaveConsent(String fiscalCode, Stri log.info("[EMD][CREATE-CITIZEN-CONSENT] Created new citizen consent for fiscal code: {}", Utils.createSHA256(fiscalCode)); bloomFilterService.add(fiscalCode); }) - .map(mapperToDTO::map); + .map(savedConsent -> mapperToDTO.map(citizenConsent)); } else { return Mono.error(exceptionMap.throwException(ExceptionName.TPP_NOT_FOUND, "TPP is not active or is invalid")); } @@ -70,7 +70,7 @@ private Mono validateTppAndUpdateConsent(CitizenConsent exist existingConsent.getConsents().put(tppId, citizenConsent.getConsents().get(tppId)); return citizenRepository.save(existingConsent) .doOnSuccess(savedConsent -> log.info("[EMD][CREATE-CITIZEN-CONSENT] Updated citizen consent for TPP: {}", tppId)) - .flatMap(savedConsent -> Mono.just(mapperToDTO.map(savedConsent))); + .map(savedConsent -> mapperToDTO.map(citizenConsent)); }); } }