From cfbc4496a2d29ff17e9b079cd35c3a67199379da Mon Sep 17 00:00:00 2001 From: david steinsland Date: Tue, 26 Nov 2024 12:12:25 +0100 Subject: [PATCH] fjerner vedtaksperiode_venter-river til fordel for ny --- .../VedtaksperiodeVenterRiver.kt | 43 ------------------- 1 file changed, 43 deletions(-) diff --git a/src/main/kotlin/no/nav/helse/ventetilstand/VedtaksperiodeVenterRiver.kt b/src/main/kotlin/no/nav/helse/ventetilstand/VedtaksperiodeVenterRiver.kt index 1419133..554b651 100644 --- a/src/main/kotlin/no/nav/helse/ventetilstand/VedtaksperiodeVenterRiver.kt +++ b/src/main/kotlin/no/nav/helse/ventetilstand/VedtaksperiodeVenterRiver.kt @@ -34,31 +34,6 @@ internal class VedtaksperiodeVenterRiver ( } } }.register(this) - - // todo: deprecated river - River(rapidApplication).apply { - precondition { it.requireValue("@event_name", "vedtaksperiode_venter") } - validate { it.requireKey( - "venterPå.venteårsak.hva", - "venterPå.vedtaksperiodeId", - "venterPå.skjæringstidspunkt", - "venterPå.organisasjonsnummer" - ) } - validate { it.interestedIn("venterPå.venteårsak.hvorfor") } - validate { it.requireKey( - "@id", - "vedtaksperiodeId", - "skjæringstidspunkt", - "organisasjonsnummer", - "ventetSiden", - "venterTil", - "fødselsnummer" - ) } - }.register(object : River.PacketListener { - override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) { - dao.venter(packet.vedtaksperiodeVenter, packet.hendelse) - } - }) } override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) { @@ -81,24 +56,6 @@ internal class VedtaksperiodeVenterRiver ( ), packet.hendelse) } } - - private companion object { - val JsonMessage.vedtaksperiodeVenter get() = VedtaksperiodeVenter.opprett( - vedtaksperiodeId = UUID.fromString(this["vedtaksperiodeId"].asText()), - skjæringstidspunkt = this["skjæringstidspunkt"].asLocalDate(), - fødselsnummer = this["fødselsnummer"].asText(), - organisasjonsnummer = this["organisasjonsnummer"].asText(), - ventetSiden = this["ventetSiden"].asLocalDateTime(), - venterTil = this["venterTil"].asLocalDateTime(), - venterPå = VenterPå( - vedtaksperiodeId = UUID.fromString(this["venterPå.vedtaksperiodeId"].asText()), - skjæringstidspunkt = this["venterPå.skjæringstidspunkt"].asLocalDate(), - organisasjonsnummer = this["venterPå.organisasjonsnummer"].asText(), - hva = this["venterPå.venteårsak.hva"].asText(), - hvorfor = this["venterPå.venteårsak.hvorfor"].takeUnless { it.isMissingOrNull() }?.asText() - ) - ) - } } @JsonIgnoreProperties(ignoreUnknown = true)