Legg til støtte for venter-status for eksterne varsler (#851)

navikt · Nov 13, 2024 · 4d96513 · 4d96513
1 parent 014caae
commit 4d96513
Show file tree

Hide file tree

Showing 4 changed files with 32 additions and 30 deletions.
diff --git a/...ain/java/no/nav/veilarbaktivitet/brukernotifikasjon/kvittering/VarselHendelseMetrikk.java b/...ain/java/no/nav/veilarbaktivitet/brukernotifikasjon/kvittering/VarselHendelseMetrikk.java
@@ -4,7 +4,7 @@
 import io.micrometer.core.instrument.MeterRegistry;
 import io.micrometer.core.instrument.Timer;
 import kotlin.enums.EnumEntries;
-import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.EksternVarsling;
+import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.EksternVarselOppdatering;
 import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.Feilet;
 import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.InternVarselHendelseDTO;
 import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.VarselHendelseEventType;
@@ -62,7 +62,7 @@ public void incrementInternVarselMetrikk(InternVarselHendelseDTO event) {
                 .increment();
     }
 
-    public void incrementVarselKvitteringMottatt(EksternVarsling event) {
+    public void incrementVarselKvitteringMottatt(EksternVarselOppdatering event) {
         var counterBuilder = Counter.builder(VARSEL_HENDELSE);
         if(event.getHendelseType() == VarselHendelseEventType.feilet_ekstern) {
             counterBuilder.tag(FEILMELDING, ((Feilet) event).getFeilmelding() );

diff --git a/.../nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/EksternVarselHendelseDTO.kt b/.../nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/EksternVarselHendelseDTO.kt
@@ -21,7 +21,7 @@ data class EksternVarselHendelseDTO(
     val kanal: EksternVarselKanal? = null
 )
 object VarselFraAnnenApp: VarselHendelse()
-sealed class EksternVarsling(
+sealed class EksternVarselOppdatering(
     val varselId: MinSideVarselId,
     val hendelseType: VarselHendelseEventType,
     val varseltype: Varseltype
@@ -30,23 +30,27 @@ sealed class EksternVarsling(
 class Renotifikasjon(
     varseltype: Varseltype,
     varselId: MinSideVarselId,
-): EksternVarsling(varselId, VarselHendelseEventType.renotifikasjon_ekstern, varseltype)
+): EksternVarselOppdatering(varselId, VarselHendelseEventType.renotifikasjon_ekstern, varseltype)
 class Sendt(
     varseltype: Varseltype,
     varselId: MinSideVarselId,
     val kanal: EksternVarselKanal
-): EksternVarsling(varselId, VarselHendelseEventType.sendt_ekstern, varseltype)
+): EksternVarselOppdatering(varselId, VarselHendelseEventType.sendt_ekstern, varseltype)
 class Bestilt(
     varseltype: Varseltype,
     varselId: MinSideVarselId,
-): EksternVarsling(varselId, VarselHendelseEventType.bestilt_ekstern, varseltype)
+): EksternVarselOppdatering(varselId, VarselHendelseEventType.bestilt_ekstern, varseltype)
 class Feilet(
     varseltype: Varseltype,
     varselId: MinSideVarselId,
     val feilmelding: String
-): EksternVarsling(varselId, VarselHendelseEventType.feilet_ekstern, varseltype)
+): EksternVarselOppdatering(varselId, VarselHendelseEventType.feilet_ekstern, varseltype)
+class Venter(
+    varseltype: Varseltype,
+    varselId: MinSideVarselId,
+): EksternVarselOppdatering(varselId, VarselHendelseEventType.venter_ekstern, varseltype)
 
-fun JsonNode.deserialiserEksternVarselHendelse(): EksternVarsling {
+fun JsonNode.deserialiserEksternVarselHendelse(): EksternVarselOppdatering {
     val eksternStatus = EksternVarselStatus.valueOf(this["status"].asText())
     val varselId = MinSideVarselId(UUID.fromString(this["varselId"].asText()))
     val varseltype = Varseltype.valueOf(this["varseltype"].asText().replaceFirstChar { it.titlecase()})
@@ -67,12 +71,15 @@ fun JsonNode.deserialiserEksternVarselHendelse(): EksternVarsling {
             )
         }
         EksternVarselStatus.feilet -> {
-            return Feilet(
+            Feilet(
                 varseltype,
                 varselId,
                 this["feilmelding"].asText()
             )
         }
+        EksternVarselStatus.venter -> {
+            Venter(varseltype, varselId)
+        }
     }
 }
 
@@ -84,5 +91,6 @@ enum class EksternVarselKanal {
 enum class EksternVarselStatus {
     bestilt,
     sendt,
-    feilet
+    feilet,
+    venter // Vi tror det skjer når meldinger batches?
 }
diff --git a/.../kotlin/no/nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/VarselHendelse.kt b/.../kotlin/no/nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/VarselHendelse.kt
@@ -13,7 +13,8 @@ enum class VarselHendelseEventType {
     sendt_ekstern,
     renotifikasjon_ekstern,
     bestilt_ekstern,
-    feilet_ekstern
+    feilet_ekstern,
+    venter_ekstern
 }
 
 const val EksternStatusOppdatertEventName = "eksternStatusOppdatert"
@@ -22,8 +23,8 @@ fun String.deserialiserVarselHendelse(): VarselHendelse {
     val jsonTree = JsonUtils.getMapper().readTree(this)
     val eventName = jsonTree["@event_name"].asText()
     val appNavn = jsonTree["appnavn"].asText()
-    val varseltype = Varseltype.valueOf(jsonTree["varseltype"].asText().replaceFirstChar { it.titlecase()})
     if (appNavn != "veilarbaktivitet") return VarselFraAnnenApp
+    val varseltype = Varseltype.valueOf(jsonTree["varseltype"].asText().replaceFirstChar { it.titlecase()})
     return when (eventName == EksternStatusOppdatertEventName) {
         true -> jsonTree.deserialiserEksternVarselHendelse()
         else -> {

diff --git a/...no/nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/VarselHendelseConsumer.kt b/...no/nav/veilarbaktivitet/brukernotifikasjon/varselStatusHendelse/VarselHendelseConsumer.kt
@@ -29,7 +29,7 @@ open class VarselHendelseConsumer(
     open fun consume(kafkaRecord: ConsumerRecord<String?, String>) {
         val melding = kafkaRecord.value().deserialiserVarselHendelse()
         when (melding) {
-            is EksternVarsling -> behandleEksternVarselHendelse(melding)
+            is EksternVarselOppdatering -> behandleEksternVarselHendelse(melding)
             is InternVarselHendelseDTO -> behandleInternVarselHendelse(melding)
             is VarselFraAnnenApp -> {}
         }
@@ -50,8 +50,8 @@ open class VarselHendelseConsumer(
         }
     }
 
-    open fun behandleEksternVarselHendelse(hendelse: EksternVarsling) {
-        val varselId = hendelse.varselId
+    open fun behandleEksternVarselHendelse(varsel: EksternVarselOppdatering) {
+        val varselId = varsel.varselId
 
         if (!varselDAO.finnesBrukernotifikasjon(varselId)) {
             log.warn(
@@ -61,34 +61,27 @@ open class VarselHendelseConsumer(
             throw IllegalArgumentException("Ugyldig varselId.")
         }
 
-//        kvitteringDAO.lagreKvitering(varselId, Kvittering(
-//            status = hendelse.status.name,
-//            melding = hendelse.feilmelding,
-//        ), hendelse)
+        log.info("Minside varsel (ekstern) av type {} er {} varselId {}", varsel.varseltype, varsel.hendelseType, varselId);
 
-        when (hendelse) {
+        when (varsel) {
             is Sendt -> {
                 kvitteringDAO.setEksternVarselStatusOK(varselId)
-                log.info("Minside varsel (ekstern) varsel sendt for varselId={} kanal={}", varselId, hendelse.kanal)
-            }
-            is Bestilt -> {
-                log.info("Minside varsel (ekstern) bestilt for varselId={}", varselId)
-            }
-            is Renotifikasjon -> {
-                log.info("Minside varsel (ekstern) renotifikasjon for varselId={}", varselId)
             }
+            is Bestilt -> {}
+            is Renotifikasjon -> {}
             is Feilet -> {
                 log.warn(
                     "Minside varsel (ekstern) feilet for varselId={} med melding {}",
                     varselId,
-                    hendelse.feilmelding
+                    varsel.feilmelding
                 )
                 kvitteringDAO.setFeilet(varselId)
             }
-            else -> {}
+
+            is Venter -> {}
         }
 
-        varselHendelseMetrikk.incrementVarselKvitteringMottatt(hendelse)
+        varselHendelseMetrikk.incrementVarselKvitteringMottatt(varsel)
     }
 
 }