Legge på at behovssvar krever '@Final=true' for å spille sammen med d…

…p-behovsakkumulator (#140)
navikt · Apr 17, 2024 · ccb5717 · ccb5717
1 parent 0180d7d
commit ccb5717
Show file tree

Hide file tree

Showing 14 changed files with 156 additions and 109 deletions.
diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/db/PostgresDataSourceBuilder.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/db/PostgresDataSourceBuilder.kt
@@ -12,7 +12,7 @@ internal object PostgresDataSourceBuilder {
     const val DB_HOST_KEY = "DB_HOST"
     const val DB_PORT_KEY = "DB_PORT"
 
-    private fun getOrThrow(key: String): String = OptionHelper.getEnv(key) ?: OptionHelper.getSystemProperty(key)
+    private fun getOrThrow(key: String): String = OptionHelper.getEnv(key) ?: OptionHelper.getSystemProperty(key) ?: throw IllegalArgumentException("Missing required environment variable $key")
 
     val dataSource by lazy {
         HikariDataSource().apply {

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/EksisterendeSakerMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/EksisterendeSakerMottak.kt
@@ -24,6 +24,7 @@ internal class EksisterendeSakerMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/GosysOppgaveOpprettetMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/GosysOppgaveOpprettetMottak.kt
@@ -23,6 +23,7 @@ internal class GosysOppgaveOpprettetMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostFerdigstiltMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostFerdigstiltMottak.kt
@@ -23,6 +23,7 @@ internal class JournalpostFerdigstiltMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostMottak.kt
@@ -26,6 +26,7 @@ internal class JournalpostMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostOppdatertMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/JournalpostOppdatertMottak.kt
@@ -23,6 +23,7 @@ internal class JournalpostOppdatertMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/MinsteinntektVurderingMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/MinsteinntektVurderingMottak.kt
@@ -24,6 +24,7 @@ internal class MinsteinntektVurderingMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/OpprettArenaOppgaveMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/OpprettArenaOppgaveMottak.kt
@@ -23,6 +23,7 @@ internal class OpprettArenaOppgaveMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate {
                 it.demandAllOrAny(

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/PersondataMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/PersondataMottak.kt
@@ -24,6 +24,7 @@ internal class PersondataMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.require(key = løsning, parser = {}) }
             validate { it.requireKey("journalpostId") }

diff --git a/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/SøknadsdataMottak.kt b/mediator/src/main/kotlin/no/nav/dagpenger/mottak/tjenester/SøknadsdataMottak.kt
@@ -24,6 +24,7 @@ internal class SøknadsdataMottak(
     init {
         River(rapidsConnection).apply {
             validate { it.requireValue("@event_name", "behov") }
+            validate { it.requireValue("@final", true) }
             validate { it.require("@opprettet", JsonNode::asLocalDateTime) }
             validate { it.requireKey(løsning) }
             validate { it.requireKey("journalpostId") }