Utvid bruk av loggfelter

navikt · Jul 28, 2023 · 4f1cc78 · 4f1cc78
1 parent 836f54d
commit 4f1cc78
Show file tree

Hide file tree

Showing 3 changed files with 46 additions and 33 deletions.
diff --git a/...ulator/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/InntektService.kt b/...ulator/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/InntektService.kt
@@ -66,18 +66,19 @@ class InntektService(
 
         val transaksjonId = Key.UUID.les(UuidSerializer, json)
 
+        val forespoerselId = RedisKey.of(transaksjonId.toString(), DataFelt.FORESPOERSEL_ID)
+            .readOrIllegalState("Fant ikke forespørsel-ID.")
+
         MdcUtils.withLogFields(
             "class" to simpleName(),
             "event_name" to event.name,
-            "transaksjon_id" to transaksjonId.toString()
+            "transaksjon_id" to transaksjonId.toString(),
+            "forespoersel_id" to forespoerselId
         ) {
             sikkerLogger.info("Prosesserer transaksjon $transaction.")
 
             when (transaction) {
                 Transaction.NEW -> {
-                    val forespoerselId = RedisKey.of(transaksjonId.toString(), DataFelt.FORESPOERSEL_ID)
-                        .readOrIllegalState("Fant ikke forespørsel-ID.")
-
                     rapid.publish(
                         Key.EVENT_NAME to event.toJson(),
                         Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(),
@@ -86,7 +87,7 @@ class InntektService(
                     )
                         .also {
                             MdcUtils.withLogFields(
-                                "forespoersel_id" to forespoerselId
+                                "behov" to BehovType.HENT_TRENGER_IM.name
                             ) {
                                 sikkerLogger.info("Publiserte melding:\n${it.toPretty()}.")
                             }
@@ -111,7 +112,11 @@ class InntektService(
                             Key.UUID to transaksjonId.toJson()
                         )
                             .also {
-                                sikkerLogger.info("Publiserte melding:\n${it.toPretty()}.")
+                                MdcUtils.withLogFields(
+                                    "behov" to BehovType.INNTEKT.name
+                                ) {
+                                    sikkerLogger.info("Publiserte melding:\n${it.toPretty()}.")
+                                }
                             }
                     } else {
                         logger.error("Transaksjon er underveis, men mangler data. Dette bør aldri skje, ettersom vi kun venter på én datapakke.")

diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntekt/InntektProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntekt/InntektProducer.kt
@@ -38,7 +38,7 @@ class InntektProducer(
                 .also { json ->
                     "Publiserte request om inntekt.".let {
                         logger.info(it)
-                        sikkerLogger.info("it\n${json.toPretty()}")
+                        sikkerLogger.info("$it\n${json.toPretty()}")
                     }
                 }
         }

diff --git a/...main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselLøser.kt b/...main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselLøser.kt
@@ -27,6 +27,7 @@ import no.nav.helsearbeidsgiver.utils.log.MdcUtils
 import no.nav.helsearbeidsgiver.utils.log.logger
 import no.nav.helsearbeidsgiver.utils.pipe.ifFalse
 import no.nav.helsearbeidsgiver.utils.pipe.ifTrue
+import java.util.UUID
 
 class TrengerForespoerselLøser(
     rapid: RapidsConnection,
@@ -53,38 +54,45 @@ class TrengerForespoerselLøser(
     override fun onBehov(packet: JsonMessage) {
         val json = packet.toJsonMap()
 
-        logger.info("Mottok behov om ${BehovType.HENT_TRENGER_IM}.")
-        sikkerLogger.info("Mottok behov:\n${packet.toPretty()}")
-
-        val event = Key.EVENT_NAME.les(EventName.serializer(), json)
-        val transaksjonId = Key.UUID.les(UuidSerializer, json)
-        val forespoerselId = Key.FORESPOERSEL_ID.les(UuidSerializer, json)
-
         MdcUtils.withLogFields(
             "class" to simpleName(),
-            "event_name" to event.name,
-            "behov" to BehovType.HENT_TRENGER_IM.name,
-            "transaksjon_id" to transaksjonId.toString(),
-            "forespoersel_id" to forespoerselId.toString()
+            "behov" to BehovType.HENT_TRENGER_IM.name
         ) {
-            val trengerForespoersel = TrengerForespoersel(
-                forespoerselId = forespoerselId,
-                boomerang = mapOf(
-                    Key.EVENT_NAME to event.toJson(),
-                    Key.UUID to transaksjonId.toJson()
-                ).toJson()
-            )
+            logger.info("Mottok behov om ${BehovType.HENT_TRENGER_IM}.")
+            sikkerLogger.info("Mottok behov:\n${packet.toPretty()}")
+
+            val event = Key.EVENT_NAME.les(EventName.serializer(), json)
+            val transaksjonId = Key.UUID.les(UuidSerializer, json)
+            val forespoerselId = Key.FORESPOERSEL_ID.les(UuidSerializer, json)
 
-            priProducer.send(trengerForespoersel)
-                .ifTrue {
-                    logger.info("Publiserte melding på pri-topic om ${trengerForespoersel.behov}.")
-                    sikkerLogger.info("Publiserte melding på pri-topic:\n${trengerForespoersel.toJson(TrengerForespoersel.serializer()).toPretty()}")
-                }
-                .ifFalse {
-                    logger.warn("Klarte ikke publiserte melding på pri-topic om ${trengerForespoersel.behov}.")
-                }
+            MdcUtils.withLogFields(
+                "event_name" to event.name,
+                "transaksjon_id" to transaksjonId.toString(),
+                "forespoersel_id" to forespoerselId.toString()
+            ) {
+                spoerrEtterForespoersel(event, transaksjonId, forespoerselId)
+            }
         }
     }
+
+    private fun spoerrEtterForespoersel(event: EventName, transaksjonId: UUID, forespoerselId: UUID) {
+        val trengerForespoersel = TrengerForespoersel(
+            forespoerselId = forespoerselId,
+            boomerang = mapOf(
+                Key.EVENT_NAME to event.toJson(),
+                Key.UUID to transaksjonId.toJson()
+            ).toJson()
+        )
+
+        priProducer.send(trengerForespoersel)
+            .ifTrue {
+                logger.info("Publiserte melding på pri-topic om ${trengerForespoersel.behov}.")
+                sikkerLogger.info("Publiserte melding på pri-topic:\n${trengerForespoersel.toJson(TrengerForespoersel.serializer()).toPretty()}")
+            }
+            .ifFalse {
+                logger.warn("Klarte ikke publiserte melding på pri-topic om ${trengerForespoersel.behov}.")
+            }
+    }
 }
 
 private fun Map<Key, JsonElement>.toJson(): JsonElement =