diff --git a/.gitignore b/.gitignore index 876d186bd..c6844d4d8 100644 --- a/.gitignore +++ b/.gitignore @@ -3,3 +3,4 @@ **/build out .DS_Store +.kotlin \ No newline at end of file diff --git a/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt b/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt index ab5c31efe..461f2de7e 100644 --- a/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt +++ b/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt @@ -48,7 +48,7 @@ class TilgangRiver( behovType = Key.BEHOV.krev(BehovType.TILGANGSKONTROLL, BehovType.serializer(), json), transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, json), data = data, - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), data), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), data), fnr = Key.FNR.les(Fnr.serializer(), data), ) } 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 e2e27a770..c4a2a7b6c 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 @@ -133,7 +133,7 @@ private object MockTilgang { transaksjonId = UUID.randomUUID(), data = mapOf( - Key.ORGNRUNDERENHET to orgnr.toJson(Orgnr.serializer()), + Key.ORGNR_UNDERENHET to orgnr.toJson(Orgnr.serializer()), Key.FNR to fnr.toJson(Fnr.serializer()), ), orgnr = orgnr, diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt index 84bd07405..50aae0369 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt @@ -42,7 +42,7 @@ class TilgangProducer( EventName.TILGANG_ORG_REQUESTED, transaksjonId, fnr, - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET to orgnr.toJson(), ) private fun publish( diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt index 2120f9361..63061cc86 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt @@ -37,7 +37,7 @@ class InntektSelvbestemtProducer( Key.DATA to mapOf( Key.FNR to request.sykmeldtFnr.toJson(), - Key.ORGNRUNDERENHET to request.orgnr.toJson(), + Key.ORGNR_UNDERENHET to request.orgnr.toJson(), Key.INNTEKTSDATO to request.inntektsdato.toJson(), ).toJson(), ).also { json -> 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 8ae641e94..73b78e7f8 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 @@ -37,7 +37,7 @@ class InntektSelvbestemtProducerTest : Key.DATA to mapOf( Key.FNR to sykmeldtFnr.toJson(), - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET 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 8cc2d13b0..2540f7911 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,11 @@ enum class Key( VEDTAKSPERIODE_ID_LISTE("vedtaksperiode_id_liste"), VIRKSOMHET("virksomhet"), VIRKSOMHETER("virksomheter"), - ORGNRUNDERENHET("orgnr_underenhet"), + ORGNR_UNDERENHET("orgnr_underenhet"), // ulik formattering SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"), + SPINN_INNTEKTSMELDING_ID_V2("spinn_inntektsmelding_id"), ; diff --git a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt index a957026b1..519d116ee 100644 --- a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt +++ b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt @@ -30,7 +30,7 @@ class RedisStoreTest : "$keyPrefix#$transaksjonId" to "\"mango\"", "$keyPrefix#$transaksjonId#${Key.SAK_ID}#feil" to "\"papaya\"", "$keyPrefix#$transaksjonId#${Key.FNR}" to "\"ananas\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "\"kokosnøtt\"", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "\"kokosnøtt\"", "$keyPrefix#$transaksjonId#${Key.TILGANG}" to null, ), ), @@ -42,7 +42,7 @@ class RedisStoreTest : redisStore.lesAlleMellomlagrede(transaksjonId) shouldContainExactly mapOf( Key.FNR to "ananas".toJson(), - Key.ORGNRUNDERENHET to "kokosnøtt".toJson(), + Key.ORGNR_UNDERENHET to "kokosnøtt".toJson(), ) } @@ -60,7 +60,7 @@ class RedisStoreTest : "${Key.FNR}" to "\"bringebær\"", "$transaksjonId#${Key.FNR}" to "\"blåbær\"", "$keyPrefix#$transaksjonId#ikkeEnKey" to "\"tyttebær\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "\"kokosnøtt\"", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "\"kokosnøtt\"", ), ), keyPrefix = keyPrefix, @@ -70,7 +70,7 @@ class RedisStoreTest : redisStore.lesAlleMellomlagrede(transaksjonId) shouldContainExactly mapOf( - Key.ORGNRUNDERENHET to "kokosnøtt".toJson(), + Key.ORGNR_UNDERENHET to "kokosnøtt".toJson(), ) } @@ -85,7 +85,7 @@ class RedisStoreTest : mockStorageInit = mapOf( "$keyPrefix#$transaksjonId#${Key.FNR}" to "\"ananas\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "streng uten ekstra fnutter", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "streng uten ekstra fnutter", "$keyPrefix#$transaksjonId#${Key.PERSONER}" to "{true}", "$keyPrefix#$transaksjonId#${Key.VIRKSOMHETER}" to "]]42[[", ), diff --git a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt index 4898598be..6599331f8 100644 --- a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt +++ b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt @@ -45,16 +45,21 @@ class ForespoerselBesvartRiver : PriObjectRiver() { Metrics.forespoerslerBesvartFraSpleis.inc() - return mapOf( - Key.EVENT_NAME to EventName.FORESPOERSEL_BESVART.toJson(), - Key.KONTEKST_ID to transaksjonId.toJson(), - Key.DATA to - mapOf( - Key.FORESPOERSEL_ID to forespoerselId.toJson(), - Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId?.toJson(), - ).mapValuesNotNull { it } - .toJson(), - ) + val resultat = + mapOf( + Key.EVENT_NAME to EventName.FORESPOERSEL_BESVART.toJson(), + Key.KONTEKST_ID to transaksjonId.toJson(), + Key.DATA to + mapOf( + Key.FORESPOERSEL_ID to forespoerselId.toJson(), + Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId?.toJson(), + Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId?.toJson(), + ).mapValuesNotNull { it } + .toJson(), + ) + logger.info("Sendt en melding fra pri-topic.") + sikkerLogger.info("Sendt en melding fra pri-topic:\n${resultat.toJson()}") + return resultat } override fun BesvartMelding.haandterFeil( diff --git a/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt b/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt index 3230342b3..817638503 100644 --- a/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt +++ b/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt @@ -64,6 +64,7 @@ class ForespoerselBesvartRiverTest : mapOf( Key.FORESPOERSEL_ID to forespoerselId.toJson(), Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId.toJson(), + Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId.toJson(), ).toJson(), ) diff --git a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt index 5a60cf52e..752781ecb 100644 --- a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt +++ b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt @@ -50,7 +50,7 @@ class InntektSelvbestemtService( override fun lesSteg0(melding: Map): Steg0 = Steg0( transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, melding), - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), melding), sykmeldtFnr = Key.FNR.les(Fnr.serializer(), melding), inntektsdato = Key.INNTEKTSDATO.les(LocalDateSerializer, melding), ) @@ -74,7 +74,7 @@ class InntektSelvbestemtService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg0.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg0.orgnr.toJson(), Key.FNR to steg0.sykmeldtFnr.toJson(), Key.INNTEKTSDATO to steg0.inntektsdato.toJson(), ), diff --git a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt index 5a9f0d3c1..9edbebe8e 100644 --- a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt +++ b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt @@ -120,7 +120,7 @@ private object Mock { val steg0Data = mapOf( - Key.ORGNRUNDERENHET to Orgnr.genererGyldig().toJson(), + Key.ORGNR_UNDERENHET to Orgnr.genererGyldig().toJson(), Key.FNR to Fnr.genererGyldig().toJson(), Key.INNTEKTSDATO to 14.april.toJson(), ) diff --git a/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt b/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt index c84034e4c..6f8f8a72d 100644 --- a/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt +++ b/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt @@ -54,7 +54,7 @@ class HentInntektRiver( behovType = Key.BEHOV.krev(BehovType.HENT_INNTEKT, BehovType.serializer(), json), transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, json), data = data, - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), data), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), data), fnr = Key.FNR.les(Fnr.serializer(), data), inntektsdato = Key.INNTEKTSDATO.les(LocalDateSerializer, data), ) 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 14b81518c..1151a9bf6 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 @@ -175,7 +175,7 @@ private object Mock { transaksjonId = UUID.randomUUID(), data = mapOf( - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET to orgnr.toJson(), Key.FNR to fnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ), diff --git a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt index 5a9540cee..8cdadf183 100644 --- a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt +++ b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt @@ -105,7 +105,7 @@ class InntektService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg1.forespoersel.fnr.toJson(), Key.INNTEKTSDATO to steg0.skjaeringstidspunkt.toJson(), ), 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 2741dfc53..3cddde89c 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 @@ -34,7 +34,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.DATA to mapOf( Key.FNR to Mock.fnr.toJson(), - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), ).toJson(), ) @@ -49,7 +49,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.KONTEKST_ID to Mock.transaksjonId.toJson(), Key.DATA to mapOf( - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.FNR to Mock.fnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), ).toJson(), @@ -65,7 +65,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.KONTEKST_ID to Mock.transaksjonId.toJson(), Key.DATA to mapOf( - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.FNR to Mock.fnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), Key.INNTEKT to Mock.inntektPerMaaned.toJson(Inntekt.serializer()), diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt index 60034bdf7..b1bc541b8 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt @@ -108,7 +108,7 @@ class TilgangForespoerselService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg0.avsenderFnr.toJson(), ), ).toJson(), diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt index 8d5402a53..44fa12f8f 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt @@ -47,7 +47,7 @@ class TilgangOrgService( override fun lesSteg0(melding: Map): Steg0 = Steg0( transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, melding), - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), melding), fnr = Key.FNR.les(Fnr.serializer(), melding), ) @@ -70,7 +70,7 @@ class TilgangOrgService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg0.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg0.orgnr.toJson(), Key.FNR to steg0.fnr.toJson(), ), ).toJson(), diff --git a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt index 3ada2ae46..484aa5796 100644 --- a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt +++ b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt @@ -166,7 +166,7 @@ class HentForespoerselService( Key.DATA to mapOf( Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(), - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg1.forespoersel.fnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ).toJson(),