diff --git a/feil-behandler/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/feilbehandler/river/FeilLytter.kt b/feil-behandler/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/feilbehandler/river/FeilLytter.kt index 46bb5b3f1..bcdf6e842 100644 --- a/feil-behandler/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/feilbehandler/river/FeilLytter.kt +++ b/feil-behandler/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/feilbehandler/river/FeilLytter.kt @@ -14,12 +14,12 @@ import no.nav.helsearbeidsgiver.felles.json.toJson import no.nav.helsearbeidsgiver.felles.json.toMap import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.ModelUtils.toFailOrNull -import no.nav.helsearbeidsgiver.felles.rapidsrivers.toPretty import no.nav.helsearbeidsgiver.inntektsmelding.feilbehandler.prosessor.FeilProsessor import no.nav.helsearbeidsgiver.utils.json.fromJson import no.nav.helsearbeidsgiver.utils.json.parseJson import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer import no.nav.helsearbeidsgiver.utils.json.toJson +import no.nav.helsearbeidsgiver.utils.json.toPretty import no.nav.helsearbeidsgiver.utils.log.sikkerLogger import java.sql.SQLException import java.util.UUID @@ -59,7 +59,7 @@ class FeilLytter( packet: JsonMessage, context: MessageContext, ) { - sikkerLogger.info("Mottok feil: ${packet.toPretty()}") + sikkerLogger.info("Mottok feil: ${packet.toJson().parseJson().toPretty()}") val fail = toFailOrNull(packet.toJson().parseJson().toMap()) if (fail == null) { sikkerLogger.warn("Kunne ikke parse feil-objekt, ignorerer...") diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt index 6be65c410..25027df5a 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt @@ -7,24 +7,9 @@ import io.micrometer.prometheusmetrics.PrometheusConfig import io.micrometer.prometheusmetrics.PrometheusMeterRegistry import kotlinx.serialization.json.JsonElement import kotlinx.serialization.json.JsonNull -import no.nav.helsearbeidsgiver.felles.IKey import no.nav.helsearbeidsgiver.felles.Key import no.nav.helsearbeidsgiver.utils.json.parseJson import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.json.toPretty - -fun JsonMessage.toPretty(): String = toJson().parseJson().toPretty() - -fun JsonMessage.demandValues(vararg keyAndValuePairs: Pair) { - keyAndValuePairs.forEach { (key, value) -> - demandValue(key.str, value) - } -} - -fun JsonMessage.requireKeys(vararg keys: IKey) { - val keysAsStr = keys.map(IKey::str).toTypedArray() - requireKey(*keysAsStr) -} fun MessageContext.publish(vararg messageFields: Pair): JsonElement = publish(messageFields.toMap())