Fix/grad2 31025

api/src/main/java/ca/bc/gov/educ/api/gradstudent/constant/FieldName.java

@@ -2,6 +2,7 @@
 
 public enum FieldName {
     SCHOOL_OF_RECORD,
+    SCHOOL_OF_RECORD_ID,
     GRAD_PROGRAM,
     ADULT_START_DATE,
     SLP_DATE,

api/src/main/java/ca/bc/gov/educ/api/gradstudent/constant/FieldType.java

@@ -2,5 +2,6 @@
 
 public enum FieldType {
     STRING,
-    DATE
+    DATE,
+    GUID
 }

api/src/main/java/ca/bc/gov/educ/api/gradstudent/constant/Topics.java

@@ -8,5 +8,6 @@ public enum Topics {
    * GradStatus events topic.
    */
   GRAD_STATUS_EVENT_TOPIC,
-  GRAD_STUDENT_API_FETCH_GRAD_STATUS_TOPIC
+  GRAD_STUDENT_API_FETCH_GRAD_STATUS_TOPIC,
+  GRAD_STUDENT_API_FETCH_GRAD_STUDENT_TOPIC,
 }

api/src/main/java/ca/bc/gov/educ/api/gradstudent/messaging/jetstream/FetchGradStudentRecordSubscriber.java

@@ -0,0 +1,91 @@
+package ca.bc.gov.educ.api.gradstudent.messaging.jetstream;
+
+import ca.bc.gov.educ.api.gradstudent.constant.Topics;
+import ca.bc.gov.educ.api.gradstudent.exception.EntityNotFoundException;
+import ca.bc.gov.educ.api.gradstudent.model.dc.Event;
+import ca.bc.gov.educ.api.gradstudent.model.dc.GradStudentRecordPayload;
+import ca.bc.gov.educ.api.gradstudent.model.dto.messaging.GradStudentRecord;
+import ca.bc.gov.educ.api.gradstudent.service.GradStudentService;
+import ca.bc.gov.educ.api.gradstudent.util.EducGradStudentApiConstants;
+import ca.bc.gov.educ.api.gradstudent.util.EducGradStudentApiUtils;
+import ca.bc.gov.educ.api.gradstudent.util.JsonUtil;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import io.nats.client.*;
+import lombok.val;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.util.UUID;
+
+@Component
+public class FetchGradStudentRecordSubscriber implements MessageHandler {
+
+    private final Connection natsConnection;
+    private Dispatcher dispatcher;
+    private final GradStudentService gradStudentService;
+    public static final String RESPONDING_BACK_TO_NATS_ON_CHANNEL = "responding back to NATS on {} channel ";
+    public static final String PAYLOAD_LOG = "payload is :: {}";
+    private static final String TOPIC = Topics.GRAD_STUDENT_API_FETCH_GRAD_STUDENT_TOPIC.toString();
+    private static final Logger log = LoggerFactory.getLogger(FetchGradStudentRecordSubscriber.class);
+
+    @Autowired
+    public FetchGradStudentRecordSubscriber(final Connection natsConnection, GradStudentService gradStudentService, EducGradStudentApiConstants constants) {
+        this.natsConnection = natsConnection;
+        this.gradStudentService = gradStudentService;
+    }
+
+    @PostConstruct
+    public void subscribe() {
+        this.dispatcher = this.natsConnection.createDispatcher(this);
+        this.dispatcher.subscribe(TOPIC);
+    }
+
+    @Override
+    public void onMessage(Message message) {
+        val eventString = new String(message.getData());
+        log.debug("Received message: {}", eventString);
+        String response;
+
+        try {
+            Event event = JsonUtil.getJsonObjectFromString(Event.class, eventString);
+            log.info("received GET_STUDENT event :: {}", event.getSagaId());
+            log.trace(PAYLOAD_LOG, event.getEventPayload());
+            UUID studentId = JsonUtil.getJsonObjectFromString(UUID.class, event.getEventPayload());
+            GradStudentRecord studentRecord = gradStudentService.getGraduationStudentRecord(studentId);
+            response = getResponse(studentRecord);
+            log.info(RESPONDING_BACK_TO_NATS_ON_CHANNEL, message.getReplyTo() != null ? message.getReplyTo() : event.getReplyTo());
+        } catch (Exception e) {
+            response = getErrorResponse(e);
+            log.error("Error while processing GET_STUDENT event", e);
+        }
+        this.natsConnection.publish(message.getReplyTo(), response.getBytes());
+    }
+
+    private String getResponse(GradStudentRecord studentRecord) throws JsonProcessingException {
+        GradStudentRecordPayload gradStudentRecordPayload = GradStudentRecordPayload.builder()
+                .studentID(String.valueOf(studentRecord.getStudentID()))
+                .program(studentRecord.getProgram())
+                .programCompletionDate(studentRecord.getProgramCompletionDate() != null ? EducGradStudentApiUtils.formatDate(studentRecord.getProgramCompletionDate()) : null)
+                .schoolOfRecord(studentRecord.getSchoolOfRecord())
+                .studentStatusCode(studentRecord.getStudentStatusCode())
+                .graduated(studentRecord.getGraduated().toString())
+                .build();
+        return JsonUtil.getJsonStringFromObject(gradStudentRecordPayload);
+    }
+
+    private String getErrorResponse(Exception e) {
+        String ex = (e instanceof EntityNotFoundException) ? "not found" : "error";
+        GradStudentRecordPayload gradStudentRecordPayload = GradStudentRecordPayload.builder()
+                .exception(ex)
+                .build();
+        try {
+            return JsonUtil.getJsonStringFromObject(gradStudentRecordPayload);
+        } catch (JsonProcessingException exc) {
+            log.error("Error while serializing error response", exc);
+            return "{\"studentID\": \"\", \"program\": \"\", \"programCompletionDate\": \"\", \"schoolOfRecord\": \"\", \"studentStatusCode\": \"\", \"graduated\": \"\", \"exception\": \"JSON Parsing exception\"}";
+        }
+    }
+}

api/src/main/java/ca/bc/gov/educ/api/gradstudent/model/dc/GradStudentRecordPayload.java

@@ -0,0 +1,18 @@
+package ca.bc.gov.educ.api.gradstudent.model.dc;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class GradStudentRecordPayload {
+
+    private String studentID;
+    private String exception;
+    private String program;
+    private String programCompletionDate;
+    private String schoolOfRecord;
+    private String studentStatusCode;
+    private String graduated;
+
+}