Feature branch Cafcass APIs

service/src/integrationTest/java/uk/gov/hmcts/reform/fpl/controllers/RootControllerTest.java

@@ -4,9 +4,11 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.autoconfigure.OverrideAutoConfiguration;
 import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.web.servlet.MockMvc;
 import org.springframework.test.web.servlet.MvcResult;
+import uk.gov.hmcts.reform.idam.client.IdamClient;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
@@ -20,6 +22,9 @@ class RootControllerTest {
     @Autowired
     private MockMvc mockMvc;
 
+    @MockBean
+    private IdamClient idamClient;
+
     @Test
     void shouldWelcomeUponRootRequestWith200ResponseCode() throws Exception {
         MvcResult response = mockMvc

service/src/integrationTest/java/uk/gov/hmcts/reform/fpl/controllers/TestingSupportControllerTest.java

@@ -32,6 +32,7 @@
 import uk.gov.hmcts.reform.fpl.service.ccd.CoreCaseDataService;
 import uk.gov.hmcts.reform.fpl.testingsupport.controllers.TestingSupportController;
 import uk.gov.hmcts.reform.fpl.utils.ResourceReader;
+import uk.gov.hmcts.reform.idam.client.IdamClient;
 
 import java.util.List;
 import java.util.Map;
@@ -93,6 +94,9 @@ class TestingSupportControllerTest {
     @MockBean
     private DocumentUploadClientApi uploadClient;
 
+    @MockBean
+    private IdamClient idamClient;
+
     @BeforeEach
     void init() {
         when(requestData.authorisation()).thenReturn(USER_AUTH_TOKEN);

service/src/integrationTest/java/uk/gov/hmcts/reform/fpl/controllers/cafcass/CafcassApiControllerBaseTest.java

@@ -0,0 +1,62 @@
+package uk.gov.hmcts.reform.fpl.controllers.cafcass;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.OverrideAutoConfiguration;
+import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
+import org.springframework.test.web.servlet.request.MockHttpServletRequestBuilder;
+import uk.gov.hmcts.reform.fpl.controllers.AbstractTest;
+import uk.gov.hmcts.reform.fpl.interceptors.CafcassApiInterceptor;
+import uk.gov.hmcts.reform.idam.client.models.UserInfo;
+
+import java.io.IOException;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.when;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+import static uk.gov.hmcts.reform.fpl.enums.UserRole.CAFCASS_SYSTEM_UPDATE;
+
+@WebMvcTest(CafcassCasesController.class)
+@OverrideAutoConfiguration(enabled = true)
+public abstract class CafcassApiControllerBaseTest extends AbstractTest {
+    private static final UserInfo CAFCASS_SYSTEM_UPDATE_USER_INFO = UserInfo.builder()
+        .roles(List.of(CAFCASS_SYSTEM_UPDATE.getRoleName()))
+        .build();
+
+    @Autowired
+    protected MockMvc mockMvc;
+
+    @MockBean
+    private CafcassApiInterceptor cafcassApiInterceptor;
+
+    @BeforeEach
+    void setUp() throws Exception {
+        givenCurrentUser(CAFCASS_SYSTEM_UPDATE_USER_INFO);
+        when(cafcassApiInterceptor.preHandle(any(), any(), any())).thenReturn(true);
+    }
+
+    protected MvcResult sendRequest(MockHttpServletRequestBuilder request, int expectedStatus) throws Exception {
+        MvcResult response = mockMvc.perform(request).andExpect(status().is(expectedStatus)).andReturn();
+        assertEquals(response.getResponse().getStatus(), expectedStatus);
+        return response;
+    }
+
+    protected <T> T readResponseContent(MvcResult response, Class<T> responseType) throws IOException {
+        return mapper.readValue(response.getResponse().getContentAsByteArray(), responseType);
+    }
+
+    protected MockHttpServletRequestBuilder buildGetRequest(String url) {
+        return get(url).header("authorization", USER_AUTH_TOKEN);
+    }
+
+    protected MockHttpServletRequestBuilder buildPostRequest(String url) {
+        return post(url).header("authorization", USER_AUTH_TOKEN);
+    }
+}

service/src/integrationTest/java/uk/gov/hmcts/reform/fpl/controllers/cafcass/CafcassApiSearchCaseControllerTest.java

@@ -0,0 +1,82 @@
+package uk.gov.hmcts.reform.fpl.controllers.cafcass;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.test.web.servlet.MvcResult;
+import uk.gov.hmcts.reform.fpl.model.cafcass.api.CafcassApiCase;
+import uk.gov.hmcts.reform.fpl.model.cafcass.api.CafcassApiCaseData;
+import uk.gov.hmcts.reform.fpl.model.cafcass.api.CafcassApiSearchCasesResponse;
+import uk.gov.hmcts.reform.fpl.service.cafcass.api.CafcassApiSearchCaseService;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.Mockito.when;
+
+public class CafcassApiSearchCaseControllerTest extends CafcassApiControllerBaseTest {
+    @MockBean
+    private CafcassApiSearchCaseService cafcassApiSearchCaseService;
+
+    @Test
+    void searchCases() throws Exception {
+        List<CafcassApiCase> responseCases = List.of(
+            CafcassApiCase.builder()
+                .caseId(1L).jurisdiction("jurisdiction").state("state").caseTypeId("caseTypeId")
+                .createdDate(LocalDateTime.of(2023, 1, 1, 10, 0, 0))
+                .lastModified(LocalDateTime.of(2024, 3, 28, 12,32,0))
+                .caseData(CafcassApiCaseData.builder().build())
+                .build(),
+            CafcassApiCase.builder()
+                .caseId(2L).jurisdiction("jurisdiction").state("state").caseTypeId("caseTypeId")
+                .createdDate(LocalDateTime.of(2024, 1, 1, 10, 0, 0))
+                .lastModified(LocalDateTime.of(2024, 3, 28, 12,40,0))
+                .caseData(CafcassApiCaseData.builder().build())
+                .build());
+
+        when(cafcassApiSearchCaseService.searchCaseByDateRange(
+            LocalDateTime.of(2024, 3, 28, 12,30,1,541000000),
+            LocalDateTime.of(2024, 3, 28, 12,45,1,540000000))
+        ).thenReturn(responseCases);
+
+        MvcResult response = sendRequest(buildGetRequest("/cases")
+            .queryParam("startDate", "2024-03-28T12:30:01.541")
+            .queryParam("endDate", "2024-03-28T12:45:01.540"), 200);
+
+        assertEquals(
+            CafcassApiSearchCasesResponse.builder().total(2).cases(responseCases).build(),
+            readResponseContent(response, CafcassApiSearchCasesResponse.class));
+    }
+
+    @Test
+    void searchCasesInvalidFormat400() throws Exception {
+        sendRequest(buildGetRequest("/cases")
+            .queryParam("startDate", "123").queryParam("endDate", "321"),
+            400);
+    }
+
+    @Test
+    void shouldReturn400IfEmptyParam() throws Exception {
+        sendRequest(buildGetRequest("/cases"), 400);
+
+        sendRequest(buildGetRequest("/cases")
+            .queryParam("startDate", "2023-03-28T12:32:54.541"), 400);
+
+        sendRequest(buildGetRequest("/cases")
+            .queryParam("endDate", "2024-03-27T12:32:54.542"), 400);
+    }
+
+    @Test
+    void searchCasesInvalidTimeRange() throws Exception {
+        sendRequest(buildGetRequest("/cases")
+            .queryParam("startDate", "2024-03-28T12:32:54.541")
+            .queryParam("endDate", "2023-03-27T12:32:54.542"), 400);
+    }
+
+    @Test
+    void shouldReturn400IfSearchRangeMoreThan15Minutes() throws Exception {
+        sendRequest(buildGetRequest("/cases")
+            .queryParam("startDate", "2024-03-28T12:32:54.541")
+            .queryParam("endDate", "2024-03-28T12:47:54.542"), 400);
+    }
+}

service/src/integrationTest/java/uk/gov/hmcts/reform/fpl/controllers/cafcass/CafcassCasesControllerTest.java

@@ -0,0 +1,165 @@
+package uk.gov.hmcts.reform.fpl.controllers.cafcass;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.OverrideAutoConfiguration;
+import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.http.MediaType;
+import org.springframework.mock.web.MockMultipartFile;
+import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
+import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
+import uk.gov.hmcts.reform.fpl.controllers.AbstractTest;
+import uk.gov.hmcts.reform.idam.client.models.UserInfo;
+
+import java.util.List;
+import java.util.UUID;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+import static uk.gov.hmcts.reform.fpl.enums.UserRole.CAFCASS_SYSTEM_UPDATE;
+
+@Deprecated
+@WebMvcTest(CafcassCasesController.class)
+@OverrideAutoConfiguration(enabled = true)
+public class CafcassCasesControllerTest extends AbstractTest {
+    private static final UserInfo CAFCASS_SYSTEM_UPDATE_USER_INFO = UserInfo.builder()
+        .roles(List.of(CAFCASS_SYSTEM_UPDATE.getRoleName()))
+        .build();
+    private static final UUID CASE_ID = UUID.randomUUID();
+    private static final  byte[] FILE_BYTES = "This is a file. Trust me!".getBytes();
+    private static final MockMultipartFile FILE = new MockMultipartFile(
+        "file", "MOCK_FILE.pdf", MediaType.TEXT_PLAIN_VALUE, FILE_BYTES);
+
+    @Autowired
+    private MockMvc mockMvc;
+
+    @BeforeEach
+    void setUp() {
+        givenCurrentUser(CAFCASS_SYSTEM_UPDATE_USER_INFO);
+    }
+
+    @Test
+    void uploadDocument() throws Exception {
+
+        MvcResult response = mockMvc
+            .perform(MockMvcRequestBuilders.multipart("/cases/%s/document".formatted(CASE_ID))
+                .file(FILE)
+                .param("typeOfDocument", "type Of Document")
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(200))
+            .andReturn();
+
+        assertEquals("uploadDocument - caseId: [%s], file length: [%s], typeOfDocument: [%s]"
+                .formatted(CASE_ID, FILE_BYTES.length, "type Of Document"),
+            response.getResponse().getContentAsString());
+    }
+
+    @Test
+    void uploadDocument400() throws Exception {
+        UUID caseId = UUID.randomUUID();
+
+        MvcResult response = mockMvc
+            .perform(MockMvcRequestBuilders.multipart("/cases/%s/document".formatted(caseId))
+                .param("typeOfDocument", "type Of Document")
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(400))
+            .andReturn();
+
+        assertEquals(response.getResponse().getStatus(), 400);
+
+
+        byte[] fileBytes = "This is a file. Trust me!".getBytes();
+        MockMultipartFile file = new MockMultipartFile(
+            "file", "MOCK_FILE.pdf", MediaType.TEXT_PLAIN_VALUE, fileBytes);
+
+        response = mockMvc
+            .perform(MockMvcRequestBuilders.multipart("/cases/%s/document".formatted(caseId))
+                .file(file)
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(400))
+            .andReturn();
+
+        assertEquals(response.getResponse().getStatus(), 400);
+    }
+
+    @Test
+    void uploadGuardians() throws Exception {
+        UUID caseId = UUID.randomUUID();
+
+        MvcResult response = mockMvc.perform(post("/cases/%s/guardians".formatted(caseId))
+                .content("[\n"
+                         + "  {\n"
+                         + "    \"guardianName\": \"John Smith\",\n"
+                         + "    \"telephoneNumber\": \"01234567890\",\n"
+                         + "    \"email\": \"[email protected]\",\n"
+                         + "    \"children\": [\n"
+                         + "      \"Joe Bloggs\"\n"
+                         + "    ]\n"
+                         + "  }\n"
+                         + "]")
+                .contentType(MediaType.APPLICATION_JSON)
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(200))
+            .andReturn();
+
+        assertEquals("uploadGuardians - caseId: [%s], no of guardians: [%s]\nguardianName: [%s], children: [%s]\n"
+                .formatted(caseId, 1, "John Smith", "Joe Bloggs"),
+            response.getResponse().getContentAsString());
+    }
+
+    @Test
+    void uploadGuardians400() throws Exception {
+        UUID caseId = UUID.randomUUID();
+
+        MvcResult response = mockMvc.perform(post("/cases/%s/guardians".formatted(caseId))
+                .content("[]")
+                .contentType(MediaType.APPLICATION_JSON)
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(400))
+            .andReturn();
+
+        assertEquals(response.getResponse().getStatus(), 400);
+
+        response = mockMvc.perform(post("/cases/%s/guardians".formatted(" "))
+                .content("[\n"
+                         + "  {\n"
+                         + "    \"guardianName\": \"John Smith\",\n"
+                         + "    \"telephoneNumber\": \"01234567890\",\n"
+                         + "    \"email\": \"[email protected]\",\n"
+                         + "    \"children\": [\n"
+                         + "      \"Joe Bloggs\"\n"
+                         + "    ]\n"
+                         + "  }\n"
+                         + "]")
+                .contentType(MediaType.APPLICATION_JSON)
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(400))
+            .andReturn();
+
+        assertEquals(response.getResponse().getStatus(), 400);
+    }
+
+    @Test
+    void uploadGuardians500() throws Exception {
+        UUID caseId = UUID.randomUUID();
+
+        MvcResult response = mockMvc.perform(post("/cases/%s/guardians".formatted(caseId))
+                .content("[\n"
+                         + "  {\n"
+                         + "    \"guardianName\": \"John Smith\",\n"
+                         + "    \"telephoneNumber\": \"01234567890\",\n"
+                         + "    \"email\": \"[email protected]\",\n"
+                         + "    \"children\": \"12313\""
+                         + "  }\n"
+                         + "]")
+                .contentType(MediaType.APPLICATION_JSON)
+                .header("authorization", USER_AUTH_TOKEN))
+            .andExpect(status().is(500))
+            .andReturn();
+
+        assertEquals(response.getResponse().getStatus(), 500);
+    }
+}

service/src/main/java/uk/gov/hmcts/reform/fpl/config/cafcass/CafcassApiConfiguration.java

@@ -0,0 +1,18 @@
+package uk.gov.hmcts.reform.fpl.config.cafcass;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+import uk.gov.hmcts.reform.fpl.interceptors.CafcassApiInterceptor;
+
+@Configuration
+@RequiredArgsConstructor(onConstructor = @__(@Autowired))
+public class CafcassApiConfiguration implements WebMvcConfigurer {
+    private final CafcassApiInterceptor cafcassApiInterceptor;
+
+    public void addInterceptors(InterceptorRegistry registry) {
+        registry.addInterceptor(cafcassApiInterceptor).addPathPatterns("/cases");
+    }
+}