Endret key format for ekstern inntektsmelding

navikt · Nov 11, 2024 · 53e40b6 · 53e40b6
1 parent 7a58f14
commit 53e40b6
Show file tree

Hide file tree

Showing 9 changed files with 30 additions and 9 deletions.
diff --git a/...n/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiver.kt b/...n/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiver.kt
@@ -60,7 +60,10 @@ class HentEksternImRiver(
             Key.DATA to
                 data
                     .plus(
-                        Key.EKSTERN_INNTEKTSMELDING to eksternInntektsmelding.toJson(EksternInntektsmelding.serializer()),
+                        mapOf(
+                            Key.EKSTERN_INNTEKTSMELDING to eksternInntektsmelding.toJson(EksternInntektsmelding.serializer()),
+                            Key.EKSTERN_INNTEKTSMELDING_V2 to eksternInntektsmelding.toJson(EksternInntektsmelding.serializer()),
+                        ),
                     ).toJson(),
         )
     }

diff --git a/bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnService.kt b/bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnService.kt
@@ -7,6 +7,7 @@ import no.nav.helsearbeidsgiver.felles.EventName
 import no.nav.helsearbeidsgiver.felles.Key
 import no.nav.helsearbeidsgiver.felles.domene.EksternInntektsmelding
 import no.nav.helsearbeidsgiver.felles.json.les
+import no.nav.helsearbeidsgiver.felles.json.lesOrNull
 import no.nav.helsearbeidsgiver.felles.json.toJson
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.publish
@@ -50,7 +51,9 @@ class SpinnService(
 
     override fun lesSteg1(melding: Map<Key, JsonElement>): Steg1 =
         Steg1(
-            eksternInntektsmelding = Key.EKSTERN_INNTEKTSMELDING.les(EksternInntektsmelding.serializer(), melding),
+            eksternInntektsmelding =
+                Key.EKSTERN_INNTEKTSMELDING_V2.lesOrNull(EksternInntektsmelding.serializer(), melding)
+                    ?: Key.EKSTERN_INNTEKTSMELDING.les(EksternInntektsmelding.serializer(), melding),
         )
 
     override fun utfoerSteg0(
@@ -94,6 +97,7 @@ class SpinnService(
                         mapOf(
                             Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
                             Key.EKSTERN_INNTEKTSMELDING to steg1.eksternInntektsmelding.toJson(EksternInntektsmelding.serializer()),
+                            Key.EKSTERN_INNTEKTSMELDING_V2 to steg1.eksternInntektsmelding.toJson(EksternInntektsmelding.serializer()),
                         ).toJson(),
                 )
 

diff --git a/...c/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiverTest.kt b/...c/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiverTest.kt
@@ -56,10 +56,10 @@ class HentEksternImRiverTest :
                     Key.DATA to
                         innkommendeMelding.data
                             .plus(
-                                Key.EKSTERN_INNTEKTSMELDING to
-                                    mockEksternInntektsmelding().toJson(
-                                        EksternInntektsmelding.serializer(),
-                                    ),
+                                mapOf(
+                                    Key.EKSTERN_INNTEKTSMELDING to mockEksternInntektsmelding().toJson(EksternInntektsmelding.serializer()),
+                                    Key.EKSTERN_INNTEKTSMELDING_V2 to mockEksternInntektsmelding().toJson(EksternInntektsmelding.serializer()),
+                                ),
                             ).toJson(),
                 )
 

diff --git a/...inn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt b/...inn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt
@@ -64,6 +64,7 @@ class SpinnServiceTest :
                         mapOf(
                             Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
                             Key.EKSTERN_INNTEKTSMELDING to Mock.eksternIm.toJson(EksternInntektsmelding.serializer()),
+                            Key.EKSTERN_INNTEKTSMELDING_V2 to Mock.eksternIm.toJson(EksternInntektsmelding.serializer()),
                         ).toJson(),
                 )
         }

diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiver.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiver.kt
@@ -67,6 +67,7 @@ class HentLagretImRiver(
                         mapOf(
                             Key.LAGRET_INNTEKTSMELDING to inntektsmelding.toJson(ResultJson.serializer()),
                             Key.EKSTERN_INNTEKTSMELDING to eksternInntektsmelding.toJson(ResultJson.serializer()),
+                            Key.EKSTERN_INNTEKTSMELDING_V2 to eksternInntektsmelding.toJson(ResultJson.serializer()),
                         ),
                     ).toJson(),
         )

diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreEksternImRiver.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreEksternImRiver.kt
@@ -6,6 +6,7 @@ import no.nav.helsearbeidsgiver.felles.Key
 import no.nav.helsearbeidsgiver.felles.domene.EksternInntektsmelding
 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
 import no.nav.helsearbeidsgiver.felles.json.toMap
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
@@ -41,7 +42,9 @@ class LagreEksternImRiver(
                 eventName = Key.EVENT_NAME.krev(EventName.EKSTERN_INNTEKTSMELDING_MOTTATT, EventName.serializer(), json),
                 transaksjonId = Key.UUID.les(UuidSerializer, json),
                 forespoerselId = Key.FORESPOERSEL_ID.les(UuidSerializer, data),
-                eksternInntektsmelding = Key.EKSTERN_INNTEKTSMELDING.les(EksternInntektsmelding.serializer(), data),
+                eksternInntektsmelding =
+                    Key.EKSTERN_INNTEKTSMELDING_V2.lesOrNull(EksternInntektsmelding.serializer(), data)
+                        ?: Key.EKSTERN_INNTEKTSMELDING.les(EksternInntektsmelding.serializer(), data),
             )
         }
 

diff --git a/...rc/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiverTest.kt b/...rc/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiverTest.kt
@@ -82,6 +82,11 @@ class HentLagretImRiverTest :
                                                 ?.toJson(EksternInntektsmelding.serializer())
                                                 ?.toSuccessJson()
                                                 .orDefault(MockHentIm.tomResultJson()),
+                                        Key.EKSTERN_INNTEKTSMELDING_V2 to
+                                            lagret.second
+                                                ?.toJson(EksternInntektsmelding.serializer())
+                                                ?.toSuccessJson()
+                                                .orDefault(MockHentIm.tomResultJson()),
                                     ),
                                 ).toJson(),
                     )

diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt
@@ -49,6 +49,7 @@ enum class Key(
 
     // ulik formattering
     EKSTERN_INNTEKTSMELDING("eksternInntektsmelding"),
+    EKSTERN_INNTEKTSMELDING_V2("ekstern_inntektsmelding"),
     FORESPOERSEL_ID("forespoerselId"),
     FORESPOERSEL_SVAR("forespoersel-svar"),
     JOURNALPOST_ID("journalpostId"),

diff --git a/.../src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt b/.../src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt
@@ -10,6 +10,7 @@ import no.nav.helsearbeidsgiver.felles.domene.EksternInntektsmelding
 import no.nav.helsearbeidsgiver.felles.domene.InnsendtInntektsmelding
 import no.nav.helsearbeidsgiver.felles.domene.ResultJson
 import no.nav.helsearbeidsgiver.felles.json.les
+import no.nav.helsearbeidsgiver.felles.json.lesOrNull
 import no.nav.helsearbeidsgiver.felles.json.toJson
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.publish
@@ -23,6 +24,7 @@ import no.nav.helsearbeidsgiver.utils.json.toPretty
 import no.nav.helsearbeidsgiver.utils.log.MdcUtils
 import no.nav.helsearbeidsgiver.utils.log.logger
 import no.nav.helsearbeidsgiver.utils.log.sikkerLogger
+import no.nav.helsearbeidsgiver.utils.pipe.orDefault
 import java.util.UUID
 
 class KvitteringService(
@@ -58,8 +60,9 @@ class KvitteringService(
                     .success
                     ?.fromJson(Inntektsmelding.serializer()),
             eksternInntektsmelding =
-                Key.EKSTERN_INNTEKTSMELDING
-                    .les(ResultJson.serializer(), melding)
+                Key.EKSTERN_INNTEKTSMELDING_V2
+                    .lesOrNull(ResultJson.serializer(), melding)
+                    .orDefault(Key.EKSTERN_INNTEKTSMELDING.les(ResultJson.serializer(), melding))
                     .success
                     ?.fromJson(EksternInntektsmelding.serializer()),
         )