[HIA-721]

WIP getting some tests set up for the Gateway

Author: AlexHerbertMadeTech

src/main/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/gateways/RiskManagementGateway.kt

@@ -0,0 +1,10 @@
+package uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways;
+
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.models.assessRisksAndNeeds.CrnRiskManagementPlans
+
+class RiskManagementGateway {
+
+  fun getRiskManagementPlansForCrn(crn: String): CrnRiskManagementPlans {
+    return CrnRiskManagementPlans(crn, "plan", emptyList())
+  }
+}

src/main/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/models/assessRisksAndNeeds/CrnRiskManagementPlans.kt

@@ -8,7 +8,7 @@ data class CrnRiskManagementPlans(
   val limitedAccessOffender: String,
   val riskManagementPlan: List<CrnRiskManagementPlan>
 ) {
-  fun toRiskManagementPlan(): List<RiskManagementPlan> {
+  fun toRiskManagementPlans(): List<RiskManagementPlan> {
     return this.riskManagementPlan.stream()
       .map {
         RiskManagementPlan(

src/test/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/gateways/riskManagement/fixtures/GetRiskManagementPlanResponse.json

@@ -0,0 +1,32 @@
+{
+  "crn": "D1974X",
+  "limitedAccessOffender": true,
+  "riskManagementPlan": [
+    {
+      "assessmentId": 0,
+      "dateCompleted": "2024-05-04T01:04:20",
+      "partcompStatus": "string",
+      "initiationDate": "2024-05-04T01:04:20",
+      "assessmentStatus": "string",
+      "assessmentType": "string",
+      "superStatus": "string",
+      "keyInformationCurrentSituation": "string",
+      "furtherConsiderationsCurrentSituation": "string",
+      "supervision": "string",
+      "monitoringAndControl": "string",
+      "interventionsAndTreatment": "string",
+      "victimSafetyPlanning": "string",
+      "contingencyPlans": "string",
+      "laterWIPAssessmentExists": true,
+      "latestWIPDate": "2024-05-04T01:04:20",
+      "laterSignLockAssessmentExists": true,
+      "latestSignLockDate": "2024-05-04T01:04:20",
+      "laterPartCompUnsignedAssessmentExists": true,
+      "latestPartCompUnsignedDate": "2024-05-04T01:04:20",
+      "laterPartCompSignedAssessmentExists": true,
+      "latestPartCompSignedDate": "2024-05-04T01:04:20",
+      "laterCompleteAssessmentExists": true,
+      "latestCompleteDate": "2024-05-04T01:04:20"
+    }
+  ]
+}

src/test/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/gateways/riskManagement/riskManagementGatewayTest.kt

@@ -0,0 +1,51 @@
+package uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways.riskManagement
+
+import io.kotest.core.spec.style.DescribeSpec
+import org.mockito.Mockito
+import org.mockito.internal.verification.VerificationModeFactory
+import org.mockito.kotlin.verify
+import org.mockito.kotlin.whenever
+import org.springframework.boot.test.mock.mockito.MockBean
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways.HmppsAuthGateway
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways.RiskManagementGateway
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.mockservers.HmppsAuthMockServer
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.mockservers.RiskManagementApiMockServer
+import java.io.File
+
+class RiskManagementGatewayTest (
+  @MockBean val hmppsAuthGateway: HmppsAuthGateway,
+  private val riskManagementGateway: RiskManagementGateway,
+) : DescribeSpec({
+
+  val riskManagementMockServer = RiskManagementApiMockServer()
+
+  beforeEach{
+    riskManagementMockServer.start()
+    Mockito.reset(hmppsAuthGateway)
+
+    whenever(hmppsAuthGateway.getClientToken("Risk Management Plan Search")).thenReturn(HmppsAuthMockServer.TOKEN)
+  }
+
+  afterTest {
+    riskManagementMockServer.stop()
+  }
+
+  describe("get risks for given crn") {
+    val crn = "D1974X"
+
+    riskManagementMockServer.stubGetRiskManagementPlan(
+      crn,
+      File(
+        "src/test/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/gateways/riskManagement/fixtures/GetRiskManagementPlanResponse.json",
+      ).readText(),
+    )
+
+    it("authenticates using HMPPS Auth with credentials") {
+      riskManagementGateway.getRiskManagementPlansForCrn(crn)
+
+      verify(hmppsAuthGateway, VerificationModeFactory.times(1)).getClientToken("Prisoner Offender Search")
+    }
+
+  }
+
+})

src/test/kotlin/uk/gov/justice/digital/hmpps/hmppsintegrationapi/mockservers/RiskManagementApiMockServer.kt

@@ -0,0 +1,31 @@
+package uk.gov.justice.digital.hmpps.hmppsintegrationapi.mockservers
+
+import com.github.tomakehurst.wiremock.WireMockServer
+import com.github.tomakehurst.wiremock.client.WireMock.matching
+import com.github.tomakehurst.wiremock.client.WireMock.get
+import com.github.tomakehurst.wiremock.client.WireMock.aResponse
+import org.springframework.http.HttpStatus
+
+class RiskManagementApiMockServer : WireMockServer(WIREMOCK_PORT) {
+  companion object {
+    private const val WIREMOCK_PORT = 4009
+  }
+
+  fun stubGetRiskManagementPlan(
+    crn: String,
+    responseBody: String,
+    status: HttpStatus = HttpStatus.OK,
+  ) {
+    stubFor(
+      get("risks/crn/$crn/risk-management-plan")
+        .withHeader("Authorization", matching("Bearer ${HmppsAuthMockServer.TOKEN}"))
+        .willReturn(
+          aResponse()
+            .withHeader("Content-Type", "application/json")
+            .withStatus(status.value())
+            .withBody(responseBody.trimIndent()),
+        ),
+    )
+  }
+
+}