[HIA-721]

WIP More progress

Author: AlexHerbertMadeTech

gradle.properties

@@ -2,21 +2,55 @@ package uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways
 
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.beans.factory.annotation.Value
+import org.springframework.http.HttpMethod
 import org.springframework.stereotype.Component
 import uk.gov.justice.digital.hmpps.hmppsintegrationapi.extensions.WebClientWrapper
 import uk.gov.justice.digital.hmpps.hmppsintegrationapi.models.assessRisksAndNeeds.CrnRiskManagementPlans
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.models.hmpps.Response
+import uk.gov.justice.digital.hmpps.hmppsintegrationapi.models.hmpps.UpstreamApi
 
 @Component
 class RiskManagementGateway (
-  @Value("\${risk-management-plan-search.base-url}") baseUrl: String,
+  @Value("\${services.risk-management-plan-search.base-url}") baseUrl: String,
 ){
 
   private val webClient = WebClientWrapper(baseUrl)
 
   @Autowired
   lateinit var hmppsAuthGateway: HmppsAuthGateway
 
-  fun getRiskManagementPlansForCrn(crn: String): CrnRiskManagementPlans {
-    return CrnRiskManagementPlans(crn, "plan", emptyList())
+  fun getRiskManagementPlansForCrn(crn: String): Response<CrnRiskManagementPlans> {
+
+    val requestBody =
+      mapOf("crn" to crn)
+
+    val result =
+      webClient.request<CrnRiskManagementPlans>(
+        HttpMethod.GET,
+        "/risks/crn/$crn/risk-management-plan",
+        authenticationHeader(),
+        UpstreamApi.RISK_MANAGEMENT_PLAN,
+        requestBody,
+      )
+    return when (result) {
+      is WebClientWrapper.WebClientWrapperResponse.Success -> {
+        Response(data = result.data, errors = emptyList())
+      }
+
+      is WebClientWrapper.WebClientWrapperResponse.Error -> {
+        Response(
+          data = CrnRiskManagementPlans("", "", emptyList()),
+          errors = result.errors,
+        )
+      }
+    }
+  }
+
+  private fun authenticationHeader(): Map<String, String> {
+    val token = hmppsAuthGateway.getClientToken("Risk Management Plan Search")
+
+    return mapOf(
+      "Authorization" to "Bearer $token",
+    )
   }
 }

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

@@ -10,5 +10,6 @@ enum class UpstreamApi {
   CVL,
   CASE_NOTES,
   MANAGE_POM_CASE,
+  RISK_MANAGEMENT_PLAN,
   TEST,
 }

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

@@ -1,6 +1,7 @@
 package uk.gov.justice.digital.hmpps.hmppsintegrationapi.gateways.riskManagement
 
 import io.kotest.core.spec.style.DescribeSpec
+import io.kotest.matchers.shouldBe
 import org.mockito.Mockito
 import org.mockito.internal.verification.VerificationModeFactory
 import org.mockito.kotlin.verify
@@ -39,20 +40,30 @@ class RiskManagementGatewayTest (
     riskManagementMockServer.stop()
   }
 
-  describe("get risks for given crn") {
+  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(),
-    )
+    beforeEach {
+      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("Risk Management Plan Search")
+    }
+
+    it ("returns a risk management plan when searching with a valid CRN") {
+      val response = riskManagementGateway.getRiskManagementPlansForCrn(crn)
+      val blah = response.data
+      blah.crn.shouldBe(crn)
+      response.data.riskManagementPlan.size.shouldBe(1)
 
-      verify(hmppsAuthGateway, VerificationModeFactory.times(1)).getClientToken("Prisoner Offender Search")
+      response.errors.size.shouldBe(0)
     }
 
   }