fjerner vedtaksperiode_venter-river til fordel for ny

navikt · Nov 26, 2024 · cfbc449 · cfbc449
1 parent 06208e9
commit cfbc449
Showing 1 changed file with 0 additions and 43 deletions.
diff --git 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)