Merge pull request #109 from navikt/dytte_generasjon_opprettet_paa_kafka

Sender generasjon_opprettet hele veien ut på rapiden.

sykepenger-mediators/src/main/kotlin/no/nav/helse/spleis/PersonMediator.kt

@@ -219,6 +219,21 @@ internal class PersonMediator(
         )))
     }
 
+    override fun nyGenerasjon(event: PersonObserver.GenerasjonOpprettetEvent) {
+        queueMessage(JsonMessage.newMessage("generasjon_opprettet", mutableMapOf(
+            "organisasjonsnummer" to event.organisasjonsnummer,
+            "vedtaksperiodeId" to event.vedtaksperiodeId,
+            "generasjonId" to event.generasjonId,
+            "type" to event.type,
+            "kilde" to mapOf(
+                "meldingsreferanseId" to event.kilde.meldingsreferanseId,
+                "innsendt" to event.kilde.innsendt,
+                "registrert" to event.kilde.registert,
+                "avsender" to event.kilde.avsender
+            )
+        )))
+    }
+
     override fun utbetalingEndret(event: PersonObserver.UtbetalingEndretEvent) {
         queueMessage(JsonMessage.newMessage("utbetaling_endret", mapOf(
             "organisasjonsnummer" to event.organisasjonsnummer,

sykepenger-mediators/src/test/kotlin/no/nav/helse/spleis/mediator/e2e/GenerasjonerMediatorTest.kt

@@ -0,0 +1,26 @@
+package no.nav.helse.spleis.mediator.e2e
+
+import no.nav.helse.flex.sykepengesoknad.kafka.SoknadsperiodeDTO
+import no.nav.helse.januar
+import no.nav.helse.spleis.meldinger.model.SimuleringMessage
+import no.nav.inntektsmeldingkontrakt.Periode
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.Test
+
+internal class GenerasjonerMediatorTest : AbstractEndToEndMediatorTest() {
+
+    @Test
+    fun `vanlig greie burde opprette en generasjon`() {
+        sendNySøknad(SoknadsperiodeDTO(fom = 1.januar, tom = 31.januar, sykmeldingsgrad = 100))
+        sendSøknad(perioder = listOf(SoknadsperiodeDTO(fom = 1.januar, tom = 31.januar, sykmeldingsgrad = 100)))
+        sendInntektsmelding(listOf(Periode(fom = 1.januar, tom = 16.januar)), førsteFraværsdag = 1.januar)
+        sendVilkårsgrunnlag(0)
+        sendYtelser(0)
+        sendSimulering(0, SimuleringMessage.Simuleringstatus.OK)
+        sendUtbetalingsgodkjenning(0)
+        sendUtbetaling()
+
+        val generasjonMeldinger = testRapid.inspektør.meldinger("generasjon_opprettet")
+        assertEquals(1, generasjonMeldinger.size)
+    }
+}

sykepenger-mediators/src/test/kotlin/no/nav/helse/spleis/mediator/e2e/PåminnelserTest.kt

@@ -28,7 +28,7 @@ internal class PåminnelserTest : AbstractEndToEndMediatorTest() {
             perioder = listOf(SoknadsperiodeDTO(fom = 3.januar, tom = 26.januar, sykmeldingsgrad = 100))
         )
         val id = sendNyPåminnelse()
-        assertEquals(15, testRapid.inspektør.antall())
+        assertEquals(16, testRapid.inspektør.antall())
         val melding = testRapid.inspektør.meldinger("vedtaksperiode_ikke_funnet").single()
         assertEquals("vedtaksperiode_ikke_funnet", melding.path("@event_name").asText())
         assertEquals("$id", melding.path("vedtaksperiodeId").asText())

sykepenger-model/src/main/kotlin/no/nav/helse/person/PersonObserver.kt

@@ -595,10 +595,10 @@ interface PersonObserver : SykefraværstilfelleeventyrObserver {
             Revurdering
         }
         data class Kilde(
-            private val meldingsreferanseId: UUID,
-            private val innsendt: LocalDateTime,
-            private val registert: LocalDateTime,
-            private val avsender: Avsender
+            val meldingsreferanseId: UUID,
+            val innsendt: LocalDateTime,
+            val registert: LocalDateTime,
+            val avsender: Avsender
         )
     }