Hindre flytting mellom samarbeid av behovsvurderinger som ikke er AVS…

…LUTTET

Sende til Salesforce behovsvurdering som har blitt flyttet

Co-authored-by: Nima Jimale <nima.jimale@nav.no>

.github/workflows/main.yaml

@@ -65,7 +65,7 @@ jobs:
       id-token: write
     name: Deploy app to dev
     needs: build
-    if: github.ref == 'refs/heads/nye-undertemaer'
+    if: github.ref == 'refs/heads/sende-melding-til-sf-ved-flytt-behovsv'
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4

src/main/kotlin/no/nav/lydia/ia/sak/SpørreundersøkelseService.kt

@@ -289,7 +289,7 @@ class SpørreundersøkelseService(
         )
     }
 
-    fun oppdaterBehovsvurdering(
+    fun oppdaterSamarbeidIdIBehovsvurdering(
         behovsvurderingId: String,
         oppdaterBehovsvurderingDto: OppdaterBehovsvurderingDto,
     ): Either<Feil, Spørreundersøkelse> {
@@ -301,8 +301,11 @@ class SpørreundersøkelseService(
         if (behovsvurdering.saksnummer != oppdaterBehovsvurderingDto.saksnummer) {
             return IASakSpørreundersøkelseError.`feil under oppdatering`.left()
         }
+        if (behovsvurdering.status != AVSLUTTET) {
+            return IASakSpørreundersøkelseError.`ikke avsluttet, kan ikke bytte samarbeid`.left()
+        }
 
-        return iaSakService.hentIASak(behovsvurdering.saksnummer).flatMap {
+        val oppdatertBehovsvurdering = iaSakService.hentIASak(behovsvurdering.saksnummer).flatMap {
             iaProsessService.hentIAProsesser(it)
         }.map { prosess ->
             prosess.map { it.id }
@@ -313,6 +316,13 @@ class SpørreundersøkelseService(
                 IASakSpørreundersøkelseError.`feil under oppdatering`.left()
             }
         }
+
+        oppdatertBehovsvurdering.getOrNull()?.let { oppdatertSpørreundersøkelse ->
+            if (oppdatertSpørreundersøkelse.status == AVSLUTTET) {
+                spørreundersøkelseObservers.forEach { it.receive(oppdatertSpørreundersøkelse) }
+            }
+        }
+        return oppdatertBehovsvurdering
     }
 
     private fun sendResultaterForTemaPåKafka(

src/main/kotlin/no/nav/lydia/ia/sak/api/spørreundersøkelse/SpørreundersøkelseRoutes.kt

@@ -205,7 +205,10 @@ fun Route.iaSakSpørreundersøkelse(
         val input = call.receive<OppdaterBehovsvurderingDto>()
 
         call.somSaksbehandler(adGrupper) {
-            spørreundersøkelseService.oppdaterBehovsvurdering(id, input)
+            spørreundersøkelseService.oppdaterSamarbeidIdIBehovsvurdering(
+                behovsvurderingId = id,
+                oppdaterBehovsvurderingDto = input,
+            )
         }.also { spørreundersøkelseEither ->
             auditLog.auditloggEither(
                 call = call,
@@ -251,7 +254,15 @@ object IASakSpørreundersøkelseError {
     val `feil status kan ikke starte` =
         Feil("Kan ikke starte spørreundersøkelse, feil status", HttpStatusCode.Forbidden)
     val `ikke avsluttet` =
-        Feil("Spørreundersøkelse er ikke i status '${AVSLUTTET.name}', kan ikke hente resultat", HttpStatusCode.Forbidden)
+        Feil(
+            "Spørreundersøkelse er ikke i status '${AVSLUTTET.name}', kan ikke hente resultat",
+            HttpStatusCode.Forbidden,
+        )
+    val `ikke avsluttet, kan ikke bytte samarbeid` =
+        Feil(
+            "Spørreundersøkelse er ikke i status '${AVSLUTTET.name}', kan ikke bytte samarbeid",
+            HttpStatusCode.BadRequest,
+        )
     val `generell feil under uthenting` =
         Feil("Generell feil under uthenting av en spørreundersøkelse", HttpStatusCode.InternalServerError)
     val `feil under oppdatering` =

src/test/kotlin/no/nav/lydia/container/ia/sak/kartlegging/BehovsvurderingApiTest.kt

@@ -12,6 +12,7 @@ import io.kotest.matchers.collections.shouldHaveSize
 import io.kotest.matchers.collections.shouldNotBeEmpty
 import io.kotest.matchers.shouldBe
 import io.kotest.matchers.shouldNotBe
+import io.kotest.matchers.string.shouldContain
 import io.kotest.matchers.string.shouldMatch
 import io.kotest.matchers.string.shouldNotBeEmpty
 import io.ktor.http.HttpStatusCode
@@ -39,6 +40,7 @@ import no.nav.lydia.helper.forExactlyOne
 import no.nav.lydia.helper.hentAlleSamarbeid
 import no.nav.lydia.helper.opprettNyttSamarbeid
 import no.nav.lydia.helper.tilSingelRespons
+import no.nav.lydia.ia.eksport.FullførtBehovsvurdering
 import no.nav.lydia.ia.eksport.SpørreundersøkelseProdusent.SerializableSpørreundersøkelse
 import no.nav.lydia.ia.sak.api.spørreundersøkelse.SPØRREUNDERSØKELSE_BASE_ROUTE
 import no.nav.lydia.ia.sak.api.spørreundersøkelse.SpørreundersøkelseDto
@@ -49,14 +51,18 @@ import kotlin.test.Test
 
 class BehovsvurderingApiTest {
     private val spørreundersøkelseKonsument = kafkaContainerHelper.nyKonsument(this::class.java.name)
+    private val fullførtBehovsvurderingKonsument = kafkaContainerHelper.nyKonsument(this::class.java.name)
 
     @Before
     fun setUp() {
         spørreundersøkelseKonsument.subscribe(mutableListOf(Topic.SPORREUNDERSOKELSE_TOPIC.navn))
+        fullførtBehovsvurderingKonsument.subscribe(mutableListOf(Topic.FULLFØRT_BEHOVSVURDERING_TOPIC.navn))
     }
 
     @After
     fun tearDown() {
+        fullførtBehovsvurderingKonsument.unsubscribe()
+        fullførtBehovsvurderingKonsument.close()
         spørreundersøkelseKonsument.unsubscribe()
         spørreundersøkelseKonsument.close()
     }
@@ -583,14 +589,58 @@ class BehovsvurderingApiTest {
         val behovsvurdering = sak.opprettSpørreundersøkelse(prosessId = førsteSamarbeid.id)
         hentSpørreundersøkelse(sak.orgnr, sak.saksnummer, førsteSamarbeid.id, type = "Behovsvurdering")
             .map { it.id } shouldBe listOf(behovsvurdering.id)
+        behovsvurdering.start(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
+        behovsvurdering.avslutt(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
 
         oppdaterBehovsvurdering(behovsvurdering, sak, sisteSamarbeid.id)
+
         hentSpørreundersøkelse(sak.orgnr, sak.saksnummer, førsteSamarbeid.id, type = "Behovsvurdering")
             .map { it.id } shouldBe emptyList()
         hentSpørreundersøkelse(sak.orgnr, sak.saksnummer, sisteSamarbeid.id, type = "Behovsvurdering")
             .map { it.id } shouldBe listOf(behovsvurdering.id)
     }
 
+    @Test
+    fun `skal sende på nytt til SF en Kafka melding om at en fullført behhovsvurdering er flyttet`() {
+        val sak = nySakIKartlegges()
+            .opprettNyttSamarbeid(navn = "Først")
+            .opprettNyttSamarbeid(navn = "Sist")
+        val alleSamarbeid = sak.hentAlleSamarbeid()
+        val førsteSamarbeid = alleSamarbeid.first()
+        val sisteSamarbeid = alleSamarbeid.last()
+
+        val behovsvurdering = sak.opprettSpørreundersøkelse(prosessId = førsteSamarbeid.id)
+        behovsvurdering.start(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
+        behovsvurdering.avslutt(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
+        runBlocking {
+            kafkaContainerHelper.ventOgKonsumerKafkaMeldinger(
+                key = behovsvurdering.id,
+                konsument = fullførtBehovsvurderingKonsument,
+            ) {
+                it.forExactlyOne { melding ->
+                    val behovsvurderingIKafkaMelding = Json.decodeFromString<FullførtBehovsvurdering>(melding)
+                    behovsvurderingIKafkaMelding.behovsvurderingId shouldBe behovsvurdering.id
+                    behovsvurderingIKafkaMelding.prosessId shouldBe førsteSamarbeid.id.toString()
+                }
+            }
+        }
+
+        oppdaterBehovsvurdering(behovsvurdering, sak, sisteSamarbeid.id)
+
+        runBlocking {
+            kafkaContainerHelper.ventOgKonsumerKafkaMeldinger(
+                key = behovsvurdering.id,
+                konsument = fullførtBehovsvurderingKonsument,
+            ) {
+                it.forExactlyOne { melding ->
+                    val behovsvurderingIKafkaMelding = Json.decodeFromString<FullførtBehovsvurdering>(melding)
+                    behovsvurderingIKafkaMelding.behovsvurderingId shouldBe behovsvurdering.id
+                    behovsvurderingIKafkaMelding.prosessId shouldBe sisteSamarbeid.id.toString()
+                }
+            }
+        }
+    }
+
     @Test
     fun `skal ikke kunne flytte kartlegging en ugyldig prosess eller som lesebruker`() {
         val sak = nySakIKartlegges()
@@ -623,7 +673,7 @@ class BehovsvurderingApiTest {
     }
 
     @Test
-    fun `skal kunne avslutte en flyttet behovsvurdering`() {
+    fun `skal IKKE kunne flytte en behovsvurdering som ikke er avsluttet (fullført)`() {
         val sak = nySakIKartlegges()
             .opprettNyttSamarbeid(navn = "Først")
             .opprettNyttSamarbeid(navn = "Sist")
@@ -637,23 +687,22 @@ class BehovsvurderingApiTest {
         val behovsvurdering = sak.opprettSpørreundersøkelse(prosessId = førsteSamarbeid.id)
         behovsvurdering.start(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
 
-        val flyttetBehovsvurdering = oppdaterBehovsvurdering(behovsvurdering, sak, andreSamarbeid.id)
-        flyttetBehovsvurdering.avslutt(orgnummer = sak.orgnr, saksnummer = sak.saksnummer)
+        shouldFail { oppdaterBehovsvurdering(behovsvurdering, sak, andreSamarbeid.id) }.message shouldContain "kan ikke bytte samarbeid"
 
         hentSpørreundersøkelse(
             orgnr = sak.orgnr,
             saksnummer = sak.saksnummer,
-            prosessId = andreSamarbeid.id,
+            prosessId = førsteSamarbeid.id,
             type = "Behovsvurdering",
         ).forExactlyOne {
-            it.status shouldBe AVSLUTTET
-            it.samarbeidId shouldBe andreSamarbeid.id
+            it.status shouldBe PÅBEGYNT
+            it.samarbeidId shouldBe førsteSamarbeid.id
         }
 
         hentSpørreundersøkelse(
             orgnr = sak.orgnr,
             saksnummer = sak.saksnummer,
-            prosessId = førsteSamarbeid.id,
+            prosessId = andreSamarbeid.id,
             type = "Behovsvurdering",
         ) shouldHaveSize 0
     }