La til metric for aktive perioder uten opplysninger

Author: nilsmsa

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/App.kt

@@ -5,6 +5,7 @@ import io.micrometer.prometheusmetrics.PrometheusConfig
 import io.micrometer.prometheusmetrics.PrometheusMeterRegistry
 import no.nav.paw.arbeidssokerregisteret.api.v1.Periode
 import no.nav.paw.arbeidssokerregisteret.api.v4.OpplysningerOmArbeidssoeker
+import no.nav.paw.arbeidssokerregisteret.app.config.ApplicationLogicConfig
 import no.nav.paw.arbeidssokerregisteret.app.config.KafkaKonfigurasjon
 import no.nav.paw.arbeidssokerregisteret.app.helse.Helse
 import no.nav.paw.arbeidssokerregisteret.app.helse.initKtor
@@ -56,14 +57,15 @@ fun main() {
             Time.SYSTEM
         )
     )
+    val appLogicCfg: ApplicationLogicConfig = loadNaisOrLocalConfiguration(applicationLogicConfigFile)
     val topology = topology(
         prometheusMeterRegistry = prometheusMeterRegistry,
         builder = strømBygger,
         dbNavn = dbNavn,
         innTopic = kafkaKonfigurasjon.streamKonfigurasjon.eventlogTopic,
         periodeTopic = kafkaKonfigurasjon.streamKonfigurasjon.periodeTopic,
         opplysningerOmArbeidssoekerTopic = kafkaKonfigurasjon.streamKonfigurasjon.opplysningerOmArbeidssoekerTopic,
-        applicationLogicConfig = loadNaisOrLocalConfiguration(applicationLogicConfigFile)
+        applicationLogicConfig = appLogicCfg
     )
 
     val kafkaStreams = KafkaStreams(topology, StreamsConfig(kafkaKonfigurasjon.properties))
@@ -83,7 +85,7 @@ fun main() {
             stateStore().all().asSequence()
                 .mapNotNull { it.value }
         },
-        mapper = ::withMetricsInfoMapper
+        mapper = (::withMetricsInfoMapper).withAppLogicCfg(appLogicCfg)
     )
     kafkaStreams.setUncaughtExceptionHandler { throwable ->
         streamLogger.error("Uventet feil: {}", throwable.message, throwable)

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/metrics/ManglerOpplysningerMaaler.kt

@@ -0,0 +1,41 @@
+package no.nav.paw.arbeidssokerregisteret.app.metrics
+
+import io.micrometer.core.instrument.Tag
+import no.nav.paw.arbeidssokerregisteret.PROSENT
+import no.nav.paw.arbeidssokerregisteret.STILLING_STYRK08
+import no.nav.paw.arbeidssokerregisteret.app.funksjoner.isWithinWindow
+import no.nav.paw.arbeidssokerregisteret.app.tilstand.GjeldeneTilstand
+import no.nav.paw.arbeidssokerregisteret.app.tilstand.TilstandV1
+import java.time.Duration
+import java.time.Instant
+
+data class ManglerOpplysningerMaaler(
+    override val partition: Int?,
+    val manglerOpplysninger: Boolean
+): WithMetricsInfo {
+    override val name: String get() = Names.MANGLER_OPPLYSNINGER
+    override val labels: List<Tag> get() = listOf(
+        Tag.of("mangler_opplysninger", manglerOpplysninger.toString()),
+    )
+}
+
+fun manglerOpplysningerMaaler(opplysningTidsvindu: Duration, tilstand: TilstandV1): List<ManglerOpplysningerMaaler> {
+    return listOfNotNull(
+        tilstand
+            .takeIf { it.gjeldeneTilstand == GjeldeneTilstand.STARTET}
+            ?.let { aktiv ->
+                val startet = aktiv.gjeldenePeriode?.startet?.tidspunkt
+                val sisteOpplysning = aktiv.sisteOpplysningerOmArbeidssoeker?.metadata?.tidspunkt
+                when {
+                    startet == null -> null
+                    sisteOpplysning == null -> ManglerOpplysningerMaaler(partition = tilstand.hendelseScope.partition, manglerOpplysninger = true)
+                    else -> {
+                        val mangler =
+                            sisteOpplysning.isAfter(startet) ||
+                            !(opplysningTidsvindu.isWithinWindow(sisteOpplysning, startet))
+                        ManglerOpplysningerMaaler(partition = tilstand.hendelseScope.partition, manglerOpplysninger = mangler)
+                    }
+                }
+            }
+    )
+}

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/metrics/NamesAndLabels.kt

@@ -12,6 +12,7 @@ object Names {
     const val ARBEIDSSOEKER_ANTALL = "${PREFIX}_arbeidssoker_antall_v2"
     const val ARBEIDSSOEKER_JOBB_SITUASJON = "${PREFIX}_arbeidssoker_jobb_situasjon_v2"
     const val ANTALL_TILSTANDER = "${PREFIX}_arbeidssoker_antall_tilstander_v2"
+    const val MANGLER_OPPLYSNINGER = "${PREFIX}_arbeidssoker_mangler_opplysninger_v2"
 }
 
 object Labels {

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/metrics/StateGaugeTask.kt

@@ -1,6 +1,7 @@
 package no.nav.paw.arbeidssokerregisteret.app.metrics
 
 import io.micrometer.prometheusmetrics.PrometheusMeterRegistry
+import no.nav.paw.arbeidssokerregisteret.app.config.ApplicationLogicConfig
 import no.nav.paw.arbeidssokerregisteret.app.tilstand.TilstandV1
 import org.apache.kafka.streams.KafkaStreams
 import org.apache.kafka.streams.errors.InvalidStateStoreException
@@ -48,7 +49,12 @@ fun <T1> initStateGaugeTask(
         }
     }
 
-fun withMetricsInfoMapper(tilstand: TilstandV1): List<WithMetricsInfo> =
+fun withMetricsInfoMapper(logicCfg: ApplicationLogicConfig, tilstand: TilstandV1): List<WithMetricsInfo> =
     arbeidssoekerSituasjonsMaaler(tilstand) +
             listOfNotNull(arbeidssokerMaaler(tilstand)) +
-            antallTilstanderMaaler(tilstand)
+            antallTilstanderMaaler(tilstand) +
+            manglerOpplysningerMaaler(logicCfg.inkluderOpplysningerInnenforTidsvindu, tilstand)
+
+fun ((ApplicationLogicConfig, TilstandV1) -> List<WithMetricsInfo>).withAppLogicCfg(appLogicCfg: ApplicationLogicConfig) = { tilstand: TilstandV1 ->
+    this(appLogicCfg, tilstand)
+}