From 15fb217573c9253937ada65e2979c7ab220221f9 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Tue, 12 Nov 2024 15:20:18 +0100 Subject: [PATCH] Lagt til midlertidlig JOURNALPOST_ID key (#769) * Lagt til midlertidlig JOURNALPOST_ID key Co-authored-by: Mikael Bjerga * Fikset failing test Co-authored-by: Mikael Bjerga * trigger full deploy --------- Co-authored-by: Mikael Bjerga --- .../db/river/LagreJournalpostIdRiverTest.kt | 3 +++ .../distribusjon/DistribusjonRiverTest.kt | 2 ++ .../kotlin/no/nav/helsearbeidsgiver/felles/Key.kt | 1 + .../felles/rapidsrivers/RiverUtils.kt | 11 +++++++++++ .../inntektsmelding/joark/JournalfoerImRiverTest.kt | 2 ++ 5 files changed, 19 insertions(+) diff --git a/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreJournalpostIdRiverTest.kt b/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreJournalpostIdRiverTest.kt index 242134c74..9e945a83e 100644 --- a/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreJournalpostIdRiverTest.kt +++ b/db/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreJournalpostIdRiverTest.kt @@ -66,6 +66,7 @@ class LagreJournalpostIdRiverTest : Key.INNTEKTSMELDING to innkommendeMelding.inntektsmelding.toJson(Inntektsmelding.serializer()), Key.BESTEMMENDE_FRAVAERSDAG to Mock.bestemmendeFravaersdag.toJson(), Key.JOURNALPOST_ID to innkommendeMelding.journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to innkommendeMelding.journalpostId.toJson(), ) verifySequence { @@ -105,6 +106,7 @@ class LagreJournalpostIdRiverTest : Key.UUID to innkommendeMelding.transaksjonId.toJson(), Key.INNTEKTSMELDING to innkommendeMelding.inntektsmelding.toJson(Inntektsmelding.serializer()), Key.JOURNALPOST_ID to innkommendeMelding.journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to innkommendeMelding.journalpostId.toJson(), ) verifySequence { @@ -245,6 +247,7 @@ private object Mock { Key.EVENT_NAME to eventName.toJson(), Key.UUID to transaksjonId.toJson(), Key.JOURNALPOST_ID to journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to journalpostId.toJson(), Key.INNTEKTSMELDING to inntektsmelding.toJson(Inntektsmelding.serializer()), Key.BESTEMMENDE_FRAVAERSDAG to bestemmendeFravaersdag.toJson(), Key.INNSENDING_ID to INNSENDING_ID.toJson(Long.serializer()), diff --git a/distribusjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiverTest.kt b/distribusjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiverTest.kt index 873cdc746..7a1447f61 100644 --- a/distribusjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiverTest.kt +++ b/distribusjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/distribusjon/DistribusjonRiverTest.kt @@ -61,6 +61,7 @@ class DistribusjonRiverTest : Key.EVENT_NAME to EventName.INNTEKTSMELDING_DISTRIBUERT.toJson(), Key.UUID to innkommendeMelding.transaksjonId.toJson(), Key.JOURNALPOST_ID to innkommendeMelding.journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to innkommendeMelding.journalpostId.toJson(), Key.INNTEKTSMELDING to innkommendeMelding.inntektsmelding.toJson(Inntektsmelding.serializer()), Key.BESTEMMENDE_FRAVAERSDAG to innkommendeMelding.bestemmendeFravaersdag?.toJson(), ).mapValuesNotNull { it } @@ -109,6 +110,7 @@ class DistribusjonRiverTest : Key.EVENT_NAME to EventName.INNTEKTSMELDING_DISTRIBUERT.toJson(), Key.UUID to innkommendeMelding.transaksjonId.toJson(), Key.JOURNALPOST_ID to innkommendeMelding.journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to innkommendeMelding.journalpostId.toJson(), Key.INNTEKTSMELDING to selvbestemtInntektsmelding.toJson(Inntektsmelding.serializer()), ) 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 fd1360081..dbe0bf489 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt @@ -52,6 +52,7 @@ enum class Key( // ulik formattering FORESPOERSEL_ID("forespoerselId"), JOURNALPOST_ID("journalpostId"), + JOURNALPOST_ID_V2("journalpost_id"), ORGNRUNDERENHET("orgnrUnderenhet"), SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"), ; diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt index 25027df5a..385e5de78 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt @@ -8,6 +8,7 @@ import io.micrometer.prometheusmetrics.PrometheusMeterRegistry import kotlinx.serialization.json.JsonElement import kotlinx.serialization.json.JsonNull import no.nav.helsearbeidsgiver.felles.Key +import no.nav.helsearbeidsgiver.utils.collection.mapValuesNotNull import no.nav.helsearbeidsgiver.utils.json.parseJson import no.nav.helsearbeidsgiver.utils.json.toJson @@ -15,6 +16,7 @@ fun MessageContext.publish(vararg messageFields: Pair): JsonEl fun MessageContext.publish(messageFields: Map): JsonElement = messageFields + .mapAddTemporaryJournalpostKey() .mapKeys { (key, _) -> key.toString() } .filterValues { it !is JsonNull } .toJson() @@ -29,3 +31,12 @@ fun MessageContext.publish(messageFields: Map): JsonElement = }.toJson() .also(::publish) .parseJson() + +private fun Map.mapAddTemporaryJournalpostKey(): Map { + // forsikre at this inneholder journalpost + if (!this.containsKey(Key.JOURNALPOST_ID)) { + return this + } + + return this.plus(Key.JOURNALPOST_ID_V2 to this[Key.JOURNALPOST_ID]).mapValuesNotNull { it } +} diff --git a/joark/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt b/joark/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt index b3ecf9485..db10f51b7 100644 --- a/joark/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt +++ b/joark/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/joark/JournalfoerImRiverTest.kt @@ -78,6 +78,7 @@ class JournalfoerImRiverTest : Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(), Key.UUID to innkommendeMelding.transaksjonId.toJson(), Key.JOURNALPOST_ID to journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to journalpostId.toJson(), Key.INNTEKTSMELDING to Mock.inntektsmelding.toJson(Inntektsmelding.serializer()), Key.BESTEMMENDE_FRAVAERSDAG to Mock.bestemmendeFravaersdag.toJson(), Key.INNSENDING_ID to innsendingId.toJson(Long.serializer()), @@ -124,6 +125,7 @@ class JournalfoerImRiverTest : Key.EVENT_NAME to EventName.INNTEKTSMELDING_JOURNALFOERT.toJson(), Key.UUID to innkommendeMelding.transaksjonId.toJson(), Key.JOURNALPOST_ID to journalpostId.toJson(), + Key.JOURNALPOST_ID_V2 to journalpostId.toJson(), Key.INNTEKTSMELDING to Mock.inntektsmelding.toJson(Inntektsmelding.serializer()), )