Legg til metrikkar for parsing, filtrering og rapid-sending

Co-authored-by: erlingjd <[email protected]>

Author: avoldsund

src/main/kotlin/no/nav/hjelpemidler/Application.kt

@@ -66,27 +66,37 @@ fun main() {
                 }
 
                 val rawJson: String = call.receiveText()
+                SensuMetrics().meldingFraOebs()
                 sikkerlogg.info("Received JSON push request from OEBS: $rawJson")
 
                 // Check for valid json request
                 val ordrelinje: Statusinfo?
                 try {
                     ordrelinje = mapper.readValue(rawJson)
                     sikkerlogg.info("Parsing incoming json request successful: ${mapper.writeValueAsString(ordrelinje)}")
-                    SensuMetrics().meldingFraOebs()
+                    SensuMetrics().oebsParsingOk()
                 } catch (e: Exception) {
                     // Deal with invalid json in request
                     sikkerlogg.info("Parsing incoming json request failed with exception (responding 4xx): $e")
-                    SensuMetrics().feilVedMeldingFraOebs()
+                    SensuMetrics().oebsParsingFeilet()
                     call.respond(HttpStatusCode.BadRequest, "bad request: json not valid")
                     return@post
                 }
 
                 if (ordrelinje!!.serviceforespørseltype != "Vedtak Infotrygd") {
-                    logg.info(
-                        "Mottok melding fra oebs med sf-type ${ordrelinje.serviceforespørseltype} og sf-status ${ordrelinje.serviceforespørselstatus}. " +
-                            "Avbryter prosesseringen og returnerer"
-                    )
+                    if (ordrelinje.serviceforespørseltype == "") {
+                        logg.info(
+                            "Mottok melding fra oebs som ikke er en SF. Avbryter prosesseringen og returnerer"
+                        )
+                        SensuMetrics().sfTypeBlank()
+                    } else {
+                        logg.info(
+                            "Mottok melding fra oebs med sf-type ${ordrelinje.serviceforespørseltype} og sf-status ${ordrelinje.serviceforespørselstatus}. " +
+                                "Avbryter prosesseringen og returnerer"
+                        )
+                        SensuMetrics().sfTypeUlikVedtakInfotrygd()
+                    }
+
                     call.respond(HttpStatusCode.OK)
                     return@post
                 }
@@ -95,6 +105,7 @@ fun main() {
                     ordrelinje.hjelpemiddeltype != "Individstyrt hjelpemiddel"
                 ) {
                     logg.info("Mottok melding fra oebs med hjelpemiddeltype ${ordrelinje.hjelpemiddeltype}.")
+                    SensuMetrics().irrelevantHjelpemiddeltype()
                     call.respond(HttpStatusCode.OK)
                     return@post
                 }

src/main/kotlin/no/nav/hjelpemidler/metrics/SensuMetrics.kt

@@ -22,19 +22,35 @@ class SensuMetrics {
         .build()
 
     fun meldingTilRapidSuksess() {
-        registerPoint(MELDING_TIL_RAPID_SUKSESS, mapOf("counter" to 1L), emptyMap())
+        registerPoint(MELDING_TIL_RAPID_OK, mapOf("counter" to 1L), emptyMap())
     }
 
     fun meldingTilRapidFeilet() {
         registerPoint(MELDING_TIL_RAPID_FEILET, mapOf("counter" to 1L), emptyMap())
     }
 
     fun meldingFraOebs() {
-        registerPoint(MELDING_FRA_OEBS, mapOf("counter" to 1L), emptyMap())
+        registerPoint(OEBS_MELDING, mapOf("counter" to 1L), emptyMap())
     }
 
-    fun feilVedMeldingFraOebs() {
-        registerPoint(OEBS_MELDING_FEIL, mapOf("counter" to 1L), emptyMap())
+    fun oebsParsingOk() {
+        registerPoint(OEBS_PARSING_OK, mapOf("counter" to 1L), emptyMap())
+    }
+
+    fun oebsParsingFeilet() {
+        registerPoint(OEBS_PARSING_FEILET, mapOf("counter" to 1L), emptyMap())
+    }
+
+    fun sfTypeBlank() {
+        registerPoint(OEBS_MELDING_SF_TYPE_BLANK, mapOf("counter" to 1L), emptyMap())
+    }
+
+    fun sfTypeUlikVedtakInfotrygd() {
+        registerPoint(OEBS_MELDING_SF_TYPE_ULIK_VEDTAK_INFOTRYGD, mapOf("counter" to 1L), emptyMap())
+    }
+
+    fun irrelevantHjelpemiddeltype() {
+        registerPoint(OEBS_MELDING_IRRELEVANT_HJELPEMIDDELTYPE, mapOf("counter" to 1L), emptyMap())
     }
 
     private fun registerPoint(measurement: String, fields: Map<String, Any>, tags: Map<String, String>) {
@@ -88,9 +104,13 @@ class SensuMetrics {
         )
 
         private const val SOKNADER = "hm-oebs-listener"
-        const val MELDING_TIL_RAPID_SUKSESS = "$SOKNADER.rapid.suksess"
-        const val MELDING_TIL_RAPID_FEILET = "$SOKNADER.rapid.feilet"
-        const val MELDING_FRA_OEBS = "$SOKNADER.oebs.melding"
-        const val OEBS_MELDING_FEIL = "$SOKNADER.oebs.feil"
+        const val MELDING_TIL_RAPID_OK = "$SOKNADER.rapidOk"
+        const val MELDING_TIL_RAPID_FEILET = "$SOKNADER.rapidFeilet"
+        const val OEBS_MELDING = "$SOKNADER.oebs.melding"
+        const val OEBS_PARSING_OK = "$SOKNADER.oebs.parsingOk"
+        const val OEBS_PARSING_FEILET = "$SOKNADER.oebs.parsingFeilet"
+        const val OEBS_MELDING_SF_TYPE_BLANK = "$SOKNADER.oebs.sfTypeBlank"
+        const val OEBS_MELDING_SF_TYPE_ULIK_VEDTAK_INFOTRYGD = "$SOKNADER.oebs.sfTypeUlikVedtakInfotrygd"
+        const val OEBS_MELDING_IRRELEVANT_HJELPEMIDDELTYPE = "$SOKNADER.oebs.irrelevantHjelpemiddeltype"
     }
 }