Create endpoint for resending an EhrExtract

Author: adrianclay

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

@@ -0,0 +1,48 @@
+package uk.nhs.adaptors.gp2gp.ehr;
+
+import org.hl7.fhir.dstu3.model.OperationOutcome;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.http.HttpStatus;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import uk.nhs.adaptors.gp2gp.ehr.model.EhrExtractStatus;
+import uk.nhs.adaptors.gp2gp.testcontainers.ActiveMQExtension;
+import uk.nhs.adaptors.gp2gp.testcontainers.MongoDBExtension;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@SpringBootTest
+@DirtiesContext
+@ExtendWith({SpringExtension.class, MongoDBExtension.class, ActiveMQExtension.class, MockitoExtension.class})
+public class EhrResendControllerTest {
+    @Autowired
+    private EhrExtractStatusRepository ehrExtractStatusRepository;
+    @Autowired
+    private EhrResendController ehrResendController;
+
+    @Test
+    public void When_AnEhrExtractHasFailed_Expect_RespondsWith202() {
+        var ehrExtractStatus = new EhrExtractStatus();
+        ehrExtractStatus.setConversationId("123-456");
+        // TODO: Mark ehrExtractStatus as failed.
+        ehrExtractStatusRepository.save(ehrExtractStatus);
+
+        var response = ehrResendController.scheduleEhrExtractResend("123-456");
+
+        assertThat(response.getStatusCode()).isEqualTo(HttpStatus.ACCEPTED);
+        assertThat(response.getBody()).isNull();
+    }
+
+    @Test
+    public void When_AnEhrExtractDoesNotExist_Expect_RespondsWith404() {
+        var response = ehrResendController.scheduleEhrExtractResend("123-456");
+
+        assertThat(response.getStatusCode()).isEqualTo(HttpStatus.NOT_FOUND);
+        // TODO: Add more detail to OperationOutcome
+        assertThat(response.getBody()).usingRecursiveComparison().isEqualTo(new OperationOutcome());
+    }
+}

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

@@ -0,0 +1,31 @@
+package uk.nhs.adaptors.gp2gp.ehr;
+
+import lombok.AllArgsConstructor;
+import org.hl7.fhir.dstu3.model.OperationOutcome;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PathVariable;
+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.ehr.model.EhrExtractStatus;
+
+import java.util.Optional;
+
+@RestController
+@AllArgsConstructor(onConstructor = @__(@Autowired))
+@RequestMapping(path = "/ehr-resend")
+public class EhrResendController {
+    private EhrExtractStatusRepository ehrExtractStatusRepository;
+
+    @PostMapping("/{conversationId}")
+    public ResponseEntity<OperationOutcome> scheduleEhrExtractResend(@PathVariable String conversationId) {
+        Optional<EhrExtractStatus> ehrExtractStatus = ehrExtractStatusRepository.findByConversationId(conversationId);
+
+        return ehrExtractStatus.map(e -> new ResponseEntity<OperationOutcome>(HttpStatus.ACCEPTED))
+                .orElse(new ResponseEntity<>(new OperationOutcome(), HttpStatus.NOT_FOUND));
+    }
+
+}