diff --git a/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/ApplicationBuilder.kt b/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/ApplicationBuilder.kt index 2b60ccb..d20d7fe 100644 --- a/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/ApplicationBuilder.kt +++ b/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/ApplicationBuilder.kt @@ -15,8 +15,8 @@ internal class ApplicationBuilder(config: Map) : RapidsConnectio RapidApplication.Builder(RapidApplication.RapidApplicationConfig.fromEnv(config)) .withKtorModule { journalpostApi(repository) - }.build().also { - InnsendingFerdigstilMottak(it, repository) + }.build().also { rapidsConnection -> + InnsendingFerdigstiltMottak(rapidsConnection, repository) } init { diff --git a/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottak.kt b/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottak.kt similarity index 86% rename from src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottak.kt rename to src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottak.kt index 785a3a9..ff35de1 100644 --- a/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottak.kt +++ b/src/main/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottak.kt @@ -10,11 +10,12 @@ import java.util.UUID private val logger = KotlinLogging.logger { } -class InnsendingFerdigstilMottak(rapidsConnection: RapidsConnection, private val repository: Repository) : +class InnsendingFerdigstiltMottak(rapidsConnection: RapidsConnection, private val repository: Repository) : River.PacketListener { init { River(rapidsConnection).apply { validate { it.demandValue("@event_name", "innsending_ferdigstilt") } + validate { it.requireValue("type", value = "NySøknad") } validate { it.requireKey("fagsakId") } validate { it.requireKey("journalpostId") } validate { it.requireKey("søknadsData.søknad_uuid") } diff --git a/src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottakTest.kt b/src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottakTest.kt similarity index 91% rename from src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottakTest.kt rename to src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottakTest.kt index c414e50..6962e31 100644 --- a/src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstilMottakTest.kt +++ b/src/test/kotlin/no/nav/dagpenger/oppslag/journalpost/id/InnsendingFerdigstiltMottakTest.kt @@ -9,7 +9,7 @@ import no.nav.helse.rapids_rivers.testsupport.TestRapid import org.junit.jupiter.api.Test import java.util.UUID -class InnsendingFerdigstilMottakTest { +class InnsendingFerdigstiltMottakTest { private val testRapid = TestRapid() @Test @@ -19,7 +19,7 @@ class InnsendingFerdigstilMottakTest { every { it.lagre(any(), any()) } just runs } - InnsendingFerdigstilMottak(testRapid, repository) + InnsendingFerdigstiltMottak(testRapid, repository) //language=JSON testRapid.sendTestMessage(