La til mer tracing for bekreftelse

Author: nilsmsa

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

@@ -1,6 +1,9 @@
 package no.nav.paw.bekreftelsetjeneste.topology
 
 import arrow.core.andThen
+import io.opentelemetry.api.common.Attributes
+import io.opentelemetry.api.trace.Span
+import io.opentelemetry.api.trace.SpanKind.INTERNAL
 import io.opentelemetry.instrumentation.annotations.WithSpan
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig
@@ -9,6 +12,7 @@ import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeGjenstaaendeT
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept
 import no.nav.paw.bekreftelsetjeneste.tilstand.Bekreftelse
 import no.nav.paw.bekreftelsetjeneste.tilstand.BekreftelseTilstand
+import no.nav.paw.bekreftelsetjeneste.tilstand.BekreftelseTilstandStatus
 import no.nav.paw.bekreftelsetjeneste.tilstand.BekreftelseTilstandsLogg
 import no.nav.paw.bekreftelsetjeneste.tilstand.GracePeriodeUtloept
 import no.nav.paw.bekreftelsetjeneste.tilstand.GracePeriodeVarselet
@@ -30,7 +34,8 @@ import java.util.*
 
 
 @WithSpan(
-
+    value = "punctuator_process bekreftelse_tilstand",
+    kind = INTERNAL
 )
 fun BekreftelseContext.prosesser(bekreftelseTilstand: BekreftelseTilstand): BekreftelseProsesseringsResultat =
     (::opprettInitielBekreftelse andThen
@@ -54,6 +59,15 @@ fun BekreftelseContext.opprettInitielBekreftelse(bekreftelser: List<Bekreftelse>
             startTid = fra,
             interval = konfigurasjon.interval
         )
+        Span.current().addEvent(
+            intern,
+            Attributes.of(
+                actionKey, bekreftelseOpprettetAction,
+                initielBekreftelseKey, true,
+                fraOgMedDagKey, fra.tilFraTilAttributeKeyValue(),
+                tilDagKey, til.tilFraTilAttributeKeyValue()
+            )
+        )
         pawNonEmptyListOf(
             Bekreftelse(
                 bekreftelseId = UUID.randomUUID(),
@@ -72,10 +86,21 @@ fun BekreftelseContext.opprettManglendeBekreftelser(bekreftelser: PawNonEmptyLis
     val siste = bekreftelser.maxBy { it.gjelderTil }
     val ventende = bekreftelser.toList().filter { it.sisteTilstand() is VenterPaaSvar }
     return if (siste.gjelderTil.isBefore(wallClock.value) && ventende.size < konfigurasjon.maksAntallVentendeBekreftelser) {
+        val fra = siste.gjelderTil
+        val til = sluttTidForBekreftelsePeriode(siste.gjelderTil, konfigurasjon.interval)
+        Span.current().addEvent(
+            intern,
+            Attributes.of(
+                actionKey, bekreftelseOpprettetAction,
+                initielBekreftelseKey, true,
+                fraOgMedDagKey, fra.tilFraTilAttributeKeyValue(),
+                tilDagKey, til.tilFraTilAttributeKeyValue()
+            )
+        )
         val neste = Bekreftelse(
             bekreftelseId = UUID.randomUUID(),
-            gjelderFra = siste.gjelderTil,
-            gjelderTil = sluttTidForBekreftelsePeriode(siste.gjelderTil, konfigurasjon.interval),
+            gjelderFra = fra,
+            gjelderTil = til,
             tilstandsLogg = BekreftelseTilstandsLogg(
                 siste = IkkeKlarForUtfylling(wallClock.value),
                 tidligere = emptyList()
@@ -91,7 +116,7 @@ fun BekreftelseContext.oppdaterBekreftelser(bekreftelser: PawNonEmptyList<Bekref
     bekreftelser.map { bekreftelse ->
         when {
             bekreftelse.erKlarForUtfylling(wallClock.value, konfigurasjon.tilgjengeligOffset) -> {
-                bekreftelse.plus(KlarForUtfylling(wallClock.value)) to BekreftelseTilgjengelig(
+                bekreftelse.setStatus(KlarForUtfylling(wallClock.value)) to BekreftelseTilgjengelig(
                     hendelseId = UUID.randomUUID(),
                     periodeId = periodeInfo.periodeId,
                     arbeidssoekerId = periodeInfo.arbeidsoekerId,
@@ -103,7 +128,7 @@ fun BekreftelseContext.oppdaterBekreftelser(bekreftelser: PawNonEmptyList<Bekref
             }
 
             bekreftelse.harFristUtloept(wallClock.value) -> {
-                bekreftelse.plus(VenterSvar(wallClock.value)) to LeveringsfristUtloept(
+                bekreftelse.setStatus(VenterSvar(wallClock.value)) to LeveringsfristUtloept(
                     hendelseId = UUID.randomUUID(),
                     periodeId = periodeInfo.periodeId,
                     arbeidssoekerId = periodeInfo.arbeidsoekerId,
@@ -117,7 +142,7 @@ fun BekreftelseContext.oppdaterBekreftelser(bekreftelser: PawNonEmptyList<Bekref
                 wallClock.value,
                 konfigurasjon.varselFoerGraceperiodeUtloept
             ) -> {
-                bekreftelse.plus(GracePeriodeVarselet(wallClock.value)) to RegisterGracePeriodeGjenstaaendeTid(
+                bekreftelse.setStatus(GracePeriodeVarselet(wallClock.value)) to RegisterGracePeriodeGjenstaaendeTid(
                     hendelseId = UUID.randomUUID(),
                     periodeId = periodeInfo.periodeId,
                     arbeidssoekerId = periodeInfo.arbeidsoekerId,
@@ -131,7 +156,7 @@ fun BekreftelseContext.oppdaterBekreftelser(bekreftelser: PawNonEmptyList<Bekref
             }
 
             bekreftelse.harGraceperiodeUtloept(wallClock.value, konfigurasjon.graceperiode) -> {
-                bekreftelse.plus(GracePeriodeUtloept(wallClock.value)) to RegisterGracePeriodeUtloept(
+                bekreftelse.setStatus(GracePeriodeUtloept(wallClock.value)) to RegisterGracePeriodeUtloept(
                     hendelseId = UUID.randomUUID(),
                     periodeId = periodeInfo.periodeId,
                     arbeidssoekerId = periodeInfo.arbeidsoekerId,
@@ -148,3 +173,15 @@ fun BekreftelseContext.oppdaterBekreftelser(bekreftelser: PawNonEmptyList<Bekref
         oppdaterteBekreftelser to hendelser
     }
 
+fun Bekreftelse.setStatus(nyStatus: BekreftelseTilstandStatus): Bekreftelse {
+    val siste = sisteTilstand()
+    Span.current().addEvent(
+        intern,
+        Attributes.of(
+            actionKey, bekreftelseSattStatusAction,
+            nyBekreftelseStatusKey, nyStatus::class.simpleName?.snakeCase() ?: "ukjent",
+            gjeldeneBekreftelseStatusKey, siste::class.simpleName?.snakeCase() ?: "ukjent"
+        )
+    )
+    return this + nyStatus
+}

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

@@ -1,23 +1,45 @@
 package no.nav.paw.bekreftelsetjeneste.topology
 
 import io.opentelemetry.api.common.AttributeKey
+import java.time.Instant
+import java.time.LocalDate
+import java.time.ZoneId
+import java.time.format.DateTimeFormatter
 
 //hendelser
+const val intern = "intern"
 const val okEvent = "ok"
 const val errorEvent = "error"
 
+
 //felles
 val bekreftelseloesingKey = AttributeKey.stringKey("bekreftelsesloesning")
 val periodeFunnetKey = AttributeKey.booleanKey("periode_funnet")
 val harAnsvarKey = AttributeKey.booleanKey("har_ansvar")
 val feilMeldingKey = AttributeKey.stringKey("feilmelding")
 val domainKey = AttributeKey.stringKey("domain")
 val actionKey = AttributeKey.stringKey("action")
+val fraOgMedDagKey = AttributeKey.stringKey("fra_og_meg_dag")
+val tilDagKey = AttributeKey.stringKey("til_dag")
+
+private val fraTilKeyValueformatter = DateTimeFormatter.ofPattern("yyyyMMdd")
+val norskTid = ZoneId.of("Europe/Oslo")
+fun Instant.tilFraTilAttributeKeyValue(): String = LocalDate.ofInstant(this, norskTid).format(fraTilKeyValueformatter)
 
 //Bekreftelse
 val tilstandKey = AttributeKey.stringKey("tilstand")
+val initielBekreftelseKey = AttributeKey.booleanKey("initiel_bekreftelse")
+val nyBekreftelseStatusKey = AttributeKey.stringKey("ny_bekreftelse_status")
+val gjeldeneBekreftelseStatusKey = AttributeKey.stringKey("gjeldene_bekreftelse_status")
 const val bekreftelseLevertAction = "bekreftelse_levert"
+const val bekreftelseOpprettetAction = "bekreftelse_opprettet"
+const val bekreftelseSattStatusAction = "bekreftelse_satt_status"
+
 
 //PaaVegneAv
 const val paaVegneAvStartet ="paa_vegne_av_startet"
 const val paaVegneAvStoppet ="paa_vegne_av_stoppet"
+val registerFristUtloept = AttributeKey.booleanKey("register_frist_utloept")
+
+
+fun String.snakeCase(): String = this.replace(Regex("([a-z])([A-Z]+)"), "$1_$2").lowercase()

lib/tracing/src/main/kotlin/no/nav/paw/tracing/SpanAttribute.kt

@@ -0,0 +1,16 @@
+package no.nav.paw.tracing
+
+const val SPAN_ATTRIBUTE_PREFIX = "nav.arbeidssoekerregisteret"
+const val PATH_SEPARATOR = "."
+
+interface Domene {
+
+}
+
+fun spanAttributeName(domene: Domene): String = TODO()
+
+
+
+fun test() {
+
+}