Les nested data fra melding om mottatt IM

navikt · Nov 20, 2024 · af32955 · af32955
1 parent 2996851
commit af32955
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 25 deletions.
diff --git a/...searbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt b/...searbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt
@@ -223,7 +223,6 @@ class BerikInntektsmeldingService(
                             Key.BESTEMMENDE_FRAVAERSDAG to steg4.bestemmendeFravaersdag.toJson(),
                             Key.INNSENDING_ID to steg0.innsendingId.toJson(Long.serializer()),
                         ).toJson(),
-                    Key.INNSENDING_ID to steg0.innsendingId.toJson(Long.serializer()),
                 )
 
             MdcUtils.withLogFields(

diff --git a/...earbeidsgiver/inntektsmelding/forespoerselmarkerbesvart/MarkerForespoerselBesvartRiver.kt b/...earbeidsgiver/inntektsmelding/forespoerselmarkerbesvart/MarkerForespoerselBesvartRiver.kt
@@ -5,7 +5,6 @@ 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.toMap
 import no.nav.helsearbeidsgiver.felles.json.toPretty
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.pritopic.Pri
@@ -40,7 +39,7 @@ class MarkerForespoerselBesvartRiver(
             Melding(
                 eventName = Key.EVENT_NAME.krev(EventName.INNTEKTSMELDING_MOTTATT, EventName.serializer(), json),
                 transaksjonId = Key.UUID.les(UuidSerializer, json),
-                forespoerselId = Key.FORESPOERSEL_ID.lesOrNull(UuidSerializer, json) ?: Key.FORESPOERSEL_ID.les(UuidSerializer, data),
+                forespoerselId = Key.FORESPOERSEL_ID.les(UuidSerializer, data),
             )
         }
 

diff --git a/...eidsgiver/inntektsmelding/forespoerselmarkerbesvart/MarkerForespoerselBesvartRiverTest.kt b/...eidsgiver/inntektsmelding/forespoerselmarkerbesvart/MarkerForespoerselBesvartRiverTest.kt
@@ -43,7 +43,10 @@ class MarkerForespoerselBesvartRiverTest :
             testRapid.sendJson(
                 Key.EVENT_NAME to EventName.INNTEKTSMELDING_MOTTATT.toJson(),
                 Key.UUID to UUID.randomUUID().toJson(),
-                Key.FORESPOERSEL_ID to expectedForespoerselId.toJson(),
+                Key.DATA to
+                    mapOf(
+                        Key.FORESPOERSEL_ID to expectedForespoerselId.toJson(),
+                    ).toJson(),
             )
 
             testRapid.inspektør.size shouldBeExactly 0

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
@@ -51,21 +51,15 @@ class JournalfoerImRiver(
                     JournalfoerImMelding(
                         eventName = eventName,
                         transaksjonId = transaksjonId,
-                        inntektsmelding =
-                            Key.INNTEKTSMELDING.lesOrNull(Inntektsmelding.serializer(), json)
-                                ?: Key.INNTEKTSMELDING.les(Inntektsmelding.serializer(), data),
-                        bestemmendeFravaersdag =
-                            Key.BESTEMMENDE_FRAVAERSDAG.lesOrNull(LocalDateSerializer, json)
-                                ?: Key.BESTEMMENDE_FRAVAERSDAG.lesOrNull(LocalDateSerializer, data),
+                        inntektsmelding = Key.INNTEKTSMELDING.les(Inntektsmelding.serializer(), data),
+                        bestemmendeFravaersdag = Key.BESTEMMENDE_FRAVAERSDAG.lesOrNull(LocalDateSerializer, data),
                     )
 
                 EventName.SELVBESTEMT_IM_LAGRET ->
                     JournalfoerImMelding(
                         eventName = eventName,
                         transaksjonId = transaksjonId,
-                        inntektsmelding =
-                            Key.SELVBESTEMT_INNTEKTSMELDING.lesOrNull(Inntektsmelding.serializer(), json)
-                                ?: Key.SELVBESTEMT_INNTEKTSMELDING.les(Inntektsmelding.serializer(), data),
+                        inntektsmelding = Key.SELVBESTEMT_INNTEKTSMELDING.les(Inntektsmelding.serializer(), data),
                         bestemmendeFravaersdag = null,
                     )
 
@@ -88,7 +82,7 @@ class JournalfoerImRiver(
             Key.JOURNALPOST_ID to journalpostId.toJson(),
             Key.INNTEKTSMELDING to inntektsmelding.toJson(Inntektsmelding.serializer()),
             Key.BESTEMMENDE_FRAVAERSDAG to bestemmendeFravaersdag?.toJson(),
-            Key.INNSENDING_ID to (json[Key.INNSENDING_ID] ?: json[Key.DATA]?.toMap().orEmpty()[Key.INNSENDING_ID]),
+            Key.INNSENDING_ID to json[Key.DATA]?.toMap()?.get(Key.INNSENDING_ID),
         ).mapValuesNotNull { it }
             .also {
                 logger.info("Publiserte melding med event '${EventName.INNTEKTSMELDING_JOURNALFOERT}' og journalpost-ID '$journalpostId'.")
@@ -112,10 +106,7 @@ class JournalfoerImRiver(
         logger.error(fail.feilmelding)
         sikkerLogger.error(fail.feilmelding, error)
 
-        return fail
-            .tilMelding()
-            .plus(Key.INNSENDING_ID to json[Key.INNSENDING_ID])
-            .mapValuesNotNull { it }
+        return fail.tilMelding()
     }
 
     override fun JournalfoerImMelding.loggfelt(): Map<String, String> =

diff --git a/.../src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt b/.../src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt
@@ -26,6 +26,7 @@ import no.nav.helsearbeidsgiver.felles.Key
 import no.nav.helsearbeidsgiver.felles.json.toJson
 import no.nav.helsearbeidsgiver.felles.json.toMap
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
+import no.nav.helsearbeidsgiver.felles.test.json.plusData
 import no.nav.helsearbeidsgiver.felles.test.mock.mockInntektsmeldingV1
 import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage
 import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson
@@ -64,10 +65,8 @@ class JournalfoerImRiverTest :
                 testRapid.sendJson(
                     innkommendeMelding
                         .toMap()
-                        .plus(
-                            mapOf(
-                                Key.INNSENDING_ID to innsendingId.toJson(Long.serializer()),
-                            ),
+                        .plusData(
+                            Key.INNSENDING_ID to innsendingId.toJson(Long.serializer()),
                         ),
                 )
 
@@ -232,9 +231,13 @@ private object Mock {
         mapOf(
             Key.EVENT_NAME to eventName.toJson(),
             Key.UUID to transaksjonId.toJson(),
-            imKey to inntektsmelding.toJson(Inntektsmelding.serializer()),
-            Key.BESTEMMENDE_FRAVAERSDAG to bestemmendeFravaersdag?.toJson(),
-        ).mapValuesNotNull { it }
+            Key.DATA to
+                mapOf(
+                    imKey to inntektsmelding.toJson(Inntektsmelding.serializer()),
+                    Key.BESTEMMENDE_FRAVAERSDAG to bestemmendeFravaersdag?.toJson(),
+                ).mapValuesNotNull { it }
+                    .toJson(),
+        )
 
     fun opprettOgFerdigstillResponse(journalpostId: String): OpprettOgFerdigstillResponse =
         OpprettOgFerdigstillResponse(