Refactoring (#3)

* Refactoring OrderlinjeAPI.kt

* BadRequest message 💅

* Remove stale todos

* Simplification of ServiceForespørselAPI.kt

* Logging 💅

* Added try-catches to OrdreAPI.kt since there is no StatusPages plugin in this project.

Author: kristoiv

src/main/kotlin/no/nav/hjelpemidler/api/OrdreAPI.kt

@@ -3,6 +3,7 @@ package no.nav.hjelpemidler.api
 import io.ktor.http.HttpStatusCode
 import io.ktor.server.application.call
 import io.ktor.server.request.receive
+import io.ktor.server.response.respond
 import io.ktor.server.routing.Route
 import io.ktor.server.routing.post
 import mu.KotlinLogging
@@ -18,47 +19,59 @@ private val log = KotlinLogging.logger { }
 
 fun Route.ordreAPI(context: Context) {
     post("/ordrekvittering") {
-        val kvittering = call.receive<Ordrekvittering>()
-        log.info {
-            "Mottok ordrekvittering, $kvittering"
+        try {
+            val kvittering = call.receive<Ordrekvittering>()
+            log.info {
+                "Mottok ordrekvittering, $kvittering"
+            }
+            context.publish(
+                kvittering.saksnummer,
+                OrdrekvitteringMottatt(kvittering = kvittering)
+            )
+            call.response.status(HttpStatusCode.OK)
+        } catch (e: Exception) {
+            log.error(e) { "Uventet feil under prosessering" }
+            call.respond(HttpStatusCode.InternalServerError)
+            return@post
         }
-        context.publish(
-            kvittering.saksnummer,
-            OrdrekvitteringMottatt(kvittering = kvittering)
-        )
-        call.response.status(HttpStatusCode.OK)
     }
     post("/ordrefeilmelding") {
-        val feilmelding = call.receive<Ordrefeilmelding>()
-        log.warn {
-            "Mottok ordrefeilmelding, $feilmelding"
-        }
-        context.publish(
-            feilmelding.saksnummer,
-            OrdrefeilmeldingMottatt(feilmelding = feilmelding)
-        )
-        if (Configuration.profile == Profile.PROD) {
-            Slack.post(
-                text = "*${Configuration.profile}* - $feilmelding - <@${Configuration.slackRecipient}>",
-                channel = "#digihot-oebs"
+        try {
+            val feilmelding = call.receive<Ordrefeilmelding>()
+            log.warn {
+                "Mottok ordrefeilmelding, $feilmelding"
+            }
+            context.publish(
+                feilmelding.saksnummer,
+                OrdrefeilmeldingMottatt(feilmelding = feilmelding)
             )
-            Ntfy.publish(
-                Ntfy.Notification(
-                    title = "Mottok ordrefeilmelding",
-                    message = "Status: ${feilmelding.status}",
-                    priority = Ntfy.Priority.HIGH,
-                    actions = setOf(
-                        Ntfy.Action(
-                            action = Ntfy.ActionType.VIEW,
-                            label = "Se detaljer i Slack",
-                            clear = true,
-                            url = "https://nav-it.slack.com/archives/C02LS2W05E1"
+            if (Configuration.profile == Profile.PROD) {
+                Slack.post(
+                    text = "*${Configuration.profile}* - $feilmelding - <@${Configuration.slackRecipient}>",
+                    channel = "#digihot-oebs"
+                )
+                Ntfy.publish(
+                    Ntfy.Notification(
+                        title = "Mottok ordrefeilmelding",
+                        message = "Status: ${feilmelding.status}",
+                        priority = Ntfy.Priority.HIGH,
+                        actions = setOf(
+                            Ntfy.Action(
+                                action = Ntfy.ActionType.VIEW,
+                                label = "Se detaljer i Slack",
+                                clear = true,
+                                url = "https://nav-it.slack.com/archives/C02LS2W05E1"
+                            )
                         )
                     )
                 )
-            )
+            }
+            call.response.status(HttpStatusCode.OK)
+        } catch (e: Exception) {
+            log.error(e) { "Uventet feil under prosessering" }
+            call.respond(HttpStatusCode.InternalServerError)
+            return@post
         }
-        call.response.status(HttpStatusCode.OK)
     }
 }
 

src/main/kotlin/no/nav/hjelpemidler/api/OrdrelinjeAPI.kt

@@ -5,7 +5,6 @@ import com.fasterxml.jackson.dataformat.xml.XmlMapper
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
-import io.ktor.client.request.request
 import io.ktor.http.HttpStatusCode
 import io.ktor.server.application.ApplicationCall
 import io.ktor.server.application.call
@@ -41,9 +40,21 @@ internal fun Route.ordrelinjeAPI(context: Context) {
     post("/push") {
         logg.info("incoming push")
         try {
-            val ordrelinje = parseOrdrelinje(context, call) ?: return@post
+            // Parse innkommende json/xml
+            val ordrelinje = parseOrdrelinje(context, call) ?:
+                return@post call.respond(HttpStatusCode.BadRequest, "request body was not in a valid format")
+
+            // Vi deler alle typer ordrelinjer med kommune-apiet
             sendUvalidertOrdrelinjeTilRapid(context, ordrelinje.toRåOrdrelinje())
-            validerOrdrelinje(context, ordrelinje)
+
+            // Avslutt tidlig hvis ordrelinjen ikke er relevant for oss
+            if (!erOrdrelinjeRelevantForOss(context, ordrelinje)) {
+                logg.info("Urelevant ordrelinje mottatt og ignorert")
+                call.respond(HttpStatusCode.OK)
+                return@post
+            }
+
+            // Anti-corruption lag
             val melding = if (ordrelinje.erOpprettetFraHOTSAK()) {
                 parseHotsakOrdrelinje(context, ordrelinje)
                 context.metrics.hotsakSF()
@@ -54,15 +65,13 @@ internal fun Route.ordrelinjeAPI(context: Context) {
                 opprettInfotrygdOrdrelinje(ordrelinje)
             }
 
+            // Publiser resultat
             publiserMelding(context, ordrelinje, melding)
             call.respond(HttpStatusCode.OK)
-        } catch (e: RapidsAndRiverException) {
-            logg.error(e) { "Feil under prosessering" }
-            call.respond(HttpStatusCode.InternalServerError, "Feil under prosessering")
-            return@post
-        } catch (e: RuntimeException) {
-            logg.error(e) { "Feil under prosessering" }
-            call.respond(HttpStatusCode.OK)
+
+        } catch (e: Exception) {
+            logg.error(e) { "Uventet feil under prosessering" }
+            call.respond(HttpStatusCode.InternalServerError)
             return@post
         }
     }
@@ -77,7 +86,13 @@ private suspend fun parseOrdrelinje(context: Context, call: ApplicationCall): Or
     val requestBody: String = call.receiveText()
     context.metrics.meldingFraOebs()
     if (Configuration.profile != Configuration.Profile.PROD) {
-        sikkerlogg.info("Received $incomingFormatType push request from OEBS: $requestBody")
+        withLoggingContext(
+            mapOf(
+                "requestBody" to requestBody,
+            )
+        ) {
+            sikkerlogg.info("Received $incomingFormatType push request from OEBS")
+        }
     }
 
     // Check for valid json request
@@ -90,32 +105,26 @@ private suspend fun parseOrdrelinje(context: Context, call: ApplicationCall): Or
         }.fiksTommeSerienumre()
 
         if (Configuration.profile != Configuration.Profile.PROD) {
-            sikkerlogg.info(
-                "Parsing incoming $incomingFormatType request successful: ${
-                    mapperJson.writeValueAsString(
-                        ordrelinje
-                    )
-                }"
-            )
+            withLoggingContext(
+                mapOf(
+                    "ordrelinje" to mapperJson.writeValueAsString(ordrelinje),
+                )
+            ) {
+                sikkerlogg.info("Parsing incoming $incomingFormatType request successful")
+            }
         }
         context.metrics.oebsParsingOk()
         return ordrelinje
     } catch (e: Exception) {
         // Deal with invalid json/xml in request
         withLoggingContext(
             mapOf(
-                "rawRequestBody" to requestBody,
+                "requestBody" to requestBody,
             )
         ) {
-            sikkerlogg.info("Parsing incoming $incomingFormatType request failed with exception (responding 4xx): $e")
-            if (Configuration.profile != Configuration.Profile.PROD) {
-                sikkerlogg.info(
-                    "$incomingFormatType in failed parsing: ${mapperJson.writeValueAsString(requestBody)}"
-                )
-            }
+            sikkerlogg.error(e) { "Parsing incoming $incomingFormatType request failed with exception (responding 4xx)" }
         }
         context.metrics.oebsParsingFeilet()
-        call.respond(HttpStatusCode.BadRequest, "bad request: $incomingFormatType not valid")
         return null
     }
 }
@@ -136,12 +145,12 @@ private fun sendUvalidertOrdrelinjeTilRapid(context: Context, ordrelinje: RåOrd
         context.metrics.meldingTilRapidSuksess()
     } catch (e: Exception) {
         context.metrics.meldingTilRapidFeilet()
-        sikkerlogg.error("Sending av uvalidert ordrelinje til rapid feilet, exception: $e\n\n${e.printStackTrace()}")
+        sikkerlogg.error(e) { "Sending av uvalidert ordrelinje til rapid feilet" }
         throw RapidsAndRiverException("Noe gikk feil ved publisering av melding")
     }
 }
 
-private fun validerOrdrelinje(context: Context, ordrelinje: OrdrelinjeOebs) {
+private fun erOrdrelinjeRelevantForOss(context: Context, ordrelinje: OrdrelinjeOebs): Boolean {
     if (ordrelinje.serviceforespørseltype != "Vedtak Infotrygd") {
         if (ordrelinje.serviceforespørseltype == "") {
             logg.info(
@@ -155,7 +164,7 @@ private fun validerOrdrelinje(context: Context, ordrelinje: OrdrelinjeOebs) {
             )
             context.metrics.sfTypeUlikVedtakInfotrygd()
         }
-        throw RuntimeException("Ugyldig ordrelinje")
+        return false
     } else {
         context.metrics.sfTypeVedtakInfotrygd()
     }
@@ -166,10 +175,12 @@ private fun validerOrdrelinje(context: Context, ordrelinje: OrdrelinjeOebs) {
     ) {
         logg.info("Mottok melding fra oebs med irrelevant hjelpemiddeltype ${ordrelinje.hjelpemiddeltype}. Avbryter prosessering")
         context.metrics.irrelevantHjelpemiddeltype()
-        throw RuntimeException("Ugyldig ordrelinje")
+        return false
     } else {
         context.metrics.rettHjelpemiddeltype()
     }
+
+    return true
 }
 
 private fun publiserMelding(
@@ -182,22 +193,21 @@ private fun publiserMelding(
         context.publish(ordrelinje.fnrBruker, mapperJson.writeValueAsString(melding))
         context.metrics.meldingTilRapidSuksess()
 
-        // TODO: Remove logging when interface stabilizes
         ordrelinje.fnrBruker = "MASKERT"
         if (ordrelinje.sendtTilAdresse.take(4).toIntOrNull() == null) {
             // If address is not municipality-intake we mask it in logging.
             ordrelinje.sendtTilAdresse = "MASKERT"
         }
-        sikkerlogg.info(
-            "Ordrelinje med OebsId ${ordrelinje.oebsId} mottatt og sendt til rapid: ${
-                mapperJson.writeValueAsString(
-                    ordrelinje
-                )
-            }"
-        )
+        withLoggingContext(
+            mapOf(
+                "ordrelinje" to mapperJson.writeValueAsString(ordrelinje),
+            )
+        ) {
+            sikkerlogg.info("Ordrelinje med OebsId ${ordrelinje.oebsId} mottatt og sendt til rapid")
+        }
     } catch (e: Exception) {
         context.metrics.meldingTilRapidFeilet()
-        sikkerlogg.error("Sending til rapid feilet", e)
+        sikkerlogg.error(e) { "Sending til rapid feilet" }
         throw RapidsAndRiverException("Noe gikk feil ved publisering av melding")
     }
 }

src/main/kotlin/no/nav/hjelpemidler/api/ServiceForespørselAPI.kt

@@ -33,14 +33,10 @@ internal fun Route.serviceforespørselAPI(context: Context) {
             )
             publiserMelding(context, serviceForespørselEndring, sfMessage)
             call.respond(HttpStatusCode.OK)
-        } catch (e: RapidsAndRiverException) {
+        } catch (e: Exception) {
             logg.error(e) { "Feil under prosessering" }
             call.respond(HttpStatusCode.InternalServerError, "Feil under prosessering")
             return@post
-        } catch (e: RuntimeException) {
-            logg.error(e) { "Feil under prosessering" }
-            call.respond(HttpStatusCode.OK)
-            return@post
         }
     }
 }
@@ -88,7 +84,7 @@ private fun publiserMelding(
         context.metrics.meldingTilRapidSuksess()
     } catch (e: Exception) {
         context.metrics.meldingTilRapidFeilet()
-        sikkerlogg.error("Sending til rapid feilet", e)
+        sikkerlogg.error(e) { "Sending til rapid feilet" }
         throw RapidsAndRiverException("Noe gikk feil ved publisering av melding")
     }
 }

src/main/kotlin/no/nav/hjelpemidler/model/OrdrelinjeOebs.kt

@@ -81,7 +81,6 @@ data class OrdrelinjeOebs(
     val enhet: String,
 
     @JsonProperty("AccountNumber")
-    // TODO: Skift tilbake til val når ting stabiliserer seg
     var fnrBruker: String,
 
     // Sidan dette feltet har informasjon som kan bli utdatert blir ikkje dette brukt.