diff --git a/akkumulator/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/InntektService.kt b/akkumulator/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/InntektService.kt index fb051ff55..6ded144ae 100644 --- a/akkumulator/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/InntektService.kt +++ b/akkumulator/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 index 5cf14e9f8..bad9fecfa 100644 --- 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/helsebro/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselL\303\270ser.kt" "b/helsebro/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselL\303\270ser.kt" index a0e9908af..1accdd530 100644 --- "a/helsebro/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselL\303\270ser.kt" +++ "b/helsebro/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/helsebro/TrengerForespoerselL\303\270ser.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.toJson(): JsonElement =