From 92d496c737790eb43cddcae95278bd56fbd78cd2 Mon Sep 17 00:00:00 2001 From: robertkittilsen Date: Thu, 12 Sep 2024 12:46:29 +0200 Subject: [PATCH] Bruker inngangsReglerV3 --- .../pdl/kafka/processors/PeriodeProcessor.kt | 4 ++-- .../utgang/pdl/ProcessPdlResultsV2Test.kt | 22 +++++++++---------- ...ppholdsReglerV1.kt => InngangsReglerV3.kt} | 8 ++++++- 3 files changed, 20 insertions(+), 14 deletions(-) rename domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/{OppholdsReglerV1.kt => InngangsReglerV3.kt} (87%) diff --git a/apps/utgang-pdl/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/kafka/processors/PeriodeProcessor.kt b/apps/utgang-pdl/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/kafka/processors/PeriodeProcessor.kt index 787bc53e..d1ee5bc1 100644 --- a/apps/utgang-pdl/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/kafka/processors/PeriodeProcessor.kt +++ b/apps/utgang-pdl/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/kafka/processors/PeriodeProcessor.kt @@ -6,7 +6,7 @@ import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.clients.pdl.PdlHentPerson import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.scheduleAvsluttPerioder import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.serdes.HendelseState import no.nav.paw.arbeidssokerregisteret.api.v1.Periode -import no.nav.paw.arbeidssokerregisteret.application.InngangsReglerV2 +import no.nav.paw.arbeidssokerregisteret.application.InngangsReglerV3 import no.nav.paw.arbeidssokerregisteret.intern.v1.Hendelse import org.apache.kafka.streams.kstream.KStream import org.apache.kafka.streams.kstream.Named @@ -54,7 +54,7 @@ class PeriodeProcessor( pdlHentForenkletStatus, pdlHentPersonBolk, prometheusMeterRegistry, - regler = InngangsReglerV2 + regler = InngangsReglerV3 ) } diff --git a/apps/utgang-pdl/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/ProcessPdlResultsV2Test.kt b/apps/utgang-pdl/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/ProcessPdlResultsV2Test.kt index 3bf1812e..2c6d316c 100644 --- a/apps/utgang-pdl/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/ProcessPdlResultsV2Test.kt +++ b/apps/utgang-pdl/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/utgang/pdl/ProcessPdlResultsV2Test.kt @@ -16,9 +16,9 @@ import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.isPdlResultOK import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.processPdlResultsV2 import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.processResults import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.serdes.HendelseState -import no.nav.paw.arbeidssokerregisteret.application.OppholdsReglerV1 import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.kafka.toAarsak import no.nav.paw.arbeidssoekerregisteret.utgang.pdl.utils.toAarsak +import no.nav.paw.arbeidssokerregisteret.application.InngangsReglerV3 import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Opplysning import no.nav.paw.pdl.graphql.generated.hentpersonbolk.Foedsel import no.nav.paw.pdl.graphql.generated.hentpersonbolk.HentPersonBolkResult @@ -77,7 +77,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) val outputV1 = resultV1.processResults(chunk, prometheusMeterRegistry, logger) - val outputV2 = listOf(resultV2).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val outputV2 = listOf(resultV2).processPdlResultsV2(InngangsReglerV3, chunk, logger) outputV1.shouldHaveSize(1) outputV2.shouldHaveSize(1) @@ -120,7 +120,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ val logger = mockk(relaxed = true) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) output[0].avsluttPeriode shouldBe true @@ -153,7 +153,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -187,7 +187,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -221,7 +221,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -257,7 +257,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -291,7 +291,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -328,7 +328,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) val chunk = listOf(KeyValue(hendelseState.periodeId, hendelseState)) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldHaveSize(1) val evalueringResultat = output.first() @@ -351,7 +351,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ val chunk = listOf>() - val output = results.processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = results.processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldBeEmpty() verify(exactly = 2) { logger.error(any()) } @@ -377,7 +377,7 @@ class ProcessPdlResultsV2Test : FreeSpec({ ) ) - val output = listOf(result).processPdlResultsV2(OppholdsReglerV1, chunk, logger) + val output = listOf(result).processPdlResultsV2(InngangsReglerV3, chunk, logger) output.shouldBeEmpty() verify { logger.error("Person er null for periodeId: $periodeId") } diff --git a/domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/OppholdsReglerV1.kt b/domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/InngangsReglerV3.kt similarity index 87% rename from domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/OppholdsReglerV1.kt rename to domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/InngangsReglerV3.kt index 8c38b001..22831785 100644 --- a/domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/OppholdsReglerV1.kt +++ b/domain/arbeidssoeker-regler/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/application/InngangsReglerV3.kt @@ -2,7 +2,7 @@ package no.nav.paw.arbeidssokerregisteret.application import no.nav.paw.arbeidssokerregisteret.application.opplysninger.DomeneOpplysning.* -object OppholdsReglerV1: Regler { +object InngangsReglerV3: Regler { override val regler: List = listOf( IkkeFunnet( PersonIkkeFunnet, @@ -20,16 +20,22 @@ object OppholdsReglerV1: Regler { ErForhaandsgodkjent, vedTreff = ::grunnlagForGodkjenning ), + Under18Aar( + ErUnder18Aar, + vedTreff = ::muligGrunnlagForAvvisning + ), UkjentAlder( UkjentFoedselsaar, UkjentFoedselsdato, vedTreff = ::muligGrunnlagForAvvisning ), Over18AarOgBosattEtterFregLoven( + ErOver18Aar, BosattEtterFregLoven, vedTreff = ::grunnlagForGodkjenning ), EuEoesStatsborgerOver18Aar( + ErOver18Aar, ErEuEoesStatsborger, !ErNorskStatsborger, vedTreff = ::grunnlagForGodkjenning