sender ut eventene sammen

steg 2 i en rakett for å sende ut én vedtaksperioder_venter-melding
navikt · Nov 26, 2024 · f00af84 · f00af84
1 parent 1c21153
commit f00af84
Show file tree

Hide file tree

Showing 5 changed files with 30 additions and 32 deletions.
diff --git a/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt b/sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt
@@ -280,25 +280,27 @@ internal class PersonMediator(
         )))
     }
 
-    override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) {
-        queueMessage(JsonMessage.newMessage("vedtaksperiode_venter", mapOf(
-            "organisasjonsnummer" to event.organisasjonsnummer,
-            "vedtaksperiodeId" to event.vedtaksperiodeId,
-            "behandlingId" to event.behandlingId,
-            "skjæringstidspunkt" to event.skjæringstidspunkt,
-            "hendelser" to event.hendelser,
-            "ventetSiden" to event.ventetSiden,
-            "venterTil" to event.venterTil,
-            "venterPå" to mapOf(
-                "vedtaksperiodeId" to event.venterPå.vedtaksperiodeId,
-                "skjæringstidspunkt" to event.venterPå.skjæringstidspunkt,
-                "organisasjonsnummer" to event.venterPå.organisasjonsnummer,
-                "venteårsak" to mapOf(
-                    "hva" to event.venterPå.venteårsak.hva,
-                    "hvorfor" to event.venterPå.venteårsak.hvorfor
+    override fun vedtaksperioderVenter(eventer: List<PersonObserver.VedtaksperiodeVenterEvent>) {
+        eventer.forEach { event ->
+            queueMessage(JsonMessage.newMessage("vedtaksperiode_venter", mapOf(
+                "organisasjonsnummer" to event.organisasjonsnummer,
+                "vedtaksperiodeId" to event.vedtaksperiodeId,
+                "behandlingId" to event.behandlingId,
+                "skjæringstidspunkt" to event.skjæringstidspunkt,
+                "hendelser" to event.hendelser,
+                "ventetSiden" to event.ventetSiden,
+                "venterTil" to event.venterTil,
+                "venterPå" to mapOf(
+                    "vedtaksperiodeId" to event.venterPå.vedtaksperiodeId,
+                    "skjæringstidspunkt" to event.venterPå.skjæringstidspunkt,
+                    "organisasjonsnummer" to event.venterPå.organisasjonsnummer,
+                    "venteårsak" to mapOf(
+                        "hva" to event.venterPå.venteårsak.hva,
+                        "hvorfor" to event.venterPå.venteårsak.hvorfor
+                    )
                 )
-            )
-        )))
+            )))
+        }
     }
 
     override fun vedtaksperiodeOpprettet(event: PersonObserver.VedtaksperiodeOpprettet) {

diff --git a/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt b/sykepenger-model/src/main/kotlin/no/nav/helse/person/Person.kt
@@ -484,10 +484,6 @@ class Person private constructor(
         observers.forEach { it.vedtaksperiodeEndret(event) }
     }
 
-    internal fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) {
-        observers.forEach { it.vedtaksperiodeVenter(event) }
-    }
-
     internal fun inntektsmeldingReplay(
         vedtaksperiodeId: UUID,
         skjæringstidspunkt: LocalDate,
@@ -801,11 +797,9 @@ class Person private constructor(
             is Sykmelding -> { /* Sykmelding fører ikke til endringer i tiltander, så sender ikke signal etter håndtering av den */ }
             else -> {
                 val nestemann = arbeidsgivere.nestemann() ?: return
-                arbeidsgivere.venter(nestemann)
+                val eventer = arbeidsgivere.venter(nestemann)
                     .map { it.event() }
-                    .forEach { event ->
-                        observers.forEach { it.vedtaksperiodeVenter(event) }
-                    }
+                observers.forEach { it.vedtaksperioderVenter(eventer) }
             }
         }
     }

diff --git a/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt b/sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt
@@ -620,7 +620,7 @@ interface PersonObserver {
     fun vedtaksperiodePåminnet(vedtaksperiodeId: UUID, organisasjonsnummer: String, påminnelse: Påminnelse) {}
     fun vedtaksperiodeIkkePåminnet(vedtaksperiodeId: UUID, organisasjonsnummer: String, nåværendeTilstand: TilstandType) {}
     fun vedtaksperiodeEndret(event: VedtaksperiodeEndretEvent) {}
-    fun vedtaksperiodeVenter(event: VedtaksperiodeVenterEvent) {}
+    fun vedtaksperioderVenter(eventer: List<VedtaksperiodeVenterEvent>) {}
     fun vedtaksperiodeForkastet(event: VedtaksperiodeForkastetEvent) {}
     fun vedtaksperiodeIkkeFunnet(event: VedtaksperiodeIkkeFunnetEvent) {}
     fun sykefraværstilfelleIkkeFunnet(event: SykefraværstilfelleIkkeFunnet) {}

diff --git a/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservatør.kt b/sykepenger-model/src/test/kotlin/no/nav/helse/dsl/UgyldigeSituasjonerObservatør.kt
@@ -137,9 +137,11 @@ internal class UgyldigeSituasjonerObservatør(private val person: Person): Perso
         søknader[søknadId] = null
     }
 
-    override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) = sjekk {
-        sjekkUgyldigeVentesituasjoner(event)
-        sjekkSøknadIdEierskap(event.vedtaksperiodeId, event.hendelser)
+    override fun vedtaksperioderVenter(eventer: List<PersonObserver.VedtaksperiodeVenterEvent>) = sjekk {
+        eventer.forEach { event ->
+            sjekkUgyldigeVentesituasjoner(event)
+            sjekkSøknadIdEierskap(event.vedtaksperiodeId, event.hendelser)
+        }
     }
 
     private fun sjekkUgyldigeVentesituasjoner(event: PersonObserver.VedtaksperiodeVenterEvent) {

diff --git a/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservatør.kt b/sykepenger-model/src/test/kotlin/no/nav/helse/spleis/e2e/TestObservatør.kt
@@ -78,8 +78,8 @@ internal class TestObservatør(person: Person? = null) : PersonObserver {
         inntektsmeldingReplayEventer.removeAll { it.vedtaksperiodeId == vedtaksperiodeId }
     }
 
-    override fun vedtaksperiodeVenter(event: PersonObserver.VedtaksperiodeVenterEvent) {
-        vedtaksperiodeVenter.add(event)
+    override fun vedtaksperioderVenter(eventer: List<PersonObserver.VedtaksperiodeVenterEvent>) {
+        vedtaksperiodeVenter.addAll(eventer)
     }
 
     fun forkastedePerioder() = forkastedeEventer.size