Bruk egen event for fullført journalføring (#747)

* Bruk egen event for fullført journalføring * Oppdater integrasjonstest * Oppdater integrasjonstest (igjen)
navikt · Nov 5, 2024 · eb40b71 · eb40b71
1 parent 8b26176
commit eb40b71
Show file tree

Hide file tree

Showing 5 changed files with 17 additions and 21 deletions.
diff --git a/...rc/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiver.kt b/...rc/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiver.kt
@@ -8,6 +8,7 @@ import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.Inntektsmelding
 import no.nav.helsearbeidsgiver.felles.BehovType
 import no.nav.helsearbeidsgiver.felles.EventName
 import no.nav.helsearbeidsgiver.felles.Key
+import no.nav.helsearbeidsgiver.felles.json.krev
 import no.nav.helsearbeidsgiver.felles.json.les
 import no.nav.helsearbeidsgiver.felles.json.lesOrNull
 import no.nav.helsearbeidsgiver.felles.json.toJson
@@ -52,18 +53,13 @@ class DistribusjonRiver(
         ) {
             null
         } else {
-            val eventName = Key.EVENT_NAME.les(EventName.serializer(), json)
-            if (eventName !in setOf(EventName.INNTEKTSMELDING_JOURNALFOERT, EventName.INNTEKTSMELDING_JOURNALPOST_ID_LAGRET)) {
-                null
-            } else {
-                Melding(
-                    eventName = eventName,
-                    transaksjonId = Key.UUID.les(UuidSerializer, json),
-                    inntektsmelding = Key.INNTEKTSMELDING.les(Inntektsmelding.serializer(), json),
-                    bestemmendeFravaersdag = Key.BESTEMMENDE_FRAVAERSDAG.lesOrNull(LocalDateSerializer, json),
-                    journalpostId = Key.JOURNALPOST_ID.les(String.serializer(), json),
-                )
-            }
+            Melding(
+                eventName = Key.EVENT_NAME.krev(EventName.INNTEKTSMELDING_JOURNALPOST_ID_LAGRET, EventName.serializer(), json),
+                transaksjonId = Key.UUID.les(UuidSerializer, json),
+                inntektsmelding = Key.INNTEKTSMELDING.les(Inntektsmelding.serializer(), json),
+                bestemmendeFravaersdag = Key.BESTEMMENDE_FRAVAERSDAG.lesOrNull(LocalDateSerializer, json),
+                journalpostId = Key.JOURNALPOST_ID.les(String.serializer(), json),
+            )
         }
     }
 

diff --git a/...src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt b/...src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt
@@ -92,11 +92,11 @@ class InnsendingIT : EndToEndTest() {
             }
 
         messages
-            .filter(EventName.INNTEKTSMELDING_MOTTATT)
+            .filter(EventName.INNTEKTSMELDING_JOURNALFOERT)
             .filter(BehovType.LAGRE_JOURNALPOST_ID)
             .firstAsMap()
             .also {
-                // Journalført i dokarkiv
+                it shouldContainKey Key.INNTEKTSMELDING
                 it[Key.JOURNALPOST_ID]?.fromJson(String.serializer()) shouldBe Mock.JOURNALPOST_ID
             }
 

diff --git a/...st/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/LagreSelvbestemtIT.kt b/...st/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/LagreSelvbestemtIT.kt
@@ -171,7 +171,7 @@ class LagreSelvbestemtIT : EndToEndTest() {
             .shouldBeEqualToInntektsmelding(nyInntektsmelding)
 
         messages
-            .filter(EventName.SELVBESTEMT_IM_LAGRET)
+            .filter(EventName.INNTEKTSMELDING_JOURNALFOERT)
             .filter(BehovType.LAGRE_JOURNALPOST_ID)
             .firstAsMap()
             .shouldContainNokTilJournalfoeringOgDistribusjon(transaksjonId, nyInntektsmelding, compareType = false)
@@ -244,7 +244,7 @@ class LagreSelvbestemtIT : EndToEndTest() {
             .shouldBeEqualToInntektsmelding(Mock.inntektsmelding, compareType = true)
 
         messages
-            .filter(EventName.SELVBESTEMT_IM_LAGRET)
+            .filter(EventName.INNTEKTSMELDING_JOURNALFOERT)
             .filter(BehovType.LAGRE_JOURNALPOST_ID)
             .firstAsMap()
             .shouldContainNokTilJournalfoeringOgDistribusjon(transaksjonId, Mock.inntektsmelding, compareType = true)
@@ -318,7 +318,7 @@ class LagreSelvbestemtIT : EndToEndTest() {
             .shouldBeEmpty()
 
         messages
-            .filter(EventName.SELVBESTEMT_IM_LAGRET)
+            .filter(EventName.INNTEKTSMELDING_JOURNALFOERT)
             .filter(BehovType.LAGRE_JOURNALPOST_ID)
             .all()
             .shouldBeEmpty()

diff --git a/joark/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiver.kt b/joark/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiver.kt
@@ -82,7 +82,7 @@ class JournalfoerImRiver(
         val journalpostId = opprettOgFerdigstillJournalpost(transaksjonId, inntektsmelding, bestemmendeFravaersdag)
 
         return mapOf(
-            Key.EVENT_NAME to eventName.toJson(),
+            Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(),
             Key.BEHOV to BehovType.LAGRE_JOURNALPOST_ID.toJson(),
             Key.UUID to transaksjonId.toJson(),
             Key.JOURNALPOST_ID to journalpostId.toJson(),

diff --git a/.../src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt b/.../src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt
@@ -75,7 +75,7 @@ class JournalfoerImRiverTest :
 
                 testRapid.firstMessage().toMap() shouldContainExactly
                     mapOf(
-                        Key.EVENT_NAME to innkommendeMelding.eventName.toJson(),
+                        Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(),
                         Key.BEHOV to BehovType.LAGRE_JOURNALPOST_ID.toJson(),
                         Key.UUID to innkommendeMelding.transaksjonId.toJson(),
                         Key.JOURNALPOST_ID to journalpostId.toJson(),
@@ -122,7 +122,7 @@ class JournalfoerImRiverTest :
 
                 testRapid.firstMessage().toMap() shouldContainExactly
                     mapOf(
-                        Key.EVENT_NAME to innkommendeMelding.eventName.toJson(),
+                        Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(),
                         Key.BEHOV to BehovType.LAGRE_JOURNALPOST_ID.toJson(),
                         Key.UUID to innkommendeMelding.transaksjonId.toJson(),
                         Key.JOURNALPOST_ID to journalpostId.toJson(),
@@ -174,7 +174,7 @@ class JournalfoerImRiverTest :
 
             testRapid.firstMessage().toMap() shouldContainExactly
                 mapOf(
-                    Key.EVENT_NAME to innkommendeMelding.eventName.toJson(),
+                    Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(),
                     Key.BEHOV to BehovType.LAGRE_JOURNALPOST_ID.toJson(),
                     Key.UUID to innkommendeMelding.transaksjonId.toJson(),
                     Key.JOURNALPOST_ID to journalpostId.toJson(),