NFDIV-4356 Send case invite to applicant when email address is updated

src/integrationTest/java/uk/gov/hmcts/divorce/solicitor/service/CcdAccessServiceIT.java

@@ -13,13 +13,17 @@
 import uk.gov.hmcts.divorce.idam.User;
 import uk.gov.hmcts.reform.authorisation.generators.AuthTokenGenerator;
 import uk.gov.hmcts.reform.ccd.client.CaseAssignmentApi;
+import uk.gov.hmcts.reform.ccd.client.model.CaseAssignmentUserRole;
 import uk.gov.hmcts.reform.ccd.client.model.CaseAssignmentUserRoleWithOrganisation;
 import uk.gov.hmcts.reform.ccd.client.model.CaseAssignmentUserRolesRequest;
+import uk.gov.hmcts.reform.ccd.client.model.CaseAssignmentUserRolesResource;
 import uk.gov.hmcts.reform.idam.client.models.UserInfo;
 
 import java.util.List;
 
 import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.mockito.ArgumentMatchers.anyList;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
@@ -84,8 +88,23 @@ void shouldRetryRemovingRolesThreeTimesWhenRemovingRolesThrowsException() {
     @Test
     void shouldRetryAddCaseRolesThreeTimesWhenAddingCaseRolesThrowsException() {
         when(idamService.retrieveUser(CASEWORKER_AUTH_TOKEN)).thenReturn(caseworkerUser());
+        when(idamService.retrieveSystemUpdateUserDetails()).thenReturn(caseworkerUser());
         when(authTokenGenerator.generate()).thenReturn(TEST_SERVICE_AUTH_TOKEN);
 
+        var response = CaseAssignmentUserRolesResource.builder()
+            .caseAssignmentUserRoles(List.of(
+                CaseAssignmentUserRole.builder().userId("1").caseRole("NOT_THIS_ONE").build(),
+                CaseAssignmentUserRole.builder().userId("2").caseRole("NOT_THIS_ONE").build()
+            ))
+            .build();
+
+        when(caseAssignmentApi.getUserRoles(
+                eq(CASEWORKER_AUTH_TOKEN),
+                eq(TEST_SERVICE_AUTH_TOKEN),
+                anyList()
+            )
+        ).thenReturn(response);
+
         doThrow(feignException(500, "some error"))
             .when(caseAssignmentApi).addCaseUserRoles(
                 CASEWORKER_AUTH_TOKEN,

src/main/java/uk/gov/hmcts/divorce/caseworker/event/CaseworkerUpdateApplicant1Email.java

@@ -0,0 +1,129 @@
+package uk.gov.hmcts.divorce.caseworker.event;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import uk.gov.hmcts.ccd.sdk.api.CCDConfig;
+import uk.gov.hmcts.ccd.sdk.api.CaseDetails;
+import uk.gov.hmcts.ccd.sdk.api.ConfigBuilder;
+import uk.gov.hmcts.ccd.sdk.api.callback.AboutToStartOrSubmitResponse;
+import uk.gov.hmcts.divorce.caseworker.service.EmailUpdateService;
+import uk.gov.hmcts.divorce.common.ccd.PageBuilder;
+import uk.gov.hmcts.divorce.divorcecase.model.Applicant;
+import uk.gov.hmcts.divorce.divorcecase.model.CaseData;
+import uk.gov.hmcts.divorce.divorcecase.model.State;
+import uk.gov.hmcts.divorce.divorcecase.model.UserRole;
+
+import static java.util.Collections.singletonList;
+import static uk.gov.hmcts.divorce.divorcecase.model.State.POST_SUBMISSION_STATES;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.CASE_WORKER;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.LEGAL_ADVISOR;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.SOLICITOR;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.SUPER_USER;
+import static uk.gov.hmcts.divorce.divorcecase.model.access.Permissions.CREATE_READ_UPDATE_DELETE;
+
+@Component
+@Slf4j
+public class CaseworkerUpdateApplicant1Email implements CCDConfig<CaseData, State, UserRole> {
+
+    public static final String CASEWORKER_UPDATE_APP1_EMAIL = "caseworker-update-app1-email";
+
+    @Autowired
+    private EmailUpdateService emailUpdateService;
+
+    private static final String EMAIL_LABEL = "${%s} email address";
+    private static final String APPLICANTS_OR_APPLICANT1S = "labelContentApplicantsOrApplicant1s";
+
+    @Override
+    public void configure(final ConfigBuilder<CaseData, State, UserRole> configBuilder) {
+        new PageBuilder(configBuilder
+            .event(CASEWORKER_UPDATE_APP1_EMAIL)
+            .forStates(POST_SUBMISSION_STATES)
+            .name("Update applicant1 email")
+            .description("Update applicant/applicant1 email")
+            .aboutToSubmitCallback(this::aboutToSubmit)
+            .showSummary()
+            .showEventNotes()
+            .grant(CREATE_READ_UPDATE_DELETE, SUPER_USER, CASE_WORKER)
+            .grantHistoryOnly(
+                SOLICITOR,
+                LEGAL_ADVISOR))
+            .page("updateApp1Email")
+            .pageLabel("Update applicant/applicant1 email")
+            .complex(CaseData::getApplicant1)
+            .optionalWithLabel(Applicant::getEmail, getLabel(EMAIL_LABEL, APPLICANTS_OR_APPLICANT1S))
+            .done();
+    }
+
+    public AboutToStartOrSubmitResponse<CaseData, State> midEvent(final CaseDetails<CaseData, State> details,
+                                                                  final CaseDetails<CaseData, State> detailsBefore) {
+        log.info("midEvent callback invoked for {}, Case Id: {}", CASEWORKER_UPDATE_APP1_EMAIL, details.getId());
+
+        CaseData caseData = details.getData();
+        CaseData caseDataBefore = detailsBefore.getData();
+
+        if (!validApplicant1ContactDetails(caseDataBefore, caseData)) {
+
+            return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+                .errors(singletonList("Please use the 'Update offline status' event before removing the email address."))
+                .build();
+        }
+
+        return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+            .data(caseData)
+            .build();
+    }
+
+    public AboutToStartOrSubmitResponse<CaseData, State> aboutToSubmit(
+        final CaseDetails<CaseData, State> details,
+        final CaseDetails<CaseData, State> beforeDetails
+    ) {
+        log.info("{} aboutToSubmit callback invoked for Case Id: {}", CASEWORKER_UPDATE_APP1_EMAIL, details.getId());
+
+        CaseData caseData = details.getData();
+        CaseData caseDataBefore = beforeDetails.getData();
+
+        boolean shouldSendInviteToApp1 = shouldSendInvite(caseData);
+
+        if (!caseData.getApplicant1().isRepresented() && shouldSendInviteToApp1) {
+            log.info("Sending new invite to applicant/applicant1  for Case Id: {}", details.getId());
+            final CaseDetails<CaseData, State> result = emailUpdateService.processUpdateForApplicant1(details);
+            String newEmail = caseData.getApplicant1().getEmail();
+
+            if (caseDataBefore.getApplicant1().getEmail() != null
+                && !caseDataBefore.getApplicant1().getEmail().isBlank()) {
+                emailUpdateService.sendNotificationToOldEmail(beforeDetails, newEmail, true);
+            }
+            return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+                .data(result.getData())
+                .build();
+        }
+
+        return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+            .data(caseData)
+            .build();
+    }
+
+    private boolean validApplicant1ContactDetails(CaseData caseDataBefore, CaseData caseData) {
+
+        if (caseDataBefore.getApplicant1().getEmail() != null && !caseDataBefore.getApplicant1().getEmail().isBlank()) {
+            if (!caseDataBefore.getApplicant1().isRepresented()
+                && !caseData.getApplicant1().isApplicantOffline()
+                && (caseData.getApplicant1().getEmail() == null || caseData.getApplicant1().getEmail().isBlank())) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    private boolean shouldSendInvite(CaseData caseData) {
+        if (caseData.getApplicant1().getEmail() == null || caseData.getApplicant1().getEmail().isBlank()) {
+            return false;
+        }
+        return true;
+    }
+
+    private String getLabel(final String label, final Object... value) {
+        return String.format(label, value);
+    }
+}

src/main/java/uk/gov/hmcts/divorce/caseworker/event/CaseworkerUpdateApplicant2Email.java

@@ -0,0 +1,133 @@
+package uk.gov.hmcts.divorce.caseworker.event;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import uk.gov.hmcts.ccd.sdk.api.CCDConfig;
+import uk.gov.hmcts.ccd.sdk.api.CaseDetails;
+import uk.gov.hmcts.ccd.sdk.api.ConfigBuilder;
+import uk.gov.hmcts.ccd.sdk.api.callback.AboutToStartOrSubmitResponse;
+import uk.gov.hmcts.divorce.caseworker.service.EmailUpdateService;
+import uk.gov.hmcts.divorce.common.ccd.PageBuilder;
+import uk.gov.hmcts.divorce.divorcecase.model.Applicant;
+import uk.gov.hmcts.divorce.divorcecase.model.CaseData;
+import uk.gov.hmcts.divorce.divorcecase.model.State;
+import uk.gov.hmcts.divorce.divorcecase.model.UserRole;
+
+import static java.util.Collections.singletonList;
+import static uk.gov.hmcts.divorce.divorcecase.model.State.POST_SUBMISSION_STATES;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.CASE_WORKER;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.LEGAL_ADVISOR;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.SOLICITOR;
+import static uk.gov.hmcts.divorce.divorcecase.model.UserRole.SUPER_USER;
+import static uk.gov.hmcts.divorce.divorcecase.model.access.Permissions.CREATE_READ_UPDATE_DELETE;
+
+@Component
+@Slf4j
+public class CaseworkerUpdateApplicant2Email implements CCDConfig<CaseData, State, UserRole> {
+
+    public static final String CASEWORKER_UPDATE_APP2_EMAIL = "caseworker-update-app2-email";
+
+    @Autowired
+    private EmailUpdateService emailUpdateService;
+
+    private static final String EMAIL_LABEL = "${%s} email address";
+    private static final String RESPONDENTS_OR_APPLICANT2S = "labelContentRespondentsOrApplicant2s";
+
+    @Override
+    public void configure(final ConfigBuilder<CaseData, State, UserRole> configBuilder) {
+        new PageBuilder(configBuilder
+            .event(CASEWORKER_UPDATE_APP2_EMAIL)
+            .forStates(POST_SUBMISSION_STATES)
+            .name("Update applicant2 email")
+            .description("Update respondent/applicant2 email")
+            .aboutToSubmitCallback(this::aboutToSubmit)
+            .showSummary()
+            .showEventNotes()
+            .grant(CREATE_READ_UPDATE_DELETE, SUPER_USER, CASE_WORKER)
+            .grantHistoryOnly(
+                SOLICITOR,
+                LEGAL_ADVISOR))
+            .page("updateApp2Email")
+            .pageLabel("Update respondent/applicant2 email")
+            .complex(CaseData::getApplicant2)
+            .optionalWithLabel(Applicant::getEmail, getLabel(EMAIL_LABEL, RESPONDENTS_OR_APPLICANT2S))
+            .done();
+    }
+
+    public AboutToStartOrSubmitResponse<CaseData, State> midEvent(final CaseDetails<CaseData, State> details,
+                                                                  final CaseDetails<CaseData, State> detailsBefore) {
+        log.info("midEvent callback invoked for {}, Case Id: {}", CASEWORKER_UPDATE_APP2_EMAIL, details.getId());
+
+        CaseData caseData = details.getData();
+        CaseData caseDataBefore = detailsBefore.getData();
+
+        if (!validApplicant2ContactDetails(caseDataBefore, caseData)) {
+
+            return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+                .errors(singletonList("Please use the 'Update offline status' event before removing the email address."))
+                .build();
+        }
+
+        return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+            .data(caseData)
+            .build();
+    }
+
+    public AboutToStartOrSubmitResponse<CaseData, State> aboutToSubmit(
+        final CaseDetails<CaseData, State> details,
+        final CaseDetails<CaseData, State> beforeDetails
+    ) {
+        log.info("{} aboutToSubmit callback invoked for Case Id: {}", CASEWORKER_UPDATE_APP2_EMAIL, details.getId());
+
+        CaseData caseData = details.getData();
+        CaseData caseDataBefore = beforeDetails.getData();
+
+        boolean shouldSendInviteToApp2 = shouldSendInvite(caseData);
+
+        if (!caseData.getApplicant2().isRepresented() && shouldSendInviteToApp2) {
+            log.info("Sending new invite to applicant2/respondent for Case Id: {}", details.getId());
+            final CaseDetails<CaseData, State> result = emailUpdateService.processUpdateForApplicant2(details);
+            String newEmail = caseData.getApplicant2().getEmail();
+
+            if (caseDataBefore.getApplicant2().getEmail() != null
+                && !caseDataBefore.getApplicant2().getEmail().isBlank()) {
+                emailUpdateService.sendNotificationToOldEmail(beforeDetails, newEmail, false);
+            }
+            return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+                .data(result.getData())
+                .build();
+        }
+
+        return AboutToStartOrSubmitResponse.<CaseData, State>builder()
+            .data(caseData)
+            .build();
+    }
+
+    private boolean validApplicant2ContactDetails(CaseData caseDataBefore, CaseData caseData) {
+
+        if (caseDataBefore.getApplicant2().getEmail() != null && !caseDataBefore.getApplicant2().getEmail().isBlank()) {
+            if (!caseDataBefore.getApplicant2().isRepresented()
+                && !caseData.getApplicant2().isApplicantOffline()
+                && (caseData.getApplicant2().getEmail() == null || caseData.getApplicant2().getEmail().isBlank())) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    private boolean shouldSendInvite(CaseData caseData) {
+        if (caseData.getApplicant2().getEmail() == null || caseData.getApplicant2().getEmail().isBlank()) {
+            return false;
+        }
+
+        if (caseData.getApplicationType().isSole() && (caseData.getApplication().getIssueDate() == null)) {
+            return false;
+        }
+        return true;
+    }
+
+    private String getLabel(final String label, final Object... value) {
+        return String.format(label, value);
+    }
+}

src/main/java/uk/gov/hmcts/divorce/caseworker/event/page/UpdateContactDetails.java

@@ -167,7 +167,6 @@ private void buildApplicant1Fields(final FieldCollectionBuilder<CaseData, State,
             .complex(CaseData::getApplicant1)
                 .optionalWithLabel(Applicant::getAddressOverseas, getLabel(ADDRESS_OVERSEAS_LABEL, APPLICANTS_OR_APPLICANT1S))
                 .optionalWithLabel(Applicant::getAddress, getLabel(ADDRESS_LABEL, APPLICANTS_OR_APPLICANT1S))
-                .optionalWithLabel(Applicant::getEmail, getLabel(EMAIL_LABEL, APPLICANTS_OR_APPLICANT1S))
                 .optionalWithLabel(Applicant::getPhoneNumber, getLabel(PHONE_LABEL, APPLICANTS_OR_APPLICANT1S))
                 .label("LabelHorizontalLine1", HORIZONTAL_RULE)
             .done();
@@ -188,7 +187,6 @@ private void buildApplicant2Fields(final FieldCollectionBuilder<CaseData, State,
                     getLabel(CONTACT_TYPE_LABEL, RESPONDENTS_OR_APPLICANT2S, THE_APPLICANT_OR_APPLICANT1))
                 .optionalWithLabel(Applicant::getAddressOverseas, getLabel(ADDRESS_OVERSEAS_LABEL, RESPONDENTS_OR_APPLICANT2S))
                 .optionalWithLabel(Applicant::getAddress, getLabel(ADDRESS_LABEL, RESPONDENTS_OR_APPLICANT2S))
-                .optionalWithLabel(Applicant::getEmail, getLabel(EMAIL_LABEL, RESPONDENTS_OR_APPLICANT2S))
                 .optionalWithLabel(Applicant::getPhoneNumber, getLabel(PHONE_LABEL, RESPONDENTS_OR_APPLICANT2S))
                 .label("LabelHorizontalLine2", HORIZONTAL_RULE)
             .done();
@@ -227,13 +225,6 @@ public AboutToStartOrSubmitResponse<CaseData, State> midEvent(final CaseDetails<
                 .build();
         }
 
-        if (!validApplicantContactDetails(caseDataBefore, caseData)) {
-
-            return AboutToStartOrSubmitResponse.<CaseData, State>builder()
-                .errors(singletonList("Please use the 'Update offline status' event before removing the email address."))
-                .build();
-        }
-
         if (!isValidCombination(caseData)) {
             final String errorMessage = String.format(
                 """
@@ -300,27 +291,6 @@ private List<String> validateSolicitorDetailsNotRemoved(Solicitor solicitorBefor
         return solicitorDetailRemovedErrors;
     }
 
-    private boolean validApplicantContactDetails(CaseData caseDataBefore, CaseData caseData) {
-
-        if (caseDataBefore.getApplicant1().getEmail() != null && !caseDataBefore.getApplicant1().getEmail().isBlank()) {
-            if (!caseDataBefore.getApplicant1().isRepresented()
-                && !caseData.getApplicant1().isApplicantOffline()
-                && (caseData.getApplicant1().getEmail() == null || caseData.getApplicant1().getEmail().isBlank())) {
-                return false;
-            }
-        }
-
-        if (caseDataBefore.getApplicant2().getEmail() != null && !caseDataBefore.getApplicant2().getEmail().isBlank()) {
-            if (!caseDataBefore.getApplicant2().isRepresented()
-                && !caseData.getApplicant2().isApplicantOffline()
-                && (caseData.getApplicant2().getEmail() == null || caseData.getApplicant2().getEmail().isBlank())) {
-                return false;
-            }
-        }
-
-        return true;
-    }
-
     private boolean isValidCombination(final CaseData caseData) {
 
         final Gender applicant1Gender = caseData.getApplicant1().getGender();