Merge branch 'main' into fjern_paaminnelser_infotrygd

navikt · Nov 4, 2024 · 512377e · 512377e
2 parents dd43d31 + 29377f6
commit 512377e
Show file tree

Hide file tree

Showing 5 changed files with 43 additions and 51 deletions.
diff --git a/...searbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt b/...searbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt
@@ -19,7 +19,6 @@ import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.publish
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceMed4Steg
 import no.nav.helsearbeidsgiver.felles.utils.Log
-import no.nav.helsearbeidsgiver.utils.collection.mapValuesNotNull
 import no.nav.helsearbeidsgiver.utils.json.serializer.LocalDateSerializer
 import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
 import no.nav.helsearbeidsgiver.utils.json.toJson
@@ -215,14 +214,12 @@ class BerikInntektsmeldingService(
         if (!steg4.erDuplikat) {
             val publisert =
                 rapid.publish(
-                    mapOf(
-                        Key.EVENT_NAME to EventName.INNTEKTSMELDING_MOTTATT.toJson(),
-                        Key.UUID to steg0.transaksjonId.toJson(),
-                        Key.FORESPOERSEL_ID to steg0.skjema.forespoerselId.toJson(),
-                        Key.INNTEKTSMELDING to steg4.inntektsmelding.toJson(Inntektsmelding.serializer()),
-                        Key.BESTEMMENDE_FRAVAERSDAG to steg4.bestemmendeFravaersdag.toJson(),
-                        Key.INNSENDING_ID to steg0.innsendingId.toJson(Long.serializer()),
-                    ).mapValuesNotNull { it },
+                    Key.EVENT_NAME to EventName.INNTEKTSMELDING_MOTTATT.toJson(),
+                    Key.UUID to steg0.transaksjonId.toJson(),
+                    Key.FORESPOERSEL_ID to steg0.skjema.forespoerselId.toJson(),
+                    Key.INNTEKTSMELDING to steg4.inntektsmelding.toJson(Inntektsmelding.serializer()),
+                    Key.BESTEMMENDE_FRAVAERSDAG to steg4.bestemmendeFravaersdag.toJson(),
+                    Key.INNSENDING_ID to steg0.innsendingId.toJson(Long.serializer()),
                 )
 
             MdcUtils.withLogFields(

diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt
@@ -16,42 +16,44 @@ enum class Key(
     BEHOV("@behov"),
 
     // Egendefinerte
-    SELVBESTEMT_ID("selvbestemt_id"),
+    ARBEIDSFORHOLD("arbeidsforhold"),
     ARBEIDSGIVER_FNR("arbeidsgiver_fnr"),
-    UUID("uuid"),
-    FORESPOERSEL_ID("forespoerselId"),
-    VEDTAKSPERIODE_ID_LISTE("vedtaksperiode_id_liste"),
-    JOURNALPOST_ID("journalpostId"),
+    BESTEMMENDE_FRAVAERSDAG("bestemmende_fravaersdag"),
     DATA("data"),
+    ER_DUPLIKAT_IM("er_duplikat_im"),
     FAIL("fail"),
-    SKJEMA_INNTEKTSMELDING("skjema_inntektsmelding"),
+    FNR("fnr"),
+    FNR_LISTE("fnr_liste"),
+    FORESPOERSEL("forespoersel"),
+    FORESPOERSEL_MAP("forespoersel_map"),
+    INNSENDING_ID("innsending_id"),
+    INNTEKT("inntekt"),
+    INNTEKTSDATO("inntektsdato"),
     INNTEKTSMELDING("inntektsmelding"),
     LAGRET_INNTEKTSMELDING("lagret_inntektsmelding"),
-    SELVBESTEMT_INNTEKTSMELDING("selvbestemt_inntektsmelding"),
-    SYKMELDT("sykmeldt"),
-    VIRKSOMHET("virksomhet"),
-    VIRKSOMHETER("virksomheter"),
-    ARBEIDSFORHOLD("arbeidsforhold"),
-    SAK_ID("sak_id"),
     OPPGAVE_ID("oppgave_id"),
-    ORGNRUNDERENHET("orgnrUnderenhet"),
     ORGNR_UNDERENHETER("orgnr_underenheter"),
     ORG_RETTIGHETER("org_rettigheter"),
-    FORESPOERSEL_SVAR("forespoersel-svar"),
-    FORESPOERSEL_MAP("forespoersel_map"),
-    FORESPOERSEL("forespoersel"),
-    INNTEKT("inntekt"),
-    FNR("fnr"),
-    FNR_LISTE("fnr_liste"),
     PERSONER("personer"),
-    BESTEMMENDE_FRAVAERSDAG("bestemmende_fravaersdag"),
-    INNTEKTSDATO("inntektsdato"),
+    SAK_ID("sak_id"),
+    SELVBESTEMT_ID("selvbestemt_id"),
+    SELVBESTEMT_INNTEKTSMELDING("selvbestemt_inntektsmelding"),
+    SKAL_HA_PAAMINNELSE("skal_ha_paaminnelse"),
+    SKJEMA_INNTEKTSMELDING("skjema_inntektsmelding"),
+    SYKMELDT("sykmeldt"),
     TILGANG("tilgang"),
-    SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"),
+    UUID("uuid"),
+    VEDTAKSPERIODE_ID_LISTE("vedtaksperiode_id_liste"),
+    VIRKSOMHET("virksomhet"),
+    VIRKSOMHETER("virksomheter"),
+
+    // ulik formattering
     EKSTERN_INNTEKTSMELDING("eksternInntektsmelding"),
-    ER_DUPLIKAT_IM("er_duplikat_im"),
-    INNSENDING_ID("innsending_id"),
-    SKAL_HA_PAAMINNELSE("skal_ha_paaminnelse"),
+    FORESPOERSEL_ID("forespoerselId"),
+    FORESPOERSEL_SVAR("forespoersel-svar"),
+    JOURNALPOST_ID("journalpostId"),
+    ORGNRUNDERENHET("orgnrUnderenhet"),
+    SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"),
     ;
 
     override fun toString(): String = str

diff --git a/...n/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt b/...n/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt
@@ -9,15 +9,13 @@ import no.nav.helsearbeidsgiver.felles.Key
 import no.nav.helsearbeidsgiver.felles.domene.Forespoersel
 import no.nav.helsearbeidsgiver.felles.domene.Person
 import no.nav.helsearbeidsgiver.felles.json.les
-import no.nav.helsearbeidsgiver.felles.json.lesOrNull
 import no.nav.helsearbeidsgiver.felles.json.orgMapSerializer
 import no.nav.helsearbeidsgiver.felles.json.personMapSerializer
 import no.nav.helsearbeidsgiver.felles.json.toJson
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.publish
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceMed2Steg
 import no.nav.helsearbeidsgiver.felles.utils.Log
-import no.nav.helsearbeidsgiver.utils.collection.mapValuesNotNull
 import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
 import no.nav.helsearbeidsgiver.utils.json.toJson
 import no.nav.helsearbeidsgiver.utils.log.logger
@@ -32,7 +30,7 @@ data class Steg0(
     val orgnr: Orgnr,
     val fnr: Fnr,
     val skalHaPaaminnelse: Boolean,
-    val forespoersel: Forespoersel?,
+    val forespoersel: Forespoersel,
 )
 
 data class Steg1(
@@ -58,7 +56,7 @@ class HentDataTilSakOgOppgaveService(
             orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding),
             fnr = Key.FNR.les(Fnr.serializer(), melding),
             skalHaPaaminnelse = Key.SKAL_HA_PAAMINNELSE.les(Boolean.serializer(), melding),
-            forespoersel = Key.FORESPOERSEL.lesOrNull(Forespoersel.serializer(), melding),
+            forespoersel = Key.FORESPOERSEL.les(Forespoersel.serializer(), melding),
         )
 
     override fun lesSteg1(melding: Map<Key, JsonElement>): Steg1 =
@@ -142,9 +140,8 @@ class HentDataTilSakOgOppgaveService(
                     Key.SYKMELDT to sykmeldt.toJson(Person.serializer()),
                     Key.VIRKSOMHET to orgNavn.toJson(),
                     Key.SKAL_HA_PAAMINNELSE to steg0.skalHaPaaminnelse.toJson(Boolean.serializer()),
-                    Key.FORESPOERSEL to steg0.forespoersel?.toJson(Forespoersel.serializer()),
-                ).mapValuesNotNull { it }
-                    .toJson(),
+                    Key.FORESPOERSEL to steg0.forespoersel.toJson(Forespoersel.serializer()),
+                ).toJson(),
         )
     }
 

diff --git a/...searbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt b/...searbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt
@@ -9,7 +9,6 @@ import no.nav.helsearbeidsgiver.felles.domene.Forespoersel
 import no.nav.helsearbeidsgiver.felles.domene.Person
 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
@@ -34,7 +33,7 @@ data class OpprettForespoerselSakOgOppgaveMelding(
     val sykmeldt: Person,
     val orgNavn: String,
     val skalHaPaaminnelse: Boolean,
-    val forespoersel: Forespoersel?,
+    val forespoersel: Forespoersel,
 )
 
 class OpprettForespoerselSakOgOppgaveRiver(
@@ -59,7 +58,7 @@ class OpprettForespoerselSakOgOppgaveRiver(
                 sykmeldt = Key.SYKMELDT.les(Person.serializer(), data),
                 orgNavn = Key.VIRKSOMHET.les(String.serializer(), data),
                 skalHaPaaminnelse = Key.SKAL_HA_PAAMINNELSE.les(Boolean.serializer(), data),
-                forespoersel = Key.FORESPOERSEL.lesOrNull(Forespoersel.serializer(), data),
+                forespoersel = Key.FORESPOERSEL.les(Forespoersel.serializer(), data),
             )
         }
 
@@ -83,7 +82,7 @@ class OpprettForespoerselSakOgOppgaveRiver(
                 skalHaPaaminnelse = skalHaPaaminnelse,
                 paaminnelseAktivert = paaminnelseToggle.oppgavePaaminnelseAktivert,
                 tidMellomOppgaveopprettelseOgPaaminnelse = paaminnelseToggle.tidMellomOppgaveopprettelseOgPaaminnelse,
-                sykmeldingsPerioder = forespoersel?.sykmeldingsperioder.orEmpty(),
+                sykmeldingsPerioder = forespoersel.sykmeldingsperioder,
             )
 
         return mapOf(

diff --git a/...beidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt b/...beidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt
@@ -29,7 +29,6 @@ import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.NotifikasjonTekst
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.PaaminnelseToggle
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.sakLevetid
-import no.nav.helsearbeidsgiver.utils.collection.mapValuesNotNull
 import no.nav.helsearbeidsgiver.utils.json.toJson
 import no.nav.helsearbeidsgiver.utils.wrapper.Fnr
 import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr
@@ -100,9 +99,7 @@ class OpprettForespoerselSakOgOppgaveRiverTest :
                                 NotifikasjonTekst.paaminnelseInnhold(
                                     innkommendeMelding.orgnr,
                                     innkommendeMelding.orgNavn,
-                                    innkommendeMelding.forespoersel
-                                        ?.sykmeldingsperioder
-                                        .orEmpty(),
+                                    innkommendeMelding.forespoersel.sykmeldingsperioder,
                                 ),
                             tidMellomOppgaveopprettelseOgPaaminnelse = "P28D",
                         ),
@@ -280,8 +277,8 @@ private fun OpprettForespoerselSakOgOppgaveMelding.toMap() =
                 Key.SYKMELDT to sykmeldt.toJson(Person.serializer()),
                 Key.VIRKSOMHET to orgNavn.toJson(),
                 Key.SKAL_HA_PAAMINNELSE to skalHaPaaminnelse.toJson(Boolean.serializer()),
-                Key.FORESPOERSEL to forespoersel?.toJson(Forespoersel.serializer()),
-            ).mapValuesNotNull { it }.toJson(),
+                Key.FORESPOERSEL to forespoersel.toJson(Forespoersel.serializer()),
+            ).toJson(),
     )
 
 private fun forventetUtgaaendeMelding(