adding a test for GpcStructureTask scheduler

Author: ORybak5

service/src/intTest/java/uk/nhs/adaptors/gp2gp/ehr/EhrResendControllerTest.java

@@ -10,10 +10,13 @@
 import org.mockito.junit.jupiter.MockitoExtension;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
 import org.springframework.http.HttpStatus;
 import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.context.junit.jupiter.SpringExtension;
+import uk.nhs.adaptors.gp2gp.common.task.TaskDispatcher;
 import uk.nhs.adaptors.gp2gp.ehr.model.EhrExtractStatus;
+import uk.nhs.adaptors.gp2gp.gpc.GetGpcStructuredTaskDefinition;
 import uk.nhs.adaptors.gp2gp.testcontainers.ActiveMQExtension;
 import uk.nhs.adaptors.gp2gp.testcontainers.MongoDBExtension;
 
@@ -25,6 +28,8 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.hl7.fhir.dstu3.model.OperationOutcome.IssueType;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
 import static uk.nhs.adaptors.gp2gp.ehr.EhrStatusConstants.INCUMBENT_NACK_CODE;
 import static uk.nhs.adaptors.gp2gp.ehr.EhrStatusConstants.INCUMBENT_NACK_DISPLAY;
 
@@ -44,6 +49,9 @@ public class EhrResendControllerTest {
     @Autowired
     private EhrResendController ehrResendController;
 
+    @MockBean
+    private TaskDispatcher taskDispatcher;
+
     @Test
     public void When_AnEhrExtractHasFailed_Expect_RespondsWith202() {
 
@@ -71,6 +79,34 @@ public void When_AnEhrExtractHasFailed_Expect_RespondsWith202() {
         assertThat(response.getBody()).isNull();
     }
 
+    @Test
+    public void When_AnEhrExtractHasFailed_Expect_GetGpcStructuredTaskScheduled() {
+
+        String ehrMessageRef = generateRandomUppercaseUUID();
+        var ehrExtractStatus = new EhrExtractStatus();
+
+        ehrExtractStatus.setConversationId(CONVERSATION_ID);
+        ehrExtractStatus.setEhrReceivedAcknowledgement(EhrExtractStatus.EhrReceivedAcknowledgement.builder()
+                                                           .conversationClosed(FIVE_DAYS_AGO)
+                                                           .errors(List.of(
+                                                               EhrExtractStatus.EhrReceivedAcknowledgement.ErrorDetails.builder()
+                                                                   .code(INCUMBENT_NACK_CODE)
+                                                                   .display(INCUMBENT_NACK_DISPLAY)
+                                                                   .build()))
+                                                           .messageRef(ehrMessageRef)
+                                                           .received(FIVE_DAYS_AGO)
+                                                           .rootId(generateRandomUppercaseUUID())
+                                                           .build());
+
+        ehrExtractStatusRepository.save(ehrExtractStatus);
+
+        ehrResendController.scheduleEhrExtractResend(CONVERSATION_ID);
+
+        var taskDefinition = GetGpcStructuredTaskDefinition.builder().build();
+        verify(taskDispatcher, times(1)).createTask(taskDefinition);
+
+    }
+
     @Test
     public void When_AnEhrExtractDoesNotExist_Expect_RespondsWith404() {
 

service/src/main/java/uk/nhs/adaptors/gp2gp/ehr/EhrResendController.java

@@ -13,7 +13,9 @@
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import uk.nhs.adaptors.gp2gp.common.task.TaskDispatcher;
 import uk.nhs.adaptors.gp2gp.ehr.model.EhrExtractStatus;
+import uk.nhs.adaptors.gp2gp.gpc.GetGpcStructuredTaskDefinition;
 
 import java.util.Collections;
 import java.util.List;
@@ -27,6 +29,7 @@ public class EhrResendController {
     private static final String OPERATION_OUTCOME_URL = "https://fhir.nhs.uk/STU3/StructureDefinition/GPConnect-OperationOutcome-1";
 
     private EhrExtractStatusRepository ehrExtractStatusRepository;
+    private TaskDispatcher taskDispatcher;
 
     @PostMapping("/{conversationId}")
     public ResponseEntity<OperationOutcome> scheduleEhrExtractResend(@PathVariable String conversationId) {
@@ -48,10 +51,13 @@ public ResponseEntity<OperationOutcome> scheduleEhrExtractResend(@PathVariable S
             return new ResponseEntity<>(operationOutcome, HttpStatus.NOT_FOUND);
         }
 
-        return new ResponseEntity<>(HttpStatus.ACCEPTED);
+        var taskDefinition = GetGpcStructuredTaskDefinition.builder().build();
+        taskDispatcher.createTask(taskDefinition);
 
+        return new ResponseEntity<>(HttpStatus.ACCEPTED);
     }
 
+
     public static OperationOutcome createOperationOutcome(
         OperationOutcome.IssueType type, OperationOutcome.IssueSeverity severity, CodeableConcept details, String diagnostics) {
         var operationOutcome = new OperationOutcome();