Task/remove moshi (#161)

* R! Fjernet bruk av moshi til fordel for jackson json bibliotek.

* Mappe exception riktig.

* Bruke jackson mot basen og les som strøm.

Author: geiralund

dp-inntekt-api/build.gradle.kts

@@ -49,11 +49,6 @@ dependencies {
     implementation("io.ktor:ktor-client-apache:${libs.versions.ktor.get()}")
 
     implementation(libs.bundles.jackson)
-
-    implementation("com.squareup.moshi:moshi:$moshiVersion")
-    implementation("com.squareup.moshi:moshi-adapters:$moshiVersion")
-    implementation("com.squareup.moshi:moshi-kotlin:$moshiVersion")
-
     implementation("org.apache.kafka:kafka-clients:3.6.1")
 
     implementation(libs.kotlin.logging)

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/InntektApi.kt

@@ -1,8 +1,8 @@
 package no.nav.dagpenger.inntekt
 
+import com.fasterxml.jackson.core.JsonParseException
+import com.fasterxml.jackson.databind.exc.MismatchedInputException
 import com.natpryce.konfig.Configuration
-import com.squareup.moshi.JsonDataException
-import com.squareup.moshi.JsonEncodingException
 import de.huxhorn.sulky.ulid.ULID
 import io.ktor.http.ContentType
 import io.ktor.http.HttpHeaders
@@ -143,7 +143,7 @@ internal fun Application.inntektApi(
                 )
             call.respond(statusCode, error)
         }
-        exception<JsonEncodingException> { call, cause ->
+        exception<JsonParseException> { call, cause ->
             LOGGER.warn("Request was malformed", cause)
             val error =
                 Problem(
@@ -153,7 +153,7 @@ internal fun Application.inntektApi(
                 )
             call.respond(HttpStatusCode.BadRequest, error)
         }
-        exception<JsonDataException> { call, cause ->
+        exception<MismatchedInputException> { call, cause ->
             LOGGER.warn("Request does not match expected json", cause)
             val error =
                 Problem(

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/MoshiAdapters.kt

@@ -4,9 +4,11 @@ import kotliquery.queryOf
 import kotliquery.sessionOf
 import kotliquery.using
 import no.nav.dagpenger.events.inntekt.v1.InntektKlasse
+import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
 import no.nav.dagpenger.inntekt.klassifiserer.klassifiserOgMapInntekt
 import no.nav.dagpenger.inntekt.mapping.mapToSpesifisertInntekt
 import no.nav.dagpenger.inntekt.opptjeningsperiode.Opptjeningsperiode
+import no.nav.dagpenger.inntekt.serder.jacksonObjectMapper
 import java.time.LocalDate
 import javax.sql.DataSource
 
@@ -54,7 +56,7 @@ internal class KronetilleggUttrekk(private val dataSource: DataSource) {
                         inntekt =
                             StoredInntekt(
                                 inntektId = InntektId(inntektId.id),
-                                inntekt = PostgresInntektStore.adapter.fromJson(it.string("inntekt"))!!,
+                                inntekt = jacksonObjectMapper.readValue(it.string("inntekt"), InntektkomponentResponse::class.java)!!,
                                 manueltRedigert = it.boolean("manuelt_redigert"),
                             ),
                         vedtakId = it.int("kontekstid"),

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/KronetilleggUttrekk.kt

@@ -1,6 +1,6 @@
 package no.nav.dagpenger.inntekt.db
 
-import com.squareup.moshi.JsonAdapter
+import com.fasterxml.jackson.module.kotlin.readValue
 import de.huxhorn.sulky.ulid.ULID
 import io.prometheus.client.Summary
 import kotliquery.queryOf
@@ -12,8 +12,8 @@ import no.nav.dagpenger.inntekt.HealthCheck
 import no.nav.dagpenger.inntekt.HealthStatus
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.InntektkomponentResponse
 import no.nav.dagpenger.inntekt.mapping.mapToSpesifisertInntekt
-import no.nav.dagpenger.inntekt.moshiInstance
 import no.nav.dagpenger.inntekt.opptjeningsperiode.Opptjeningsperiode
+import no.nav.dagpenger.inntekt.serder.jacksonObjectMapper
 import org.intellij.lang.annotations.Language
 import org.postgresql.util.PGobject
 import org.postgresql.util.PSQLException
@@ -24,8 +24,6 @@ import javax.sql.DataSource
 @Suppress("ktlint:standard:max-line-length")
 internal class PostgresInntektStore(private val dataSource: DataSource) : InntektStore, HealthCheck {
     companion object {
-        internal val adapter: JsonAdapter<InntektkomponentResponse> =
-            moshiInstance.adapter(InntektkomponentResponse::class.java)
         private val ulidGenerator = ULID()
         private val LOGGER = KotlinLogging.logger {}
         private val markerInntektTimer =
@@ -121,7 +119,7 @@ internal class PostgresInntektStore(private val dataSource: DataSource) : Inntek
                 ).map { row ->
                     StoredInntekt(
                         inntektId = InntektId(row.string("id")),
-                        inntekt = adapter.fromJson(row.string("inntekt"))!!,
+                        inntekt = row.binaryStream("inntekt").use { jacksonObjectMapper.readValue<InntektkomponentResponse>(it) },
                         manueltRedigert = row.boolean("manuelt_redigert"),
                         timestamp = row.zonedDateTime("timestamp").toLocalDateTime(),
                     )
@@ -151,7 +149,7 @@ internal class PostgresInntektStore(private val dataSource: DataSource) : Inntek
                     ).map { row ->
                         StoredInntekt(
                             inntektId = InntektId(row.string("id")),
-                            inntekt = adapter.fromJson(row.string("inntekt"))!!,
+                            inntekt = row.binaryStream("inntekt").use { jacksonObjectMapper.readValue<InntektkomponentResponse>(it) },
                             manueltRedigert = row.boolean("manuelt_redigert"),
                             timestamp = row.zonedDateTime("timestamp").toLocalDateTime(),
                         ) to row.localDate("beregningsdato")
@@ -180,7 +178,7 @@ internal class PostgresInntektStore(private val dataSource: DataSource) : Inntek
                                 "data" to
                                     PGobject().apply {
                                         type = "jsonb"
-                                        value = adapter.toJson(command.inntekt)
+                                        value = jacksonObjectMapper.writeValueAsString(command.inntekt)
                                     },
                                 when (command.manueltRedigert) {
                                     null -> "manuelt" to false