From 69093db3e56d39c5004e7f7511bea92906692601 Mon Sep 17 00:00:00 2001 From: Mikael Bjerga Date: Wed, 26 Jun 2024 10:35:07 +0200 Subject: [PATCH] Legg til flere tester for lagring av selvbestemt IM --- .../HentSelvbestemtImRoute.kt | 48 ++--- .../InntektSelvbestemtProducer.kt | 6 +- .../LagreSelvbestemtImRoute.kt | 31 +-- .../HentSelvbestemtImRouteKtTest.kt | 2 +- .../InntektSelvbestemtProducerTest.kt | 4 +- .../LagreSelvbestemtImRouteKtTest.kt | 192 ++++++++++++++++-- .../InntektSelvbestemtService.kt | 4 +- .../InntektSelvbestemtServiceTest.kt | 4 +- .../integrasjonstest/InntektSelvbestemtIT.kt | 8 +- .../integrasjonstest/TrengerIT.kt | 2 +- .../HentSelvbestemtImService.kt | 5 +- 11 files changed, 235 insertions(+), 71 deletions(-) diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRoute.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRoute.kt index d39cde96d..d5b340461 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRoute.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRoute.kt @@ -55,32 +55,28 @@ fun Route.hentSelvbestemtImRoute( ) { producer.publish(transaksjonId, selvbestemtId) - MdcUtils.withLogFields( - Log.transaksjonId(transaksjonId) - ) { - runCatching { - redisPoller.hent(transaksjonId) - } - .onSuccess { - val result = it.fromJson(ResultJson.serializer()) + runCatching { + redisPoller.hent(transaksjonId) + } + .onSuccess { + val result = it.fromJson(ResultJson.serializer()) - val inntektsmelding = result.success?.fromJson(Inntektsmelding.serializer()) + val inntektsmelding = result.success?.fromJson(Inntektsmelding.serializer()) - if (inntektsmelding != null) { - tilgangskontroll.validerTilgangTilOrg(call.request, inntektsmelding.avsender.orgnr.verdi) - sendOkResponse(inntektsmelding) - } else { - val feilmelding = result.failure - ?.fromJson(String.serializer()) - .orDefault("Ukjent feil.") + if (inntektsmelding != null) { + tilgangskontroll.validerTilgangTilOrg(call.request, inntektsmelding.avsender.orgnr.verdi) + sendOkResponse(inntektsmelding) + } else { + val feilmelding = result.failure + ?.fromJson(String.serializer()) + .orDefault("Ukjent feil.") - sendErrorResponse(feilmelding) - } + sendErrorResponse(feilmelding) } - .onFailure { - sendRedisErrorResponse(selvbestemtId, it) - } - } + } + .onFailure { + sendRedisErrorResponse(selvbestemtId, it) + } } } } @@ -99,8 +95,8 @@ private suspend fun PipelineContext.sendOkResponse(inntek private suspend fun PipelineContext.sendErrorResponse(feilmelding: String) { "Klarte ikke hente inntektsmelding pga. feil.".also { - logger.info(it) - sikkerLogger.info("$it Feilmelding: '$feilmelding'") + logger.error(it) + sikkerLogger.error("$it Feilmelding: '$feilmelding'") } val response = ResultJson( failure = HentSelvbestemtImResponseFailure(feilmelding).toJson(HentSelvbestemtImResponseFailure.serializer()) @@ -110,8 +106,8 @@ private suspend fun PipelineContext.sendErrorResponse(fei private suspend fun PipelineContext.sendRedisErrorResponse(selvbestemtId: UUID, error: Throwable) { "Klarte ikke hente inntektsmelding pga. feil i Redis.".also { - logger.info(it) - sikkerLogger.info(it, error) + logger.error(it) + sikkerLogger.error(it, error) } when (error) { is RedisPollerTimeoutException -> { diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt index cc319103c..8236276f1 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt @@ -11,8 +11,6 @@ import no.nav.helsearbeidsgiver.inntektsmelding.api.sikkerLogger import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.json.toPretty import no.nav.helsearbeidsgiver.utils.log.MdcUtils -import no.nav.helsearbeidsgiver.utils.wrapper.Fnr -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID class InntektSelvbestemtProducer( @@ -32,8 +30,8 @@ class InntektSelvbestemtProducer( Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.UUID to transaksjonId.toJson(), Key.DATA to "".toJson(), - Key.FNR to request.sykmeldtFnr.toJson(Fnr.serializer()), - Key.ORGNRUNDERENHET to request.orgnr.toJson(Orgnr.serializer()), + Key.FNR to request.sykmeldtFnr.toJson(), + Key.ORGNRUNDERENHET to request.orgnr.toJson(), Key.SKJAERINGSTIDSPUNKT to request.inntektsdato.toJson() ) .also { json -> diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRoute.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRoute.kt index e2a6d285c..dbc501550 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRoute.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRoute.kt @@ -1,6 +1,5 @@ package no.nav.helsearbeidsgiver.inntektsmelding.api.lagreselvbestemtim -import io.ktor.http.HttpStatusCode import io.ktor.server.application.ApplicationCall import io.ktor.server.application.call import io.ktor.server.request.receiveText @@ -26,9 +25,9 @@ import no.nav.helsearbeidsgiver.inntektsmelding.api.response.RedisTimeoutRespons import no.nav.helsearbeidsgiver.inntektsmelding.api.response.UkjentErrorResponse import no.nav.helsearbeidsgiver.inntektsmelding.api.response.ValideringErrorResponse import no.nav.helsearbeidsgiver.inntektsmelding.api.sikkerLogger -import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respond import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respondBadRequest import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respondInternalServerError +import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respondOk import no.nav.helsearbeidsgiver.utils.json.fromJson import no.nav.helsearbeidsgiver.utils.json.parseJson import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer @@ -37,7 +36,6 @@ import no.nav.helsearbeidsgiver.utils.log.MdcUtils import no.nav.helsearbeidsgiver.utils.pipe.orDefault import java.util.UUID -// TODO test fun Route.lagreSelvbestemtImRoute( rapid: RapidsConnection, tilgangskontroll: Tilgangskontroll, @@ -78,12 +76,11 @@ fun Route.lagreSelvbestemtImRoute( producer.publish(clientId, skjema, avsenderFnr) - runCatching { + val resultat = runCatching { redisPoller.hent(clientId) } - .let { - sendResponse(it) - } + + sendResponse(resultat) } } } @@ -126,11 +123,15 @@ private suspend fun PipelineContext.sendResponse(resultat sikkerLogger.info(it) } } - respond(HttpStatusCode.OK, LagreSelvbestemtImResponse(selvbestemtId), LagreSelvbestemtImResponse.serializer()) + respondOk(LagreSelvbestemtImResponse(selvbestemtId), LagreSelvbestemtImResponse.serializer()) } else { val feilmelding = resultat.failure?.fromJson(String.serializer()).orDefault("Tomt resultat i Redis.") - logger.info("Fikk feil under mottagelse av selvbestemt inntektsmelding.") - sikkerLogger.info("Fikk feil under mottagelse av selvbestemt inntektsmelding: $feilmelding") + + "Klarte ikke motta selvbestemt inntektsmelding pga. feil.".also { + logger.error(it) + sikkerLogger.error("$it Feilmelding: '$feilmelding'") + } + if ("Mangler arbeidsforhold i perioden" == feilmelding) { respondBadRequest(ArbeidsforholdErrorResponse(), ArbeidsforholdErrorResponse.serializer()) } else { @@ -138,10 +139,12 @@ private suspend fun PipelineContext.sendResponse(resultat } } } - .onFailure { - logger.info("Klarte ikke hente resultat.") - sikkerLogger.info("Klarte ikke hente resultat.", it) - when (it) { + .onFailure { error -> + "Klarte ikke hente resultat fra Redis.".also { + logger.error(it) + sikkerLogger.error(it, error) + } + when (error) { is RedisPollerTimeoutException -> respondInternalServerError(RedisTimeoutResponse(), RedisTimeoutResponse.serializer()) diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRouteKtTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRouteKtTest.kt index f56e9950a..6fa309338 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRouteKtTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentselvbestemtim/HentSelvbestemtImRouteKtTest.kt @@ -64,7 +64,7 @@ class HentSelvbestemtImRouteKtTest : ApiTest() { } @Test - fun `gi OK med inntektsmelding`() = testApi { + fun `gir OK med inntektsmelding`() = testApi { val expectedInntektsmelding = mockInntektsmeldingV1() coEvery { mockRedisPoller.hent(any()) } returnsMany listOf( diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt index 7ba4f3a09..5bf77407a 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt @@ -33,8 +33,8 @@ class InntektSelvbestemtProducerTest : FunSpec({ Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.UUID to transaksjonId.toJson(), Key.DATA to "".toJson(), - Key.FNR to sykmeldtFnr.toJson(Fnr.serializer()), - Key.ORGNRUNDERENHET to orgnr.toJson(Orgnr.serializer()), + Key.FNR to sykmeldtFnr.toJson(), + Key.ORGNRUNDERENHET to orgnr.toJson(), Key.SKJAERINGSTIDSPUNKT to inntektsdato.toJson() ) } diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRouteKtTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRouteKtTest.kt index 4bac1f587..62dffb9da 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRouteKtTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRouteKtTest.kt @@ -1,19 +1,22 @@ package no.nav.helsearbeidsgiver.inntektsmelding.api.lagreselvbestemtim +import io.kotest.matchers.shouldBe import io.ktor.client.statement.bodyAsText import io.ktor.http.HttpStatusCode import io.mockk.clearAllMocks import io.mockk.coEvery +import kotlinx.serialization.builtins.serializer +import kotlinx.serialization.json.JsonElement import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.skjema.SkjemaInntektsmeldingSelvbestemt import no.nav.helsearbeidsgiver.felles.ResultJson import no.nav.helsearbeidsgiver.felles.test.mock.mockSkjemaInntektsmeldingSelvbestemt +import no.nav.helsearbeidsgiver.inntektsmelding.api.RedisPollerTimeoutException import no.nav.helsearbeidsgiver.inntektsmelding.api.Routes -import no.nav.helsearbeidsgiver.inntektsmelding.api.response.ArbeidsforholdErrorResponse import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.ApiTest import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.harTilgangResultat -import no.nav.helsearbeidsgiver.utils.json.fromJson +import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.ikkeTilgangResultat import no.nav.helsearbeidsgiver.utils.json.toJson -import org.junit.jupiter.api.Assertions.assertEquals +import no.nav.helsearbeidsgiver.utils.test.json.removeJsonWhitespace import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test import java.util.UUID @@ -32,29 +35,192 @@ class LagreSelvbestemtImRouteKtTest : ApiTest() { coEvery { mockRedisPoller.hent(any()) } returnsMany listOf( harTilgangResultat, - ResultJson( - success = selvbestemtId.toJson() - ).toJson(ResultJson.serializer()) + Mock.successResult(selvbestemtId) ) val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) - assertEquals(HttpStatusCode.OK, response.status) - assertEquals(LagreSelvbestemtImResponse(selvbestemtId = selvbestemtId), response.bodyAsText().fromJson(LagreSelvbestemtImResponse.serializer())) + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.OK + actualJson shouldBe Mock.successResponseJson(selvbestemtId) + } + + @Test + fun `feil i request body gir 400-feil`() = testApi { + val expectedFeilmelding = "Feil under serialisering." + + coEvery { mockRedisPoller.hent(any()) } returns harTilgangResultat + + val response = post(path, "ikke et skjema", String.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.BadRequest + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) + } + + @Test + fun `valideringsfeil gir 400-feil`() = testApi { + val expectedFailureResponseJson = """ + { + "valideringsfeil": [ + "Sykmeldingsperioder må fylles ut", + "Beløp må være større eller lik 0", + "Refusjonsbeløp må være mindre eller lik inntekt" + ], + "error": "Feil under validering." + } + """.removeJsonWhitespace() + + coEvery { mockRedisPoller.hent(any()) } returns harTilgangResultat + + val skjemaMedFeil = mockSkjemaInntektsmeldingSelvbestemt().let { + it.copy( + sykmeldingsperioder = emptyList(), + inntekt = it.inntekt.copy( + beloep = -1.0 + ) + ) + } + + val response = post(path, skjemaMedFeil, SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.BadRequest + actualJson shouldBe expectedFailureResponseJson + } + + @Test + fun `manglende tilgang gir 500-feil`() = testApi { + coEvery { mockRedisPoller.hent(any()) } returns ikkeTilgangResultat + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe "\"Error 500: no.nav.helsearbeidsgiver.inntektsmelding.api.auth.ManglerAltinnRettigheterException\"" + } + + @Test + fun `feilresultat gir 500-feil`() = testApi { + val expectedFeilmelding = "Ukjent feil." + + coEvery { mockRedisPoller.hent(any()) } returnsMany listOf( + harTilgangResultat, + Mock.failureResult(expectedFeilmelding) + ) + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) } @Test fun `skal returnere bad reqest hvis arbeidsforhold mangler`() = testApi { + val expectedFeilmelding = "Mangler arbeidsforhold i perioden" + + coEvery { mockRedisPoller.hent(any()) } returnsMany listOf( + harTilgangResultat, + Mock.failureResult(expectedFeilmelding) + ) + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.BadRequest + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) + } + + @Test + fun `tomt resultat gir 500-feil`() = testApi { + val expectedFeilmelding = "Ukjent feil." + coEvery { mockRedisPoller.hent(any()) } returnsMany listOf( harTilgangResultat, - ResultJson( - failure = "Mangler arbeidsforhold i perioden".toJson() - ).toJson(ResultJson.serializer()) + Mock.emptyResult() ) val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) - assertEquals(HttpStatusCode.BadRequest, response.status) - assertEquals(ArbeidsforholdErrorResponse(), response.bodyAsText().fromJson(ArbeidsforholdErrorResponse.serializer())) + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) + } + + @Test + fun `timeout mot redis gir 500-feil`() = testApi { + val expectedFeilmelding = "Brukte for lang tid mot redis." + + coEvery { mockRedisPoller.hent(any()) } returns harTilgangResultat andThenThrows RedisPollerTimeoutException(UUID.randomUUID()) + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) + } + + @Test + fun `ukjent feil mot redis gir 500-feil`() = testApi { + val expectedFeilmelding = "Permanent feil mot redis." + + coEvery { mockRedisPoller.hent(any()) } returns harTilgangResultat andThenThrows IllegalStateException() + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe Mock.failureResponseJson(expectedFeilmelding) } + + @Test + fun `ukjent feil gir 500-feil`() = testApi { + coEvery { mockRedisPoller.hent(any()) } throws NullPointerException() + + val response = post(path, mockSkjemaInntektsmeldingSelvbestemt(), SkjemaInntektsmeldingSelvbestemt.serializer()) + + val actualJson = response.bodyAsText() + + response.status shouldBe HttpStatusCode.InternalServerError + actualJson shouldBe "\"Error 500: java.lang.NullPointerException\"" + } +} + +private object Mock { + fun successResponseJson(selvbestemtId: UUID): String = + """ + { + "selvbestemtId": "$selvbestemtId" + } + """.removeJsonWhitespace() + + fun failureResponseJson(feilmelding: String): String = + """ + { + "error": "$feilmelding" + } + """.removeJsonWhitespace() + + fun successResult(selvbestemtId: UUID): JsonElement = + ResultJson( + success = selvbestemtId.toJson() + ).toJson(ResultJson.serializer()) + + fun failureResult(feilmelding: String): JsonElement = + ResultJson( + failure = feilmelding.toJson(String.serializer()) + ).toJson(ResultJson.serializer()) + + fun emptyResult(): JsonElement = + ResultJson().toJson(ResultJson.serializer()) } diff --git a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt index 5b0c98606..b5e77e7bc 100644 --- a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt +++ b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt @@ -67,8 +67,8 @@ class InntektSelvbestemtService( Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.INNTEKT.toJson(), Key.UUID to transaksjonId.toJson(), - Key.FNR to fnr.toJson(Fnr.serializer()), - Key.ORGNRUNDERENHET to orgnr.toJson(Orgnr.serializer()), + Key.FNR to fnr.toJson(), + Key.ORGNRUNDERENHET to orgnr.toJson(), Key.SKJAERINGSTIDSPUNKT to inntektsdato.toJson(LocalDateSerializer) ) .also { loggBehovPublisert(BehovType.INNTEKT, it) } diff --git a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt index 4db1c3243..a3a9daed7 100644 --- a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt +++ b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt @@ -114,8 +114,8 @@ fun mockStartMelding(transaksjonId: UUID): Map = Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.UUID to transaksjonId.toJson(), Key.DATA to "".toJson(), - Key.FNR to Fnr.genererGyldig().toJson(Fnr.serializer()), - Key.ORGNRUNDERENHET to Orgnr.genererGyldig().toJson(Orgnr.serializer()), + Key.FNR to Fnr.genererGyldig().toJson(), + Key.ORGNRUNDERENHET to Orgnr.genererGyldig().toJson(), Key.SKJAERINGSTIDSPUNKT to 14.april.toJson() ) diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt index be0305dd6..27f5b1dd3 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt @@ -34,8 +34,8 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.UUID to Mock.transaksjonId.toJson(), Key.DATA to "".toJson(), - Key.FNR to Mock.fnr.toJson(Fnr.serializer()), - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(Orgnr.serializer()), + Key.FNR to Mock.fnr.toJson(), + Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), Key.SKJAERINGSTIDSPUNKT to Mock.inntektsdato.toJson() ) @@ -46,8 +46,8 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.EVENT_NAME to EventName.INNTEKT_SELVBESTEMT_REQUESTED.toJson(), Key.BEHOV to BehovType.INNTEKT.toJson(), Key.UUID to Mock.transaksjonId.toJson(), - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(Orgnr.serializer()), - Key.FNR to Mock.fnr.toJson(Fnr.serializer()), + Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.FNR to Mock.fnr.toJson(), Key.SKJAERINGSTIDSPUNKT to Mock.inntektsdato.toJson(LocalDateSerializer) ) ) diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/TrengerIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/TrengerIT.kt index be449af49..48c16471c 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/TrengerIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/TrengerIT.kt @@ -41,7 +41,7 @@ class TrengerIT : EndToEndTest() { Key.EVENT_NAME to EventName.TRENGER_REQUESTED.toJson(), Key.UUID to transaksjonId.toJson(UuidSerializer), Key.DATA to "".toJson(), - Key.ARBEIDSGIVER_ID to Fnr.genererGyldig().toJson(Fnr.serializer()), + Key.ARBEIDSGIVER_ID to Fnr.genererGyldig().toJson(), Key.FORESPOERSEL_ID to forespoerselId.toJson(UuidSerializer) ) diff --git a/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt b/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt index 5744b4e48..bb6e63e80 100644 --- a/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt +++ b/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt @@ -61,8 +61,9 @@ class HentSelvbestemtImService( } override fun onError(melding: Map, fail: Fail) { - val feilmeldingJson = fail.feilmelding.toJson() - val resultJson = ResultJson(failure = feilmeldingJson).toJson(ResultJson.serializer()) + val resultJson = ResultJson( + failure = fail.feilmelding.toJson() + ).toJson(ResultJson.serializer()) redisStore.set(RedisKey.of(fail.transaksjonId), resultJson) }