Legge til logger for testing av oppdater av inntekt

Author: ArselanSultani

.github/workflows/deploy.yaml

@@ -49,7 +49,7 @@ jobs:
   deploy-dev:
     name: Deploy to dev
     needs: [build]
-    if: github.ref == 'refs/heads/main'
+    if: github.ref == 'refs/heads/test-logs'
     runs-on: ubuntu-latest
     permissions:
       contents: "read"
@@ -64,21 +64,21 @@ jobs:
           VARS: nais/vars.yaml
           VAR: image=${{ needs.build.outputs.image }}
           PRINT_PAYLOAD: true
-  deploy-prod:
-    name: Deploy to Production
-    needs: [build, deploy-dev]
-    if: github.ref == 'refs/heads/main'
-    runs-on: ubuntu-latest
-    permissions:
-      contents: "read"
-      id-token: "write"
-    environment: prod-gcp
-    steps:
-      - uses: actions/checkout@v4
-      - uses: nais/deploy/actions/deploy@v2
-        env:
-          CLUSTER: prod-gcp
-          RESOURCE: nais/prod/nais.yaml
-          VARS: nais/vars.yaml
-          VAR: image=${{ needs.build.outputs.image }}
-          PRINT_PAYLOAD: true
+#  deploy-prod:
+#    name: Deploy to Production
+#    needs: [build, deploy-dev]
+#    if: github.ref == 'refs/heads/main'
+#    runs-on: ubuntu-latest
+#    permissions:
+#      contents: "read"
+#      id-token: "write"
+#    environment: prod-gcp
+#    steps:
+#      - uses: actions/checkout@v4
+#      - uses: nais/deploy/actions/deploy@v2
+#        env:
+#          CLUSTER: prod-gcp
+#          RESOURCE: nais/prod/nais.yaml
+#          VARS: nais/vars.yaml
+#          VAR: image=${{ needs.build.outputs.image }}
+#          PRINT_PAYLOAD: true

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

@@ -76,6 +76,7 @@ internal fun Application.inntektApi(
     install(StatusPages) {
         exception<Throwable> { call, cause ->
             LOGGER.error("Request failed!", cause)
+            cause.printStackTrace()
             val error =
                 Problem(
                     type = URI("urn:dp:error:inntekt"),

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

@@ -95,7 +95,7 @@ internal class PostgresInntektStore(
 
     override fun getInntektPersonMapping(inntektId: String): InntektPersonMapping {
         @Language("sql")
-        val statement = "SELECT * FROM inntekt_V1_person_mapping WHERE inntektId = :inntektId)".trimMargin()
+        val statement = "SELECT * FROM inntekt_V1_person_mapping WHERE inntektId = :inntektId".trimMargin()
 
         return using(sessionOf(dataSource)) { session ->
             session.run(

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

@@ -176,28 +176,33 @@ fun Route.uklassifisertInntekt(
                         .mapToStoredInntekt(
                             inntektId = inntektId,
                         ).let {
-                            val inntektPersonMapping = inntektStore.getInntektPersonMapping(inntektId)
-                            inntektStore.storeInntekt(
-                                StoreInntektCommand(
-                                    inntektparametre =
-                                        Inntektparametre(
-                                            aktørId = inntektPersonMapping.aktørId,
-                                            fødselsnummer = it.inntekt.ident.identifikator,
-                                            regelkontekst =
-                                                RegelKontekst(
-                                                    inntektPersonMapping.kontekstId,
-                                                    inntektPersonMapping.kontekstType,
-                                                ),
-                                            beregningsdato = inntektPersonMapping.beregningsdato,
-                                        ),
-                                    inntekt = it.inntekt,
-                                    manueltRedigert =
-                                        ManueltRedigert.from(
-                                            true,
-                                            call.getSubject(),
-                                        ),
-                                ),
-                            )
+                            try {
+                                val inntektPersonMapping = inntektStore.getInntektPersonMapping(inntektId)
+                                inntektStore.storeInntekt(
+                                    StoreInntektCommand(
+                                        inntektparametre =
+                                            Inntektparametre(
+                                                aktørId = inntektPersonMapping.aktørId,
+                                                fødselsnummer = it.inntekt.ident.identifikator,
+                                                regelkontekst =
+                                                    RegelKontekst(
+                                                        inntektPersonMapping.kontekstId,
+                                                        inntektPersonMapping.kontekstType,
+                                                    ),
+                                                beregningsdato = inntektPersonMapping.beregningsdato,
+                                            ),
+                                        inntekt = it.inntekt,
+                                        manueltRedigert =
+                                            ManueltRedigert.from(
+                                                true,
+                                                call.getSubject(),
+                                            ),
+                                    ),
+                                )
+                            } catch (e: Throwable) {
+                                logger.error { e }
+                                throw e
+                            }
                         }.let {
                             call.respond(HttpStatusCode.OK, it.inntektId.id)
                         }.also {

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/v1/models/InntekterDto.kt

@@ -1,5 +1,6 @@
 package no.nav.dagpenger.inntekt.v1.models
 
+import mu.KotlinLogging
 import no.nav.dagpenger.inntekt.db.InntektId
 import no.nav.dagpenger.inntekt.db.StoredInntekt
 import no.nav.dagpenger.inntekt.inntektskomponenten.v1.Aktoer
@@ -19,13 +20,20 @@ data class InntekterDto(
     val mottaker: Inntektsmottaker,
 )
 
-fun InntekterDto.mapToStoredInntekt(inntektId: String): StoredInntekt =
-    StoredInntekt(
-        inntektId = InntektId(id = inntektId),
-        inntekt = mapToInntektkomponentResponse(this),
-        manueltRedigert = true,
-        timestamp = now(),
-    )
+fun InntekterDto.mapToStoredInntekt(inntektId: String): StoredInntekt {
+    val logger = KotlinLogging.logger {}
+    return try {
+        StoredInntekt(
+            inntektId = InntektId(id = inntektId),
+            inntekt = mapToInntektkomponentResponse(this),
+            manueltRedigert = true,
+            timestamp = now(),
+        )
+    } catch (e: Throwable) {
+        logger.error("Kunne ikke mappe InntekterDto til StoredInntekt", e)
+        throw e
+    }
+}
 
 private fun mapToInntektkomponentResponse(inntekterDto: InntekterDto): InntektkomponentResponse {
     val inntektPerÅrOgMåned = mutableMapOf<YearMonth, Pair<MutableList<Inntekt>?, MutableList<Avvik>?>>()