From b35d9e1685cb4bf5aa1fe7cc62f389477a6a0320 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Mon, 11 Nov 2024 11:03:19 +0100 Subject: [PATCH 1/2] =?UTF-8?q?Endret=20EKSTERN=5FINNTEKTSMELDING=20keys?= =?UTF-8?q?=20fra=20camel=20case=20til=20snake=20case.=20Midlertidlig=20V2?= =?UTF-8?q?=20for=20=C3=A5=20unng=C3=A5=20inflight=20problemer?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Mikael Bjerga --- .../inntektsmelding/brospinn/HentEksternImRiver.kt | 5 ++++- .../inntektsmelding/brospinn/SpinnService.kt | 6 +++++- .../inntektsmelding/brospinn/HentEksternImRiverTest.kt | 8 ++++---- .../inntektsmelding/db/river/HentLagretImRiver.kt | 1 + .../inntektsmelding/db/river/LagreEksternImRiver.kt | 5 ++++- .../inntektsmelding/db/river/HentLagretImRiverTest.kt | 5 +++++ .../main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt | 1 + .../inntektsmelding/innsending/KvitteringService.kt | 7 +++++-- 8 files changed, 29 insertions(+), 9 deletions(-) diff --git a/bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiver.kt b/bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiver.kt index 5e941bfb01..35313fb314 100644 --- a/bro-spinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiver.kt +++ b/bro-spinn/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 index 1f10b3f2f1..c2eafa99b8 100644 --- 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): 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/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiverTest.kt b/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiverTest.kt index 561df8b4fa..c51b7d12ca 100644 --- a/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/HentEksternImRiverTest.kt +++ b/bro-spinn/src/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/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 index f922f11f6f..a3fd3e5d1e 100644 --- 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 index f128ecc8e9..ac4eab1474 100644 --- 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/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiverTest.kt b/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiverTest.kt index f1f550c371..1099fe90dc 100644 --- a/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/HentLagretImRiverTest.kt +++ b/db/src/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 index 9218845989..ee67caef44 100644 --- 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/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt b/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt index 71c442e6e1..cac3c5ae6b 100644 --- a/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt +++ b/innsending/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()), ) From ed1fee7ef5f71c9055d7955c7ff9b9aa27e42673 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Mon, 11 Nov 2024 13:42:25 +0100 Subject: [PATCH 2/2] Oppdaterer integrasjontest Co-authored-by: Mikael Bjerga --- .../inntektsmelding/brospinn/SpinnServiceTest.kt | 1 + 1 file changed, 1 insertion(+) diff --git a/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt b/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt index 8e262c2251..84c127f032 100644 --- a/bro-spinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/brospinn/SpinnServiceTest.kt +++ b/bro-spinn/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(), ) }