diff --git a/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt b/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt index 99e88a47f..e2e27a770 100644 --- a/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt +++ b/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt @@ -23,7 +23,6 @@ import no.nav.helsearbeidsgiver.felles.json.toMap import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson -import no.nav.helsearbeidsgiver.felles.test.shouldContainAllExcludingTempKey import no.nav.helsearbeidsgiver.inntektsmelding.altinn.MockTilgang.toMap import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.test.wrapper.genererGyldig @@ -58,7 +57,7 @@ class TilgangRiverTest : testRapid.inspektør.size shouldBeExactly 1 - testRapid.firstMessage().toMap() shouldContainAllExcludingTempKey + testRapid.firstMessage().toMap() shouldContainExactly mapOf( Key.EVENT_NAME to innkommendeMelding.eventName.toJson(), Key.KONTEKST_ID to innkommendeMelding.transaksjonId.toJson(), diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt index 7085f84aa..8ae641e94 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt @@ -38,7 +38,6 @@ class InntektSelvbestemtProducerTest : mapOf( Key.FNR to sykmeldtFnr.toJson(), Key.ORGNRUNDERENHET to orgnr.toJson(), - Key.ORGNRUNDERENHET_V2 to orgnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ).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 f9785e2fc..8cc2d13b0 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt @@ -50,10 +50,9 @@ enum class Key( VEDTAKSPERIODE_ID_LISTE("vedtaksperiode_id_liste"), VIRKSOMHET("virksomhet"), VIRKSOMHETER("virksomheter"), + ORGNRUNDERENHET("orgnr_underenhet"), // ulik formattering - ORGNRUNDERENHET("orgnrUnderenhet"), - ORGNRUNDERENHET_V2("orgnr_underenhet"), 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 8cb7de709..25027df5a 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,9 +8,6 @@ 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.felles.json.toJson -import no.nav.helsearbeidsgiver.felles.json.toMap -import no.nav.helsearbeidsgiver.utils.collection.mapValuesNotNull import no.nav.helsearbeidsgiver.utils.json.parseJson import no.nav.helsearbeidsgiver.utils.json.toJson @@ -18,18 +15,7 @@ fun MessageContext.publish(vararg messageFields: Pair): JsonEl fun MessageContext.publish(messageFields: Map): JsonElement = messageFields - .let { root -> - val data = root[Key.DATA]?.toMap().orEmpty() - val newData = - data - .plus(Key.ORGNRUNDERENHET_V2 to data[Key.ORGNRUNDERENHET]) - .mapValuesNotNull { it } - .ifEmpty { null } - root - .plus(Key.ORGNRUNDERENHET_V2 to root[Key.ORGNRUNDERENHET]) - .plus(Key.DATA to newData?.toJson()) - .mapValuesNotNull { it } - }.mapKeys { (key, _) -> key.toString() } + .mapKeys { (key, _) -> key.toString() } .filterValues { it !is JsonNull } .toJson() .toString() diff --git a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt index 5de6893db..6934441a1 100644 --- a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt +++ b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt @@ -84,99 +84,5 @@ class RiverUtilsKtTest : ) } } - - test("duplikert verdi i ORGNRUNDERENHET_V2 nøkkel") { - - val verdi = ("unik ORGNRUNDERENHET verdi " + UUID.randomUUID().toString()).toJson() - - val melding = - mapOf( - Key.FORESPOERSEL_ID to UUID.randomUUID().toJson(), - Key.ORGNRUNDERENHET to verdi, - ) - - testRapid.publish(melding) - - verifySequence { - testRapid.publish( - withArg { - it.parseJson().toMap() shouldContainExactly melding.plus(Key.ORGNRUNDERENHET_V2 to verdi) - }, - ) - } - } - - test("duplikert verdi i Data MapOf i ORGNRUNDERENHET_V2 nøkkel") { - - val verdi = ("unik ORGNRUNDERENHET verdi " + UUID.randomUUID().toString()).toJson() - - val melding = - mapOf( - Key.FORESPOERSEL_ID to UUID.randomUUID().toJson(), - Key.DATA to - mapOf( - Key.ORGNRUNDERENHET to verdi, - ).toJson(), - ) - - testRapid.publish(melding) - - val meldingMedDuplikert = - melding.plus( - Key.DATA to - mapOf( - Key.ORGNRUNDERENHET to verdi, - Key.ORGNRUNDERENHET_V2 to verdi, - ).toJson(), - ) - - verifySequence { - testRapid.publish( - withArg { - it.parseJson().toMap() shouldContainExactly meldingMedDuplikert - }, - ) - } - } - - test("duplikert verdi i nøkkel og Data MapOf nøkkel") { - - val verdi = ("unik ORGNRUNDERENHET verdi " + UUID.randomUUID().toString()).toJson() - val id = Key.FORESPOERSEL_ID to UUID.randomUUID().toJson() - - val melding = - mapOf( - id, - Key.ORGNRUNDERENHET to verdi, - Key.DATA to - mapOf( - Key.ORGNRUNDERENHET to verdi, - ).toJson(), - ) - - testRapid.publish(melding) - - val meldingMedDuplikert = - mapOf( - id, - Key.ORGNRUNDERENHET to verdi, - Key.ORGNRUNDERENHET to verdi, - Key.ORGNRUNDERENHET_V2 to verdi, - Key.DATA to - mapOf( - Key.ORGNRUNDERENHET to verdi, - Key.ORGNRUNDERENHET_V2 to verdi, - ).toJson(), - ) - - verifySequence { - testRapid.publish( - withArg { - - it.parseJson().toMap() shouldContainExactly meldingMedDuplikert - }, - ) - } - } } }) diff --git a/felles/src/testFixtures/kotlin/Temp.kt b/felles/src/testFixtures/kotlin/Temp.kt deleted file mode 100644 index afb767ded..000000000 --- a/felles/src/testFixtures/kotlin/Temp.kt +++ /dev/null @@ -1,10 +0,0 @@ -package no.nav.helsearbeidsgiver.felles.test -import io.kotest.matchers.maps.shouldContainAll -import kotlinx.serialization.json.JsonElement -import no.nav.helsearbeidsgiver.felles.Key -import no.nav.helsearbeidsgiver.felles.json.toMap - -infix fun Map.shouldContainAllExcludingTempKey(expected: Map) { - this.minus(Key.DATA) shouldContainAll expected.minus(Key.DATA) - this[Key.DATA]?.toMap().orEmpty() shouldContainAll expected[Key.DATA]?.toMap().orEmpty() -} diff --git a/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt b/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt index fed923a20..14b81518c 100644 --- a/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt +++ b/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt @@ -25,7 +25,6 @@ import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson import no.nav.helsearbeidsgiver.inntekt.InntektKlient import no.nav.helsearbeidsgiver.inntektsmelding.inntekt.Mock.toMap import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.pipe.orDefault import no.nav.helsearbeidsgiver.utils.test.date.april import no.nav.helsearbeidsgiver.utils.test.date.august import no.nav.helsearbeidsgiver.utils.test.date.januar @@ -108,15 +107,7 @@ class HentInntektRiverTest : Key.DATA to innkommendeMelding.data .plus(Key.INNTEKT to forventetInntekt.toJson(Inntekt.serializer())) - .let { - val verdi = innkommendeMelding.data[Key.ORGNRUNDERENHET].orDefault(JsonNull) - - if (innkommendeMelding.data.containsKey(Key.ORGNRUNDERENHET)) { - it.plus(Key.ORGNRUNDERENHET_V2 to verdi) - } else { - it - } - }.toJson(), + .toJson(), ) coVerifySequence { diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt index f3d5af3b9..2741dfc53 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt @@ -1,5 +1,6 @@ package no.nav.helsearbeidsgiver.inntektsmelding.integrasjonstest +import io.kotest.matchers.maps.shouldContainExactly import io.kotest.matchers.nulls.shouldNotBeNull import io.mockk.coEvery import no.nav.helsearbeidsgiver.felles.BehovType @@ -8,7 +9,6 @@ import no.nav.helsearbeidsgiver.felles.Key import no.nav.helsearbeidsgiver.felles.domene.Inntekt import no.nav.helsearbeidsgiver.felles.domene.InntektPerMaaned import no.nav.helsearbeidsgiver.felles.json.toJson -import no.nav.helsearbeidsgiver.felles.test.shouldContainAllExcludingTempKey import no.nav.helsearbeidsgiver.inntektsmelding.integrasjonstest.utils.EndToEndTest import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.test.date.april @@ -42,7 +42,7 @@ class InntektSelvbestemtIT : EndToEndTest() { messages .filter(BehovType.HENT_INNTEKT) .firstAsMap() - .shouldContainAllExcludingTempKey( + .shouldContainExactly( mapOf( Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.BEHOV to BehovType.HENT_INNTEKT.toJson(), @@ -59,7 +59,7 @@ class InntektSelvbestemtIT : EndToEndTest() { messages .filter(Key.INNTEKT) .firstAsMap() - .shouldContainAllExcludingTempKey( + .shouldContainExactly( mapOf( Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.KONTEKST_ID to Mock.transaksjonId.toJson(),