From 4be9969f8d7aadf44717d14b387b94f7e04fbad0 Mon Sep 17 00:00:00 2001 From: Nils Martin Sande Date: Fri, 27 Sep 2024 14:01:08 +0200 Subject: [PATCH] =?UTF-8?q?Fj=C3=A6rnet=20context=20receivers=20fra=20bekr?= =?UTF-8?q?eftelse-min-side-oppgaver?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/bekreftelse-min-side-oppgaver/build.gradle.kts | 8 -------- .../bekreftelse/minsideoppgaver/applogic/Topology.kt | 5 ++--- .../testdata/mainavro/PeriodeGenerator.kt | 3 +-- 3 files changed, 3 insertions(+), 13 deletions(-) diff --git a/apps/bekreftelse-min-side-oppgaver/build.gradle.kts b/apps/bekreftelse-min-side-oppgaver/build.gradle.kts index 74f163eb..d1a2f89f 100644 --- a/apps/bekreftelse-min-side-oppgaver/build.gradle.kts +++ b/apps/bekreftelse-min-side-oppgaver/build.gradle.kts @@ -36,18 +36,10 @@ dependencies { testImplementation(project(":test:test-data-lib")) } -//enable context receiver -tasks.withType().configureEach { - compilerOptions { - freeCompilerArgs.add("-Xcontext-receivers") - } -} - tasks.withType().configureEach { useJUnitPlatform() } - jib { from.image = "$baseImage:$jvmMajorVersion" to.image = "${image ?: project.name}:${project.version}" diff --git a/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt b/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt index 8a5c8b77..f6ee8119 100644 --- a/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt +++ b/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt @@ -23,8 +23,7 @@ import java.util.* typealias InternalStateStore = KeyValueStore -context(ProcessorContext<*, *>) -fun StateStoreName.getStateStore(): InternalStateStore = getStateStore(value) +fun ProcessorContext<*, *>.getStateStore(stateStoreName: StateStoreName ): InternalStateStore = getStateStore(stateStoreName.value) private val logger = LoggerFactory.getLogger("bekreftelse.varsler.topology") @@ -36,7 +35,7 @@ fun StreamsBuilder.applicationTopology( stream(kafkaTopics.periodeTopic) .filter { _, periode -> periode.avsluttet == null } .genericProcess("lagre_periode_data", stateStoreName.value) { (_, periode) -> - val stateStore = stateStoreName.getStateStore() + val stateStore = getStateStore(stateStoreName) val gjeldeneTilstand = stateStore[periode.id] val nyTilstand = genererTilstand(gjeldeneTilstand, periode) if (nyTilstand != gjeldeneTilstand) { diff --git a/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/mainavro/PeriodeGenerator.kt b/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/mainavro/PeriodeGenerator.kt index 7732eae0..f68f900b 100644 --- a/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/mainavro/PeriodeGenerator.kt +++ b/test/test-data-lib/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/testdata/mainavro/PeriodeGenerator.kt @@ -7,8 +7,7 @@ import no.nav.paw.arbeidssokerregisteret.api.v1.Periode import java.util.* -context(KafkaKeyContext) -fun periode( +fun KafkaKeyContext.periode( periodeId: UUID = UUID.randomUUID(), identitetsnummer: String = "12345678901", startetMetadata: Metadata = metadata(),