Deaktiverte utmelding ved stopp av 'på veiene av'

Author: nilsmsa

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/config/ApplicationConfig.kt

@@ -11,6 +11,7 @@ import java.time.Duration
 const val APPLICATION_CONFIG_FILE_NAME = "application_config.toml"
 
 data class ApplicationConfig(
+    val deaktiverUtmeldingVedStopp: Boolean = false,
     val kafkaTopology: KafkaTopologyConfig,
     val kafkaStreams: KafkaConfig,
     val azureM2M: AzureM2MConfig,

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelsePaaVegneAvStroem.kt

@@ -3,6 +3,7 @@ package no.nav.paw.bekreftelsetjeneste.topology
 import io.micrometer.prometheusmetrics.PrometheusMeterRegistry
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelseSerde
+import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloeptEtterEksternInnsamling
 import no.nav.paw.bekreftelse.paavegneav.v1.PaaVegneAv
 import no.nav.paw.bekreftelsetjeneste.config.BekreftelseKonfigurasjon
 import no.nav.paw.bekreftelsetjeneste.config.KafkaTopologyConfig
@@ -25,6 +26,7 @@ import java.time.Instant
 import java.util.*
 
 fun StreamsBuilder.byggBekreftelsePaaVegneAvStroem(
+    deaktiverUtmeldingVedStopp: Boolean = false,
     bekreftelseKonfigurasjon: BekreftelseKonfigurasjon,
     registry: PrometheusMeterRegistry,
     kafkaTopologyConfig: KafkaTopologyConfig,
@@ -52,7 +54,7 @@ fun StreamsBuilder.byggBekreftelsePaaVegneAvStroem(
                 bekreftelseTilstand = bekreftelseTilstand,
                 paaVegneAvTilstand = paaVegneAvTilstand,
                 paaVegneAvHendelse = message
-            ).map { handling ->
+            ).mapNotNull { handling ->
                 when (handling) {
                     is SendHendelse -> handling.hendelse
                     is SkrivPaaVegneAvTilstand -> paaVegneAvTilstandStateStore.put(handling.id, handling.value)
@@ -62,6 +64,7 @@ fun StreamsBuilder.byggBekreftelsePaaVegneAvStroem(
             }.filterIsInstance<BekreftelseHendelse>()
         }
         .flatMapValues { _, value -> value }
+        .filter { _, value -> (!deaktiverUtmeldingVedStopp || value !is RegisterGracePeriodeUtloeptEtterEksternInnsamling) }
         .peek { _, value -> registry.tellBekreftelseUtgaaendeHendelse(value) }
         .to(
             kafkaTopologyConfig.bekreftelseHendelseloggTopic,

apps/bekreftelse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/Topology.kt

@@ -29,6 +29,7 @@ fun StreamsBuilder.buildTopology(
         oddetallPartallMap = applicationContext.oddetallPartallMap
     )
     byggBekreftelsePaaVegneAvStroem(
+        deaktiverUtmeldingVedStopp = applicationContext.applicationConfig.deaktiverUtmeldingVedStopp,
         registry = applicationContext.prometheusMeterRegistry,
         kafkaTopologyConfig = applicationContext.applicationConfig.kafkaTopology,
         bekreftelseHendelseSerde = applicationContext.bekreftelseHendelseSerde,

apps/bekreftelse-tjeneste/src/main/resources/local/application_config.toml

@@ -1,3 +1,4 @@
+deaktiverUtmeldingVedStopp = false
 [kafkaTopology]
 applicationIdSuffix = "v1"
 internStateStoreName = "intern-tilstand"

apps/bekreftelse-tjeneste/src/main/resources/nais/application_config.toml

@@ -1,3 +1,4 @@
+deaktiverUtmeldingVedStopp = true
 [kafkaTopology]
 applicationIdSuffix = "${KAFKA_STREAMS_ID_SUFFIX}"
 internStateStoreName = "intern-tilstand"