diff --git a/apps/bekreftelse-api/nais/nais-dev.yaml b/apps/bekreftelse-api/nais/nais-dev.yaml index 5802a444..b5d0d6d3 100644 --- a/apps/bekreftelse-api/nais/nais-dev.yaml +++ b/apps/bekreftelse-api/nais/nais-dev.yaml @@ -10,7 +10,7 @@ spec: port: 8080 env: - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_TOPIC - value: "paw.arbeidssoker-bekreftelse-beta-v1" + value: "paw.arbeidssoker-bekreftelse-beta-v2" - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_HENDELSESLOGG_TOPIC value: "paw.arbeidssoker-bekreftelse-hendelseslogg-beta-v2" - name: CORS_ALLOW_ORIGINS diff --git a/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt b/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt index 9e754c47..74a671e5 100644 --- a/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt +++ b/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt @@ -2,6 +2,7 @@ package no.nav.paw.bekreftelse.api.model import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig import no.nav.paw.bekreftelse.melding.v1.Bekreftelse +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.bekreftelse.melding.v1.vo.Bruker import no.nav.paw.bekreftelse.melding.v1.vo.Metadata import no.nav.paw.bekreftelse.melding.v1.vo.Svar @@ -21,10 +22,10 @@ fun BekreftelseTilgjengelig.asBekreftelse( bruker: Bruker, kilde: String, aarsak: String, - namespace: String + bekreftelsesloesning: Bekreftelsesloesning ): Bekreftelse { return Bekreftelse.newBuilder() - .setNamespace(namespace) + .setBekreftelsesloesning(bekreftelsesloesning) .setId(bekreftelseId) .setPeriodeId(periodeId) .setSvar( diff --git a/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt b/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt index 63a373e3..01975cae 100644 --- a/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt +++ b/apps/bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt @@ -31,8 +31,8 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseMeldingMottatt import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig import no.nav.paw.bekreftelse.internehendelser.PeriodeAvsluttet import no.nav.paw.bekreftelse.internehendelser.meldingMottattHendelseType +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.config.env.appImageOrDefaultForLocal -import no.nav.paw.config.env.namespaceOrDefaultForLocal import org.apache.kafka.clients.consumer.ConsumerRecord import org.jetbrains.exposed.sql.transactions.transaction @@ -65,7 +65,6 @@ class BekreftelseService( meterRegistry.receiveBekreftelseCounter(meldingMottattHendelseType) val kilde = serverConfig.runtimeEnvironment.appImageOrDefaultForLocal() - val namespace = serverConfig.runtimeEnvironment.namespaceOrDefaultForLocal() val bekreftelse = bekreftelseRepository.getByBekreftelseId(request.bekreftelseId) if (bekreftelse != null) { @@ -78,8 +77,8 @@ class BekreftelseService( request.vilFortsetteSomArbeidssoeker, innloggetBruker.asBruker(), kilde, - "Mottok bekreftelse", // TODO Hva skal dette være - namespace + "Bekreftelse levert", + Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET ) logger.debug("Sletter bekreftelse fra database") diff --git a/apps/bekreftelse-tjeneste/nais/nais-dev.yaml b/apps/bekreftelse-tjeneste/nais/nais-dev.yaml index 6b92016d..e22d30fb 100644 --- a/apps/bekreftelse-tjeneste/nais/nais-dev.yaml +++ b/apps/bekreftelse-tjeneste/nais/nais-dev.yaml @@ -12,7 +12,7 @@ spec: - name: KAFKA_STREAMS_ID_SUFFIX value: "v3" - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_TOPIC - value: "paw.arbeidssoker-bekreftelse-beta-v1" + value: "paw.arbeidssoker-bekreftelse-beta-v2" - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_HENDELSELOGG_TOPIC value: "paw.arbeidssoker-bekreftelse-hendelseslogg-beta-v2" - name: KAFKA_PAW_ARBEIDSSOKERPERIODER_TOPIC diff --git a/apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt b/apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt index 52d9a17a..5aded379 100644 --- a/apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt +++ b/apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt @@ -10,6 +10,7 @@ import no.nav.paw.bekreftelse.internehendelser.BaOmAaAvsluttePeriode import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelseSerde import no.nav.paw.bekreftelse.internehendelser.BekreftelseMeldingMottatt +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.bekreftelsetjeneste.config.ApplicationConfig import no.nav.paw.bekreftelsetjeneste.tilstand.* import no.nav.paw.config.kafka.streams.Punctuation @@ -47,7 +48,7 @@ fun StreamsBuilder.buildBekreftelseStream(applicationConfig: ApplicationConfig) return@genericProcess } - if (record.value().namespace == "paw") { + if (record.value().bekreftelsesloesning == Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET) { val (nyTilstand, hendelser) = processPawNamespace(record.value(), gjeldendeTilstand) if (nyTilstand != gjeldendeTilstand) { stateStore.put(gjeldendeTilstand.periode.periodeId, nyTilstand) diff --git a/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt b/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt index 7344be1f..1aadd46f 100644 --- a/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt +++ b/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt @@ -13,6 +13,7 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig import no.nav.paw.bekreftelse.internehendelser.LeveringsfristUtloept import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeGjenstaaendeTid import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.bekreftelse.melding.v1.vo.BrukerType import no.nav.paw.bekreftelse.melding.v1.vo.Metadata import no.nav.paw.bekreftelse.melding.v1.vo.Svar @@ -179,7 +180,7 @@ class BekreftelsePunctuatorTest : FreeSpec({ val currentState = stateStore.get(periode.id) bekreftelseTopic.pipeInput( key, no.nav.paw.bekreftelse.melding.v1.Bekreftelse( - periode.id, "paw", currentState.bekreftelser.first().bekreftelseId, Svar( + periode.id, Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, currentState.bekreftelser.first().bekreftelseId, Svar( Metadata( Instant.now(), no.nav.paw.bekreftelse.melding.v1.vo.Bruker( BrukerType.SLUTTBRUKER, "12345678901" @@ -227,7 +228,7 @@ class BekreftelsePunctuatorTest : FreeSpec({ val currentState = stateStore.get(periode.id) bekreftelseTopic.pipeInput( key, no.nav.paw.bekreftelse.melding.v1.Bekreftelse( - periode.id, "paw", currentState.bekreftelser.first().bekreftelseId, Svar( + periode.id, Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, currentState.bekreftelser.first().bekreftelseId, Svar( Metadata( Instant.now(), no.nav.paw.bekreftelse.melding.v1.vo.Bruker( BrukerType.SLUTTBRUKER, "12345678901" diff --git a/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt b/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt index a6425a20..089fdf2f 100644 --- a/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt +++ b/apps/bekreftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt @@ -11,6 +11,7 @@ import no.nav.paw.arbeidssoekerregisteret.testdata.kafkaKeyContext import no.nav.paw.arbeidssoekerregisteret.testdata.mainavro.metadata import no.nav.paw.arbeidssoekerregisteret.testdata.mainavro.periode import no.nav.paw.bekreftelse.internehendelser.* +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.bekreftelsetjeneste.tilstand.* import no.nav.paw.test.assertEvent import no.nav.paw.test.seconds @@ -26,7 +27,7 @@ class BekreftelseStreamTest : FreeSpec({ with(ApplicationTestContext(initialWallClockTime = startTime)) { val bekreftelseMelding = bekreftelseMelding( periodeId = UUID.randomUUID(), - namespace = "tullball", + bekreftelsesloesning = Bekreftelsesloesning.DAGPENGER, gjelderFra = Instant.now(), gjelderTil = Instant.now(), harJobbetIDennePerioden = true, @@ -69,7 +70,7 @@ class BekreftelseStreamTest : FreeSpec({ val bekreftelseMelding = bekreftelseMelding( id = bekreftelseId, periodeId = periode.id, - namespace = "paw", + bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, gjelderFra = startTime, gjelderTil = startTime.plus(interval), harJobbetIDennePerioden = true, @@ -135,7 +136,7 @@ class BekreftelseStreamTest : FreeSpec({ val bekreftelseMelding = bekreftelseMelding( id = bekreftelseId, periodeId = periode.id, - namespace = "paw", + bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, gjelderFra = startTime, gjelderTil = fristForNesteBekreftelse(periode.startet.tidspunkt, interval, startTime), harJobbetIDennePerioden = true, @@ -200,7 +201,7 @@ class BekreftelseStreamTest : FreeSpec({ val bekreftelseMelding = bekreftelseMelding( id = bekreftelseId, periodeId = periode.id, - namespace = "paw", + bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, gjelderFra = startTime, gjelderTil = fristForNesteBekreftelse(periode.startet.tidspunkt, interval, startTime), harJobbetIDennePerioden = true, diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index b5a8f71e..d4bef871 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -2,7 +2,7 @@ pawPdlClientVersion = "24.10.18.41-1" pawAaregClientVersion = "24.07.04.18-1" arbeidssokerregisteretVersion = "1.9348086045.48-1" -bekreftelseSchemaVersion = "24.09.16.1-1" +bekreftelseSchemaVersion = "24.10.21.12-1" arrowVersion = "1.2.4" arrowJacksonIntegrationVersion = "0.14.1" noNavCommonVersion = "3.2024.05.23_05.46-2b29fa343e8e" diff --git a/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt b/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt index 40bd6ec8..a1436815 100644 --- a/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt +++ b/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt @@ -1,6 +1,7 @@ package no.nav.paw.arbeidssoekerregisteret.testdata.bekreftelse import no.nav.paw.bekreftelse.melding.v1.Bekreftelse +import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning import no.nav.paw.bekreftelse.melding.v1.vo.Bruker import no.nav.paw.bekreftelse.melding.v1.vo.BrukerType import no.nav.paw.bekreftelse.melding.v1.vo.Svar @@ -11,7 +12,7 @@ import java.util.* fun bekreftelseMelding( id: UUID = UUID.randomUUID(), periodeId: UUID = UUID.randomUUID(), - namespace: String = "paw", + bekreftelsesloesning: Bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, gjelderFra: Instant = Instant.now(), gjelderTil: Instant = Instant.now(), harJobbetIDennePerioden: Boolean = true, @@ -20,7 +21,7 @@ fun bekreftelseMelding( Bekreftelse .newBuilder() .setPeriodeId(periodeId) - .setNamespace(namespace) + .setBekreftelsesloesning(bekreftelsesloesning) .setId(id) .setSvar( Svar