Skip to content

Commit

Permalink
Bruker inngangsReglerV3
Browse files Browse the repository at this point in the history
  • Loading branch information
robertkittilsen committed Sep 12, 2024
1 parent 23e3abc commit 92d496c
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -54,7 +54,7 @@ class PeriodeProcessor(
pdlHentForenkletStatus,
pdlHentPersonBolk,
prometheusMeterRegistry,
regler = InngangsReglerV2
regler = InngangsReglerV3
)
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -120,7 +120,7 @@ class ProcessPdlResultsV2Test : FreeSpec({

val logger = mockk<Logger>(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
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand All @@ -351,7 +351,7 @@ class ProcessPdlResultsV2Test : FreeSpec({

val chunk = listOf<KeyValue<UUID, HendelseState>>()

val output = results.processPdlResultsV2(OppholdsReglerV1, chunk, logger)
val output = results.processPdlResultsV2(InngangsReglerV3, chunk, logger)

output.shouldBeEmpty()
verify(exactly = 2) { logger.error(any()) }
Expand All @@ -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") }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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<Regel> = listOf(
IkkeFunnet(
PersonIkkeFunnet,
Expand All @@ -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
Expand Down

0 comments on commit 92d496c

Please sign in to comment.