Creates endpoint for fetching student merges

api/src/main/java/ca/bc/gov/educ/eas/api/constants/EventType.java

@@ -4,6 +4,7 @@ public enum EventType {
   INITIATED, //Default. Used by BaseOrchestrator.
   MARK_SAGA_COMPLETE, //Default. Used by BaseOrchestrator.
   GET_PAGINATED_SCHOOLS,
+  GET_MERGED_STUDENT_IDS,
   CREATE_STUDENT_REGISTRATION,
   GET_STUDENT_REGISTRATION,
   PUBLISH_STUDENT_REGISTRATION,

api/src/main/java/ca/bc/gov/educ/eas/api/constants/TopicsEnum.java

@@ -5,5 +5,6 @@ public enum TopicsEnum {
   EAS_API_TOPIC,
   INSTITUTE_API_TOPIC,
   EAS_EVENTS_TOPIC,
+  PEN_SERVICES_API_TOPIC,
   CREATE_STUDENT_REGISTRATION_SAGA_TOPIC
 }

api/src/main/java/ca/bc/gov/educ/eas/api/controller/v1/PENRecordController.java

@@ -0,0 +1,24 @@
+package ca.bc.gov.educ.eas.api.controller.v1;
+
+import ca.bc.gov.educ.eas.api.endpoint.v1.PENRecordEndpoint;
+import ca.bc.gov.educ.eas.api.service.v1.PENRecordService;
+import ca.bc.gov.educ.eas.api.struct.v1.StudentMerge;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Slf4j
+@RestController
+public class PENRecordController implements PENRecordEndpoint {
+    private final PENRecordService penRecordService;
+
+    public PENRecordController(PENRecordService penRecordService){
+        this.penRecordService = penRecordService;
+    }
+
+    @Override
+    public List<StudentMerge> getMergedStudentsForDateRange(String createDateStart, String createDateEnd){
+        return penRecordService.getMergedStudentsForDateRange(createDateStart, createDateEnd);
+    }
+}

api/src/main/java/ca/bc/gov/educ/eas/api/endpoint/v1/PENRecordEndpoint.java

@@ -0,0 +1,25 @@
+package ca.bc.gov.educ.eas.api.endpoint.v1;
+
+import ca.bc.gov.educ.eas.api.constants.v1.URL;
+import ca.bc.gov.educ.eas.api.struct.v1.StudentMerge;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+
+@RequestMapping(URL.BASE_URL + "/pen-records/createDateInRange")
+public interface PENRecordEndpoint {
+
+    @GetMapping()
+    @PreAuthorize("hasAuthority('SCOPE_READ_EAS_STUDENT')")
+    @ApiResponses(value = {@ApiResponse(responseCode = "200", description = "OK")})
+    @Tag(name = "PEN Records", description = "Endpoints to retrieve PEN records.")
+    List<StudentMerge> getMergedStudentsForDateRange(@RequestParam(name = "createDateStart") String createDateStart, @RequestParam(name = "createDateEnd") String createDateEnd) throws JsonProcessingException;
+
+}

api/src/main/java/ca/bc/gov/educ/eas/api/rest/RestUtils.java

@@ -7,6 +7,7 @@
 import ca.bc.gov.educ.eas.api.properties.ApplicationProperties;
 import ca.bc.gov.educ.eas.api.struct.Event;
 import ca.bc.gov.educ.eas.api.struct.external.institute.v1.*;
+import ca.bc.gov.educ.eas.api.struct.v1.StudentMerge;
 import ca.bc.gov.educ.eas.api.util.JsonUtil;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -45,6 +46,8 @@ public class RestUtils {
   private final Map<String, FacilityTypeCode> facilityTypeCodesMap = new ConcurrentHashMap<>();
   private final Map<String, SchoolCategoryCode> schoolCategoryCodesMap = new ConcurrentHashMap<>();
   public static final String PAGE_SIZE = "pageSize";
+  public static final String CREATE_DATE_START = "createDateStart";
+  public static final String CREATE_DATE_END = "createDateEnd";
   private final WebClient webClient;
   private final MessagePublisher messagePublisher;
   private final ObjectMapper objectMapper = new ObjectMapper();
@@ -324,4 +327,26 @@ public List<School> getAllSchoolList(UUID correlationID) {
       throw new EasAPIRuntimeException(NATS_TIMEOUT + correlationID + ex.getMessage());
     }
   }
+
+  @Retryable(retryFor = {Exception.class}, noRetryFor = {EasAPIRuntimeException.class}, backoff = @Backoff(multiplier = 2, delay = 2000))
+  public List<StudentMerge> getMergedStudentsForDateRange(UUID correlationID, String createDateStart, String createDateEnd) {
+    try {
+      final TypeReference<Event> refEventResponse = new TypeReference<>() {};
+      final TypeReference<List<StudentMerge>> refMergedStudentResponse = new TypeReference<>() {};
+      Object event = Event.builder().sagaId(correlationID).eventType(EventType.GET_MERGED_STUDENT_IDS).eventPayload(CREATE_DATE_START.concat("=").concat(createDateStart).concat("&").concat(CREATE_DATE_END).concat("=").concat(createDateEnd)).build();
+      val responseMessage = this.messagePublisher.requestMessage(TopicsEnum.PEN_SERVICES_API_TOPIC.toString(), JsonUtil.getJsonBytesFromObject(event)).completeOnTimeout(null, 120, TimeUnit.SECONDS).get();
+      if (responseMessage == null) {
+        log.error("Received null response from PEN SERVICES API for correlationID: {}", correlationID);
+        throw new EasAPIRuntimeException(NATS_TIMEOUT + correlationID);
+      } else {
+        val eventResponse = objectMapper.readValue(responseMessage.getData(), refEventResponse);
+        return objectMapper.readValue(eventResponse.getEventPayload(), refMergedStudentResponse);
+      }
+
+    } catch (final Exception ex) {
+      log.error("Error occurred calling PEN SERVICES API service :: " + ex.getMessage());
+      Thread.currentThread().interrupt();
+      throw new EasAPIRuntimeException(ex.getMessage());
+    }
+  }
 }

api/src/main/java/ca/bc/gov/educ/eas/api/service/v1/PENRecordService.java

@@ -0,0 +1,24 @@
+package ca.bc.gov.educ.eas.api.service.v1;
+
+import ca.bc.gov.educ.eas.api.rest.RestUtils;
+import ca.bc.gov.educ.eas.api.struct.v1.StudentMerge;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.UUID;
+
+@Service
+public class PENRecordService {
+
+    private final RestUtils restUtils;
+
+    @Autowired
+    public PENRecordService(RestUtils restUtils){
+        this.restUtils = restUtils;
+    }
+
+    public List<StudentMerge> getMergedStudentsForDateRange(String createDateStart, String createDateEnd){
+        return restUtils.getMergedStudentsForDateRange(UUID.randomUUID(), createDateStart, createDateEnd);
+    }
+}

api/src/main/java/ca/bc/gov/educ/eas/api/struct/v1/StudentMerge.java

@@ -0,0 +1,52 @@
+package ca.bc.gov.educ.eas.api.struct.v1;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+
+/**
+ * The type Student merge.
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@SuperBuilder
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class StudentMerge extends BaseRequest implements Serializable {
+    /**
+     * The constant serialVersionUID.
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * The Student merge id.
+     */
+    String studentMergeID;
+    /**
+     * The Student id.
+     */
+    @NotNull(message = "Student ID can not be null.")
+    String studentID;
+    /**
+     * The Merge student id.
+     */
+    @NotNull(message = "Merge Student ID can not be null.")
+    String mergeStudentID;
+    /**
+     * The Student merge direction code.
+     */
+    @NotNull(message = "Student Merge Direction Code can not be null.")
+    String studentMergeDirectionCode;
+    /**
+     * The Student merge source code.
+     */
+    @NotNull(message = "Student Merge Source Code can not be null.")
+    String studentMergeSourceCode;
+}

api/src/test/java/ca/bc/gov/educ/eas/api/rest/RestUtilsTest.java

@@ -1,5 +1,6 @@
 package ca.bc.gov.educ.eas.api.rest;
 
+import ca.bc.gov.educ.eas.api.exception.EasAPIRuntimeException;
 import ca.bc.gov.educ.eas.api.messaging.MessagePublisher;
 import ca.bc.gov.educ.eas.api.properties.ApplicationProperties;
 import ca.bc.gov.educ.eas.api.struct.external.institute.v1.District;
@@ -14,6 +15,9 @@
 import org.springframework.web.reactive.function.client.WebClient;
 
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
+
+import static org.junit.jupiter.api.Assertions.*;
 
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -274,4 +278,36 @@ void testGetSchoolFromMincodeMap_WhenApiCallSucceeds_ShouldReturnSchool() {
         assertEquals(school1, result.get());
     }
 
+    @Test
+    void testGetAllMergedStudentsInRange_WhenRequestTimesOut_ShouldThrowEASAPIRuntimeException() {
+        UUID correlationID = UUID.randomUUID();
+        String createStartDate = "2024-02-01T00:00:00";
+        String createEndDate = "2024-09-01T00:00:00";
+
+        when(messagePublisher.requestMessage(anyString(), any(byte[].class)))
+                .thenReturn(CompletableFuture.completedFuture(null));
+
+        EasAPIRuntimeException exception = assertThrows(
+                EasAPIRuntimeException.class,
+                () -> restUtils.getMergedStudentsForDateRange(correlationID, createStartDate, createEndDate)
+        );
+
+        assertEquals(RestUtils.NATS_TIMEOUT + correlationID, exception.getMessage());
+    }
+
+    @Test
+    void testGetMergedStudentsInRange_WhenExceptionOccurs_ShouldThrowEASAPIRuntimeException() {
+        UUID correlationID = UUID.randomUUID();
+        String createStartDate = "2024-02-01T00:00:00";
+        String createEndDate = "2024-09-01T00:00:00";
+        Exception mockException = new Exception("exception");
+
+        when(messagePublisher.requestMessage(anyString(), any(byte[].class)))
+                .thenReturn(CompletableFuture.failedFuture(mockException));
+
+        assertThrows(
+                EasAPIRuntimeException.class,
+                () -> restUtils.getMergedStudentsForDateRange(correlationID, createStartDate, createEndDate)
+        );
+    }
 }