From 90520bc46bcd0bf9428c091902b9598b4390a014 Mon Sep 17 00:00:00 2001 From: "Nicolas N." Date: Wed, 22 Jan 2025 14:33:11 +0100 Subject: [PATCH] Fjerne mer ubrukt kode fra rivers (EY-4942) (#6818) * Fjerne mer ubrukt kode fra rivers (EY-4942) * fikse test json --- .../grunnlag/rivers/GrunnlagHendelserRiver.kt | 47 +++++++++---------- .../gyldigsoeknad/NySoeknadRiver.kt | 1 - .../StartUthentingFraSoeknadRiver.kt | 9 +--- .../src/test/resources/melding.json | 2 +- .../features/soeknad/SoeknadMapper.kt | 21 +++++---- .../src/main/kotlin/event/SoeknadInnsendt.kt | 1 - 6 files changed, 34 insertions(+), 47 deletions(-) diff --git a/apps/etterlatte-grunnlag/src/main/kotlin/grunnlag/rivers/GrunnlagHendelserRiver.kt b/apps/etterlatte-grunnlag/src/main/kotlin/grunnlag/rivers/GrunnlagHendelserRiver.kt index 3562dd8025d..379d9a72e80 100644 --- a/apps/etterlatte-grunnlag/src/main/kotlin/grunnlag/rivers/GrunnlagHendelserRiver.kt +++ b/apps/etterlatte-grunnlag/src/main/kotlin/grunnlag/rivers/GrunnlagHendelserRiver.kt @@ -28,8 +28,7 @@ class GrunnlagHendelserRiver( private val grunnlagService: GrunnlagService, ) : ListenerMedLogging() { init { - initialiserRiverUtenEventName(rapidsConnection) { - validate { it.interestedIn(EVENT_NAME_KEY) } + initialiserRiver(rapidsConnection, EventNames.NY_OPPLYSNING) { validate { it.interestedIn(FNR_KEY) } validate { it.requireKey(OPPLYSNING_KEY) } validate { it.requireKey(SAK_ID_KEY) } @@ -44,32 +43,28 @@ class GrunnlagHendelserRiver( packet: JsonMessage, context: MessageContext, ) { - val eventName = packet[EVENT_NAME_KEY].asText() + val sakId = packet[SAK_ID_KEY].asLong().let { SakId(it) } + val behandlingId = packet[BEHANDLING_ID_KEY].let { UUID.fromString(it.asText()) } - if (eventName == EventNames.NY_OPPLYSNING.eventname) { - val sakId = packet[SAK_ID_KEY].asLong().let { SakId(it) } - val behandlingId = packet[BEHANDLING_ID_KEY].let { UUID.fromString(it.asText()) } + val opplysninger: List> = + objectMapper.readValue(packet[OPPLYSNING_KEY].toJson())!! - val opplysninger: List> = - objectMapper.readValue(packet[OPPLYSNING_KEY].toJson())!! - - val fnr = packet[FNR_KEY].textValue() - if (fnr == null) { - grunnlagService.lagreNyeSaksopplysninger( - sakId, - behandlingId, - opplysninger, - ) - } else { - grunnlagService.lagreNyePersonopplysninger( - sakId, - behandlingId, - Folkeregisteridentifikator.of(fnr), - opplysninger, - ) - } - packet.eventName = GRUNNLAG_OPPDATERT - context.publish(packet.toJson()) + val fnr = packet[FNR_KEY].textValue() + if (fnr == null) { + grunnlagService.lagreNyeSaksopplysninger( + sakId, + behandlingId, + opplysninger, + ) + } else { + grunnlagService.lagreNyePersonopplysninger( + sakId, + behandlingId, + Folkeregisteridentifikator.of(fnr), + opplysninger, + ) } + packet.eventName = GRUNNLAG_OPPDATERT + context.publish(packet.toJson()) } } diff --git a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/gyldigsoeknad/NySoeknadRiver.kt b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/gyldigsoeknad/NySoeknadRiver.kt index b31d9d246c4..7d332ebbaf7 100644 --- a/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/gyldigsoeknad/NySoeknadRiver.kt +++ b/apps/etterlatte-gyldig-soeknad/src/main/kotlin/no/nav/etterlatte/gyldigsoeknad/NySoeknadRiver.kt @@ -47,7 +47,6 @@ internal class NySoeknadRiver( validate { it.requireKey(SoeknadInnsendt.lagretSoeknadIdKey) } validate { it.requireKey(SoeknadInnsendt.hendelseGyldigTilKey) } validate { it.requireKey(SoeknadInnsendt.fnrSoekerKey) } - validate { it.rejectKey(SoeknadInnsendt.adressebeskyttelseKey) } validate { it.rejectKey(SoeknadInnsendt.dokarkivReturKey) } validate { it.rejectKey(GyldigSoeknadVurdert.sakIdKey) } validate { it.rejectKey(FordelerFordelt.soeknadFordeltKey) } diff --git a/apps/etterlatte-opplysninger-fra-soeknad/src/main/kotlin/no/nav/etterlatte/opplysningerfrasoknad/StartUthentingFraSoeknadRiver.kt b/apps/etterlatte-opplysninger-fra-soeknad/src/main/kotlin/no/nav/etterlatte/opplysningerfrasoknad/StartUthentingFraSoeknadRiver.kt index 81026dc0928..6a91bfe3fb7 100644 --- a/apps/etterlatte-opplysninger-fra-soeknad/src/main/kotlin/no/nav/etterlatte/opplysningerfrasoknad/StartUthentingFraSoeknadRiver.kt +++ b/apps/etterlatte-opplysninger-fra-soeknad/src/main/kotlin/no/nav/etterlatte/opplysningerfrasoknad/StartUthentingFraSoeknadRiver.kt @@ -4,7 +4,6 @@ import no.nav.etterlatte.libs.common.event.GyldigSoeknadVurdert import no.nav.etterlatte.libs.common.event.SoeknadInnsendtHendelseType import no.nav.etterlatte.libs.common.innsendtsoeknad.common.SoeknadType import no.nav.etterlatte.libs.common.rapidsandrivers.CORRELATION_ID_KEY -import no.nav.etterlatte.libs.common.rapidsandrivers.EVENT_NAME_KEY import no.nav.etterlatte.libs.common.rapidsandrivers.lagParMedEventNameKey import no.nav.etterlatte.opplysningerfrasoknad.opplysningsuthenter.Opplysningsuthenter import no.nav.etterlatte.rapidsandrivers.BEHANDLING_ID_KEY @@ -27,13 +26,7 @@ internal class StartUthentingFraSoeknadRiver( private val rapid = rapidsConnection init { - initialiserRiverUtenEventName(rapidsConnection) { - validate { - it.demandAny( - EVENT_NAME_KEY, - SoeknadInnsendtHendelseType.entries.map { it.lagEventnameForType() }, - ) - } + initialiserRiver(rapidsConnection, SoeknadInnsendtHendelseType.EVENT_NAME_BEHANDLINGBEHOV) { validate { it.requireKey(GyldigSoeknadVurdert.skjemaInfoKey) } validate { it.requireKey(GyldigSoeknadVurdert.sakIdKey) } validate { it.requireKey(GyldigSoeknadVurdert.behandlingIdKey) } diff --git a/apps/etterlatte-opplysninger-fra-soeknad/src/test/resources/melding.json b/apps/etterlatte-opplysninger-fra-soeknad/src/test/resources/melding.json index fd3fedc5c30..efa67d4bb2b 100644 --- a/apps/etterlatte-opplysninger-fra-soeknad/src/test/resources/melding.json +++ b/apps/etterlatte-opplysninger-fra-soeknad/src/test/resources/melding.json @@ -1,5 +1,5 @@ { - "@event_name": "soeknad_innsendt", + "@event_name": "trenger_behandling", "behandlingId": "f525f2f7-e246-43d7-b61a-5f0757472916", "sakId": 1, "@skjema_info": { diff --git a/apps/etterlatte-testdata/src/main/kotlin/no/nav/etterlatte/testdata/features/soeknad/SoeknadMapper.kt b/apps/etterlatte-testdata/src/main/kotlin/no/nav/etterlatte/testdata/features/soeknad/SoeknadMapper.kt index b5965e81c21..a27fb537b6f 100644 --- a/apps/etterlatte-testdata/src/main/kotlin/no/nav/etterlatte/testdata/features/soeknad/SoeknadMapper.kt +++ b/apps/etterlatte-testdata/src/main/kotlin/no/nav/etterlatte/testdata/features/soeknad/SoeknadMapper.kt @@ -1,5 +1,6 @@ package no.nav.etterlatte.testdata.features.soeknad +import no.nav.etterlatte.libs.common.event.SoeknadInnsendt import no.nav.etterlatte.libs.common.event.SoeknadInnsendtHendelseType import no.nav.etterlatte.libs.common.innsendtsoeknad.ArbeidOgUtdanningOMS import no.nav.etterlatte.libs.common.innsendtsoeknad.ForholdTilAvdoedeOMS @@ -49,16 +50,16 @@ object SoeknadMapper { JsonMessage.newMessage( mutableMapOf( SoeknadInnsendtHendelseType.EVENT_NAME_BEHANDLINGBEHOV.lagParMedEventNameKey(), - "@skjema_info" to + SoeknadInnsendt.skjemaInfoKey to opprettOmstillingsstoenadSoeknad( soekerFnr = soekerFnr, avdoedFnr = avdoedFnr, barn = barn, ).toObjectNode(), - "@lagret_soeknad_id" to "TEST-${UUID.randomUUID()}", - "@template" to "soeknad", - "@fnr_soeker" to soekerFnr, - "@hendelse_gyldig_til" to OffsetDateTime.now().plusMinutes(60L), + SoeknadInnsendt.lagretSoeknadIdKey to "TEST-${UUID.randomUUID()}", + SoeknadInnsendt.templateKey to "soeknad", + SoeknadInnsendt.fnrSoekerKey to soekerFnr, + SoeknadInnsendt.hendelseGyldigTilKey to OffsetDateTime.now().plusMinutes(60L), Behandlingssteg.KEY to behandlingssteg.name, ), ) @@ -69,17 +70,17 @@ object SoeknadMapper { JsonMessage.newMessage( mutableMapOf( SoeknadInnsendtHendelseType.EVENT_NAME_BEHANDLINGBEHOV.lagParMedEventNameKey(), - "@skjema_info" to + SoeknadInnsendt.skjemaInfoKey to opprettBarnepensjonSoeknad( gjenlevendeFnr = gjenlevendeFnr, avdoedFnr = avdoedFnr, barnFnr = soekerFnr, soesken = barn.filter { it != soeker }, ).toObjectNode(), - "@lagret_soeknad_id" to "TEST-${UUID.randomUUID()}", - "@template" to "soeknad", - "@fnr_soeker" to barn.first(), - "@hendelse_gyldig_til" to OffsetDateTime.now().plusMinutes(60L), + SoeknadInnsendt.lagretSoeknadIdKey to "TEST-${UUID.randomUUID()}", + SoeknadInnsendt.templateKey to "soeknad", + SoeknadInnsendt.fnrSoekerKey to barn.first(), + SoeknadInnsendt.hendelseGyldigTilKey to OffsetDateTime.now().plusMinutes(60L), Behandlingssteg.KEY to behandlingssteg.name, ), ) diff --git a/libs/saksbehandling-common/src/main/kotlin/event/SoeknadInnsendt.kt b/libs/saksbehandling-common/src/main/kotlin/event/SoeknadInnsendt.kt index 191191d59e0..4fe44cbcbb9 100644 --- a/libs/saksbehandling-common/src/main/kotlin/event/SoeknadInnsendt.kt +++ b/libs/saksbehandling-common/src/main/kotlin/event/SoeknadInnsendt.kt @@ -6,7 +6,6 @@ interface ISoeknadInnsendt { val templateKey get() = "@template" val lagretSoeknadIdKey get() = "@lagret_soeknad_id" val hendelseGyldigTilKey get() = "@hendelse_gyldig_til" - val adressebeskyttelseKey get() = "@adressebeskyttelse" val fnrSoekerKey get() = "@fnr_soeker" val dokarkivReturKey get() = "@dokarkivRetur" }