From a3238e0959c0217b7160513867707cbda9c59e97 Mon Sep 17 00:00:00 2001 From: david steinsland Date: Thu, 14 Nov 2024 11:51:28 +0100 Subject: [PATCH] =?UTF-8?q?g=C3=A5r=20over=20til=20precondition-apiet?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/kotlin/no/nav/helse/sporbar/AnnulleringRiver.kt | 2 +- src/main/kotlin/no/nav/helse/sporbar/NyttDokumentRiver.kt | 4 +++- .../kotlin/no/nav/helse/sporbar/UtbetalingUtbetaltRiver.kt | 2 +- .../no/nav/helse/sporbar/UtbetalingUtenUtbetalingRiver.kt | 2 +- src/main/kotlin/no/nav/helse/sporbar/VedtakFattetRiver.kt | 2 +- .../no/nav/helse/sporbar/VedtaksperiodeAnnullertRiver.kt | 2 +- .../no/nav/helse/sporbar/sis/BehandlingForkastetRiver.kt | 2 +- .../no/nav/helse/sporbar/sis/BehandlingLukketRiver.kt | 2 +- .../no/nav/helse/sporbar/sis/BehandlingOpprettetRiver.kt | 2 +- .../no/nav/helse/sporbar/sis/VedtaksperiodeVenterRiver.kt | 6 ++++-- 10 files changed, 15 insertions(+), 11 deletions(-) diff --git a/src/main/kotlin/no/nav/helse/sporbar/AnnulleringRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/AnnulleringRiver.kt index 316b0c0..2ad08b2 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/AnnulleringRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/AnnulleringRiver.kt @@ -32,8 +32,8 @@ class AnnulleringRiver( River.PacketListener { init { River(rapidsConnection).apply { + precondition { it.requireValue("@event_name", "utbetaling_annullert") } validate { - it.demandValue("@event_name", "utbetaling_annullert") it.requireKey( "@id", "fødselsnummer", diff --git a/src/main/kotlin/no/nav/helse/sporbar/NyttDokumentRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/NyttDokumentRiver.kt index 6d562c1..3a23545 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/NyttDokumentRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/NyttDokumentRiver.kt @@ -23,8 +23,10 @@ internal class NyttDokumentRiver(rapidsConnection: RapidsConnection, private val } init { River(rapidsConnection).apply { + precondition { + it.requireAny("@event_name", listOf("inntektsmelding", "ny_søknad", "sendt_søknad_nav", "sendt_søknad_arbeidsgiver", "sendt_søknad_arbeidsledig")) + } validate { - it.demandAny("@event_name", listOf("inntektsmelding", "ny_søknad", "sendt_søknad_nav", "sendt_søknad_arbeidsgiver", "sendt_søknad_arbeidsledig")) it.requireKey("@opprettet") it.require("@id") { id -> UUID.fromString(id.asText()) } it.interestedIn("inntektsmeldingId") { id -> UUID.fromString(id.asText()) } diff --git a/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtbetaltRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtbetaltRiver.kt index 76fb008..c4a06b5 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtbetaltRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtbetaltRiver.kt @@ -36,8 +36,8 @@ internal class UtbetalingUtbetaltRiver( init { River(rapidsConnection).apply { + precondition { it.requireValue("@event_name", "utbetaling_utbetalt") } validate { - it.demandValue("@event_name", "utbetaling_utbetalt") it.requireKey( "fødselsnummer", "@id", diff --git a/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtenUtbetalingRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtenUtbetalingRiver.kt index 559b53a..c4be069 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtenUtbetalingRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/UtbetalingUtenUtbetalingRiver.kt @@ -33,8 +33,8 @@ internal class UtbetalingUtenUtbetalingRiver( init { River(rapidsConnection).apply { + precondition { it.requireValue("@event_name", "utbetaling_uten_utbetaling") } validate { - it.demandValue("@event_name", "utbetaling_uten_utbetaling") it.requireKey( "fødselsnummer", "@id", diff --git a/src/main/kotlin/no/nav/helse/sporbar/VedtakFattetRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/VedtakFattetRiver.kt index 71b893a..20e75d0 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/VedtakFattetRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/VedtakFattetRiver.kt @@ -34,8 +34,8 @@ internal class VedtakFattetRiver( init { River(rapidsConnection).apply { + precondition { it.requireValue("@event_name", "vedtak_fattet") } validate { - it.demandValue("@event_name", "vedtak_fattet") it.requireKey( "fødselsnummer", "@id", diff --git a/src/main/kotlin/no/nav/helse/sporbar/VedtaksperiodeAnnullertRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/VedtaksperiodeAnnullertRiver.kt index a31849a..b7c2f1a 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/VedtaksperiodeAnnullertRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/VedtaksperiodeAnnullertRiver.kt @@ -31,8 +31,8 @@ internal class VedtaksperiodeAnnullertRiver( init { River(rapidsConnection).apply { + precondition { it.requireValue("@event_name", "vedtaksperiode_annullert") } validate { - it.demandValue("@event_name", "vedtaksperiode_annullert") it.requireKey( "fødselsnummer", "@id", diff --git a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingForkastetRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingForkastetRiver.kt index fe2d9cb..9f95180 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingForkastetRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingForkastetRiver.kt @@ -19,8 +19,8 @@ internal class BehandlingForkastetRiver(rapid: RapidsConnection, private val sis init { River(rapid).apply { + precondition { it.requireValue("@event_name", "behandling_forkastet") } validate { - it.demandValue("@event_name", "behandling_forkastet") it.requireKey("vedtaksperiodeId", "behandlingId") it.require("@opprettet", JsonNode::asLocalDateTime) } diff --git a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingLukketRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingLukketRiver.kt index 8bfd0e7..f45db8e 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingLukketRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingLukketRiver.kt @@ -19,8 +19,8 @@ internal class BehandlingLukketRiver(rapid: RapidsConnection, private val sisPub init { River(rapid).apply { + precondition { it.requireValue("@event_name", "behandling_lukket") } validate { - it.demandValue("@event_name", "behandling_lukket") it.requireKey("vedtaksperiodeId", "behandlingId") it.require("@opprettet", JsonNode::asLocalDateTime) } diff --git a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingOpprettetRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingOpprettetRiver.kt index a4ac34e..33f878d 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingOpprettetRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/sis/BehandlingOpprettetRiver.kt @@ -21,8 +21,8 @@ internal class BehandlingOpprettetRiver(rapid: RapidsConnection, private val dok init { River(rapid).apply { + precondition { it.requireValue("@event_name", "behandling_opprettet") } validate { - it.demandValue("@event_name", "behandling_opprettet") it.requireKey("vedtaksperiodeId", "behandlingId", "søknadIder") it.require("@opprettet", JsonNode::asLocalDateTime) } diff --git a/src/main/kotlin/no/nav/helse/sporbar/sis/VedtaksperiodeVenterRiver.kt b/src/main/kotlin/no/nav/helse/sporbar/sis/VedtaksperiodeVenterRiver.kt index 003f4d9..c23ec2a 100644 --- a/src/main/kotlin/no/nav/helse/sporbar/sis/VedtaksperiodeVenterRiver.kt +++ b/src/main/kotlin/no/nav/helse/sporbar/sis/VedtaksperiodeVenterRiver.kt @@ -27,9 +27,11 @@ internal class VedtaksperiodeVenterRiver(rapid: RapidsConnection, private val do init { River(rapid).apply { + precondition { + it.requireValue("@event_name", "vedtaksperiode_venter") + it.requireAny("venterPå.venteårsak.hva", listOf("SØKNAD", "INNTEKTSMELDING", "GODKJENNING")) + } validate { - it.demandValue("@event_name", "vedtaksperiode_venter") - it.demandAny("venterPå.venteårsak.hva", listOf("SØKNAD", "INNTEKTSMELDING", "GODKJENNING")) it.requireKey("vedtaksperiodeId", "behandlingId", "organisasjonsnummer", "venterPå.vedtaksperiodeId", "venterPå.organisasjonsnummer", "hendelser") it.require("@opprettet", JsonNode::asLocalDateTime) }