Lag datatype for utgåande melding til rapid for å få rett feltnamn i JSON

avoldsund · avoldsund · commit bac92fa8cb04 · 2021-03-26T15:05:43.000+01:00
diff --git a/src/main/kotlin/no/nav/hjelpemidler/Application.kt b/src/main/kotlin/no/nav/hjelpemidler/Application.kt
@@ -1,5 +1,6 @@
 package no.nav.hjelpemidler
 
+import com.fasterxml.jackson.annotation.JsonFormat
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
@@ -16,7 +17,9 @@ import no.nav.helse.rapids_rivers.RapidApplication
 import no.nav.helse.rapids_rivers.RapidsConnection
 import no.nav.hjelpemidler.configuration.Configuration
 import no.nav.hjelpemidler.metrics.SensuMetrics
-import no.nav.hjelpemidler.model.Statusinfo
+import no.nav.hjelpemidler.model.Ordrelinje
+import no.nav.hjelpemidler.model.OrdrelinjeOebs
+import no.nav.hjelpemidler.model.toOrdrelinje
 import java.net.InetAddress
 import java.time.LocalDateTime
 import java.util.UUID
@@ -53,7 +56,7 @@ fun main() {
                 null,
                 null,
             ),
-            8080,
+            Configuration.rapidConfig["HTTP_PORT"]!!.toInt(),
         )
     ).withKtorModule {
         routing {
@@ -70,7 +73,7 @@ fun main() {
                 sikkerlogg.info("Received JSON push request from OEBS: $rawJson")
 
                 // Check for valid json request
-                val ordrelinje: Statusinfo?
+                val ordrelinje: OrdrelinjeOebs?
                 try {
                     ordrelinje = mapper.readValue(rawJson)
                     sikkerlogg.info("Parsing incoming json request successful: ${mapper.writeValueAsString(ordrelinje)}")
@@ -115,7 +118,7 @@ fun main() {
                     eventName = "hm-NyOrdrelinje",
                     opprettet = LocalDateTime.now(),
                     fnrBruker = ordrelinje.fnrBruker,
-                    data = ordrelinje
+                    data = ordrelinje.toOrdrelinje()
                 )
 
                 // Publish the received json to our rapid
@@ -143,7 +146,8 @@ fun main() {
 data class Message(
     val eventId: UUID,
     val eventName: String,
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
     val opprettet: LocalDateTime,
     val fnrBruker: String,
-    val data: Statusinfo,
+    val data: Ordrelinje,
 )
diff --git a/src/main/kotlin/no/nav/hjelpemidler/configuration/Configuration.kt b/src/main/kotlin/no/nav/hjelpemidler/configuration/Configuration.kt
@@ -1,6 +1,11 @@
 package no.nav.hjelpemidler.configuration
 
-import com.natpryce.konfig.*
+import com.natpryce.konfig.ConfigurationMap
+import com.natpryce.konfig.ConfigurationProperties
+import com.natpryce.konfig.EnvironmentVariables
+import com.natpryce.konfig.Key
+import com.natpryce.konfig.overriding
+import com.natpryce.konfig.stringType
 
 internal object Configuration {
 
@@ -14,6 +19,8 @@ internal object Configuration {
 
     private val prodProperties = ConfigurationMap(
         mapOf(
+            "HTTP_PORT" to "8080",
+
             "kafka.aiven.topic" to "teamdigihot.hm-soknadsbehandling-v1",
             "kafka.reset.policy" to "latest",
             "kafka.client.id" to "hm-oebs-listener-prod",
@@ -25,6 +32,8 @@ internal object Configuration {
 
     private val devProperties = ConfigurationMap(
         mapOf(
+            "HTTP_PORT" to "8080",
+
             "kafka.aiven.topic" to "teamdigihot.hm-soknadsbehandling-v1",
             "kafka.reset.policy" to "latest",
             "kafka.client.id" to "hm-oebs-listener-dev",
@@ -37,17 +46,17 @@ internal object Configuration {
     private val localProperties = ConfigurationMap(
         mapOf(
             "HTTP_PORT" to "8085",
+            "OEBSTOKEN" to "abc",
 
             "kafka.reset.policy" to "earliest",
-            "application.httpPort" to "8082",
             "application.profile" to "LOCAL",
             "KAFKA_TRUSTSTORE_PATH" to "",
             "KAFKA_CREDSTORE_PASSWORD" to "",
             "KAFKA_KEYSTORE_PATH" to "",
             "kafka.brokers" to "host.docker.internal:9092",
             "kafka.client.id" to "hm-oebs-listener-local",
             "kafka.aiven.topic" to "teamdigihot.hm-soknadsbehandling-v1",
-
+            "kafka.reset.policy" to "earliest",
             "application.profile" to "local",
             "SENSU_URL" to "https://test",
         )
@@ -64,7 +73,7 @@ internal object Configuration {
         "KAFKA_TRUSTSTORE_PASSWORD" to config()[Key("KAFKA_CREDSTORE_PASSWORD", stringType)],
         "KAFKA_KEYSTORE_PATH" to config()[Key("KAFKA_KEYSTORE_PATH", stringType)],
         "KAFKA_KEYSTORE_PASSWORD" to config()[Key("KAFKA_CREDSTORE_PASSWORD", stringType)],
-        "HTTP_PORT" to "8080",
+        "HTTP_PORT" to config()[Key("HTTP_PORT", stringType)],
         "KAFKA_CLIENT_ID" to config()[Key("kafka.client.id", stringType)],
     ) + System.getenv().filter { it.key.startsWith("NAIS_") }
 
@@ -73,5 +82,4 @@ internal object Configuration {
         "SENSU_URL" to config()[Key("SENSU_URL", stringType)],
         "OEBSTOKEN" to config()[Key("OEBSTOKEN", stringType)],
     ) + System.getenv().filter { it.key.startsWith("NAIS_") }
-
-}
+}
diff --git a/src/main/kotlin/no/nav/hjelpemidler/model/Ordrelinje.kt b/src/main/kotlin/no/nav/hjelpemidler/model/Ordrelinje.kt
@@ -0,0 +1,32 @@
+package no.nav.hjelpemidler.model
+
+import com.fasterxml.jackson.annotation.JsonFormat
+import java.time.LocalDate
+
+data class Ordrelinje(
+    val mottakendeSystem: String,
+    val serviceforespørsel: Int,
+    val serviceforespørselstatus: String,
+    val serviceforespørseltype: String,
+    val søknadstype: String,
+
+    // N.B.: Viss dato er "" i meldinga blir den til null under deserialisering og forblir null under serialisering (utgåande JSON)
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
+    val vedtaksdato: LocalDate?,
+
+    val søknad: String,
+    val resultat: String,
+    val saksblokkOgSaksnr: String,
+    val ordrenr: Int,
+    val ordrelinje: Int,
+    val delordrelinje: Int,
+    val artikkelbeskrivelse: String,
+    val produktgruppe: String,
+    val artikkelnr: String,
+    val hjelpemiddeltype: String,
+    val antall: Int,
+    val fnrBruker: String,
+
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
+    val sistOppdatert: LocalDate
+)
diff --git a/src/main/kotlin/no/nav/hjelpemidler/model/OrdrelinjeOebs.kt b/src/main/kotlin/no/nav/hjelpemidler/model/OrdrelinjeOebs.kt
@@ -4,7 +4,7 @@ import com.fasterxml.jackson.annotation.JsonFormat
 import com.fasterxml.jackson.annotation.JsonProperty
 import java.time.LocalDate
 
-data class Statusinfo(
+data class OrdrelinjeOebs(
     @JsonProperty("System")
     val mottakendeSystem: String,
 
@@ -21,7 +21,7 @@ data class Statusinfo(
     val søknadstype: String,
 
     // N.B.: Viss dato er "" i meldinga blir den til null under deserialisering og forblir null under serialisering (utgåande JSON)
-    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd")
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
     @JsonProperty("IncidentVedtakDato")
     val vedtaksdato: LocalDate?,
 
@@ -32,16 +32,16 @@ data class Statusinfo(
     val resultat: String,
 
     @JsonProperty("IncidentRef")
-    val saksblokkOgSaksnummer: String,
+    val saksblokkOgSaksnr: String,
 
     @JsonProperty("OrdreNumber")
-    val ordrenummer: Int,
+    val ordrenr: Int,
 
     @JsonProperty("LineNumber")
-    val ordrelinjenummer: Int,
+    val ordrelinje: Int,
 
     @JsonProperty("ShipmentNumber")
-    val delordrelinjenummer: Int,
+    val delordrelinje: Int,
 
     @JsonProperty("Description")
     val artikkelbeskrivelse: String,
@@ -50,7 +50,7 @@ data class Statusinfo(
     val produktgruppe: String,
 
     @JsonProperty("OrderedItem")
-    val artikkel: String,
+    val artikkelnr: String,
 
     @JsonProperty("User_ItemType")
     val hjelpemiddeltype: String,
@@ -61,7 +61,31 @@ data class Statusinfo(
     @JsonProperty("AccountNumber")
     val fnrBruker: String,
 
-    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd")
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
     @JsonProperty("LastUpdateDate")
     val sistOppdatert: LocalDate
 )
+
+fun OrdrelinjeOebs.toOrdrelinje(): Ordrelinje {
+    return Ordrelinje(
+        this.mottakendeSystem,
+        this.serviceforespørsel,
+        this.serviceforespørselstatus,
+        this.serviceforespørseltype,
+        this.søknadstype,
+        this.vedtaksdato,
+        this.søknad,
+        this.resultat,
+        this.saksblokkOgSaksnr,
+        this.ordrenr,
+        this.ordrelinje,
+        this.delordrelinje,
+        this.artikkelbeskrivelse,
+        this.produktgruppe,
+        this.artikkelnr,
+        this.hjelpemiddeltype,
+        this.antall,
+        this.fnrBruker,
+        this.sistOppdatert
+    )
+}
diff --git a/src/test/kotlin/no/nav/hjelpemidler/ParsingTest.kt b/src/test/kotlin/no/nav/hjelpemidler/ParsingTest.kt
@@ -3,7 +3,7 @@ package no.nav.hjelpemidler
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
-import no.nav.hjelpemidler.model.Statusinfo
+import no.nav.hjelpemidler.model.OrdrelinjeOebs
 import java.time.LocalDate
 import kotlin.test.Test
 import kotlin.test.assertEquals
@@ -17,7 +17,7 @@ internal class ParsingTest {
         val mapper = jacksonObjectMapper()
         mapper.registerModule(JavaTimeModule())
 
-        val result: Statusinfo = mapper.readValue(
+        val result: OrdrelinjeOebs = mapper.readValue(
             """
             {
                 "System": "DIGIHOT",
@@ -55,7 +55,7 @@ internal class ParsingTest {
         val mapper = jacksonObjectMapper()
         mapper.registerModule(JavaTimeModule())
 
-        val result: Statusinfo = mapper.readValue(
+        val result: OrdrelinjeOebs = mapper.readValue(
             """
             {
                 "System": "DIGIHOT",
@@ -93,7 +93,7 @@ internal class ParsingTest {
         val mapper = jacksonObjectMapper()
         mapper.registerModule(JavaTimeModule())
 
-        val result: Statusinfo = mapper.readValue(
+        val result: OrdrelinjeOebs = mapper.readValue(
             """
             {
                 "System": "DIGIHOT",
@@ -120,7 +120,7 @@ internal class ParsingTest {
         )
 
         println(result.toString())
-        assertEquals("012345", result.artikkel)
+        assertEquals("012345", result.artikkelnr)
         println(mapper.writeValueAsString(result))
     }
 }
