Ikke lagre selvbestemt IM som ekstern IM

bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnService.kt

@@ -20,8 +20,8 @@ import no.nav.helsearbeidsgiver.utils.log.logger
 import no.nav.helsearbeidsgiver.utils.log.sikkerLogger
 import java.util.UUID
 
-// TODO også sjekk "NAV_NO_SELVBESTEMT"
 private const val AVSENDER_NAV_NO = "NAV_NO"
+private const val AVSENDER_NAV_NO_SELVBESTEMT = "NAV_NO_SELVBESTEMT"
 
 data class Steg0(
     val transaksjonId: UUID,
@@ -85,7 +85,7 @@ class SpinnService(
         steg0: Steg0,
         steg1: Steg1,
     ) {
-        if (steg1.eksternInntektsmelding.avsenderSystemNavn != AVSENDER_NAV_NO) {
+        if (steg1.eksternInntektsmelding.avsenderSystemNavn !in setOf(AVSENDER_NAV_NO, AVSENDER_NAV_NO_SELVBESTEMT)) {
             val publisert =
                 rapid.publish(
                     Key.EVENT_NAME to EventName.EKSTERN_INNTEKTSMELDING_MOTTATT.toJson(),

bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt

@@ -2,21 +2,24 @@ package no.nav.helsearbeidsgiver.inntektsmelding.brospinn
 
 import com.github.navikt.tbd_libs.rapids_and_rivers.test_support.TestRapid
 import io.kotest.core.spec.style.FunSpec
+import io.kotest.datatest.withData
 import io.kotest.matchers.ints.shouldBeExactly
-import io.kotest.matchers.nulls.shouldNotBeNull
-import io.kotest.matchers.shouldBe
+import io.kotest.matchers.maps.shouldContainExactly
 import io.mockk.clearAllMocks
+import kotlinx.serialization.json.JsonElement
 import no.nav.helsearbeidsgiver.felles.BehovType
 import no.nav.helsearbeidsgiver.felles.EventName
 import no.nav.helsearbeidsgiver.felles.Key
-import no.nav.helsearbeidsgiver.felles.json.les
+import no.nav.helsearbeidsgiver.felles.domene.EksternInntektsmelding
 import no.nav.helsearbeidsgiver.felles.json.toJson
 import no.nav.helsearbeidsgiver.felles.json.toMap
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceRiverStateless
+import no.nav.helsearbeidsgiver.felles.test.json.plusData
 import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage
+import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.message
 import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson
-import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
 import no.nav.helsearbeidsgiver.utils.json.toJson
+import java.time.LocalDateTime
 import java.util.UUID
 
 class SpinnServiceTest :
@@ -27,34 +30,96 @@ class SpinnServiceTest :
             SpinnService(testRapid),
         ).connect(testRapid)
 
-        beforeEach {
+        beforeTest {
             testRapid.reset()
             clearAllMocks()
         }
 
-        test("Publiser nytt behov med inntektsmeldingId ved nytt event") {
+        test("publiser mottatt-event for inntektsmelding fra LPS/Altinn") {
+            testRapid.sendJson(Mock.steg0())
 
-            testRapid.sendJson(
-                Key.EVENT_NAME to EventName.EKSTERN_INNTEKTSMELDING_REQUESTED.toJson(),
-                Key.UUID to Mock.transaksjonId.toJson(),
-                Key.DATA to
-                    mapOf(
-                        Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
-                        Key.SPINN_INNTEKTSMELDING_ID to Mock.spinnInntektsmeldingId.toJson(),
-                    ).toJson(),
-            )
+            testRapid.inspektør.size shouldBeExactly 1
 
-            val actual = testRapid.firstMessage().toMap()
-            val actualData = actual[Key.DATA].shouldNotBeNull().toMap()
+            testRapid.firstMessage().toMap() shouldContainExactly
+                mapOf(
+                    Key.EVENT_NAME to EventName.EKSTERN_INNTEKTSMELDING_REQUESTED.toJson(),
+                    Key.BEHOV to BehovType.HENT_EKSTERN_INNTEKTSMELDING.toJson(),
+                    Key.UUID to Mock.transaksjonId.toJson(),
+                    Key.DATA to
+                        mapOf(
+                            Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
+                            Key.SPINN_INNTEKTSMELDING_ID to Mock.spinnInntektsmeldingId.toJson(),
+                        ).toJson(),
+                )
 
-            testRapid.inspektør.size shouldBeExactly 1
-            Key.BEHOV.les(BehovType.serializer(), actual) shouldBe BehovType.HENT_EKSTERN_INNTEKTSMELDING
-            Key.SPINN_INNTEKTSMELDING_ID.les(UuidSerializer, actualData) shouldBe Mock.spinnInntektsmeldingId
+            testRapid.sendJson(Mock.steg1())
+
+            testRapid.inspektør.size shouldBeExactly 2
+
+            testRapid.message(1).toMap() shouldContainExactly
+                mapOf(
+                    Key.EVENT_NAME to EventName.EKSTERN_INNTEKTSMELDING_MOTTATT.toJson(),
+                    Key.UUID to Mock.transaksjonId.toJson(),
+                    Key.DATA to
+                        mapOf(
+                            Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
+                            Key.EKSTERN_INNTEKTSMELDING to Mock.eksternIm.toJson(EksternInntektsmelding.serializer()),
+                        ).toJson(),
+                )
+        }
+
+        context("publiserer ikke mottatt-event for ...") {
+            withData(
+                mapOf(
+                    "forespurt inntektsmelding fra nav.no" to "NAV_NO",
+                    "selvbestemt inntektsmelding fra nav.no" to "NAV_NO_SELVBESTEMT",
+                ),
+            ) { avsenderSystemNavn ->
+                val imFraNavNo =
+                    Mock.eksternIm.copy(
+                        avsenderSystemNavn = avsenderSystemNavn,
+                    )
+
+                testRapid.sendJson(Mock.steg0())
+
+                testRapid.inspektør.size shouldBeExactly 1
+
+                testRapid.sendJson(
+                    Mock
+                        .steg1()
+                        .plusData(Key.EKSTERN_INNTEKTSMELDING to imFraNavNo.toJson(EksternInntektsmelding.serializer())),
+                )
+
+                testRapid.inspektør.size shouldBeExactly 1
+            }
         }
     })
 
 private object Mock {
     val transaksjonId: UUID = UUID.randomUUID()
     val forespoerselId: UUID = UUID.randomUUID()
     val spinnInntektsmeldingId: UUID = UUID.randomUUID()
+    val eksternIm =
+        EksternInntektsmelding(
+            avsenderSystemNavn = "LittPengeSvindel",
+            avsenderSystemVersjon = "den andre versjonen",
+            arkivreferanse = "archivo apostolico",
+            tidspunkt = LocalDateTime.now(),
+        )
+
+    fun steg0(): Map<Key, JsonElement> =
+        mapOf(
+            Key.EVENT_NAME to EventName.EKSTERN_INNTEKTSMELDING_REQUESTED.toJson(),
+            Key.UUID to transaksjonId.toJson(),
+            Key.DATA to
+                mapOf(
+                    Key.FORESPOERSEL_ID to forespoerselId.toJson(),
+                    Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId.toJson(),
+                ).toJson(),
+        )
+
+    fun steg1(): Map<Key, JsonElement> =
+        steg0().plusData(
+            Key.EKSTERN_INNTEKTSMELDING to eksternIm.toJson(EksternInntektsmelding.serializer()),
+        )
 }