rydder litt i meldingsklasser

Author: di0nys1us

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

@@ -9,12 +9,15 @@ import io.ktor.server.response.respond
 import io.ktor.server.routing.Route
 import io.ktor.server.routing.post
 import no.nav.hjelpemidler.configuration.Environment
+import no.nav.hjelpemidler.domain.id.UUID
 import no.nav.hjelpemidler.oebs.listener.Configuration
 import no.nav.hjelpemidler.oebs.listener.Context
 import no.nav.hjelpemidler.oebs.listener.Metrics
 import no.nav.hjelpemidler.oebs.listener.Ntfy
 import no.nav.hjelpemidler.oebs.listener.Slack
 import no.nav.hjelpemidler.oebs.listener.model.Message
+import java.time.LocalDateTime
+import java.util.UUID
 
 private val log = KotlinLogging.logger { }
 
@@ -127,11 +130,26 @@ data class Ordrefeilmelding(
     override fun toString(): String = "id: $id, saksnummer: $saksnummer, feilmelding: $feilmelding, system: $system, status: $status"
 }
 
-class OrdrekvitteringMottatt(val kvittering: Ordrekvittering) :
-    Message(eventName = "hm-ordrekvittering-mottatt")
+class OrdrekvitteringMottatt(
+    val kvittering: Ordrekvittering,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : Message {
+    override val eventName: String = "hm-ordrekvittering-mottatt"
+}
 
-class OrdrekvitteringDelbestillingMottatt(val kvittering: Ordrekvittering) :
-    Message(eventName = "hm-ordrekvittering-delbestilling-mottatt")
+class OrdrekvitteringDelbestillingMottatt(
+    val kvittering: Ordrekvittering,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : Message {
+    override val eventName: String = "hm-ordrekvittering-delbestilling-mottatt"
+}
 
-class OrdrefeilmeldingMottatt(val feilmelding: Ordrefeilmelding) :
-    Message(eventName = "hm-ordrefeilmelding-mottatt")
+class OrdrefeilmeldingMottatt(
+    val feilmelding: Ordrefeilmelding,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : Message {
+    override val eventName: String = "hm-ordrefeilmelding-mottatt"
+}

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

@@ -13,8 +13,8 @@ import no.nav.hjelpemidler.logging.secureLog
 import no.nav.hjelpemidler.oebs.listener.Context
 import no.nav.hjelpemidler.oebs.listener.Slack
 import no.nav.hjelpemidler.oebs.listener.jsonMapper
-import no.nav.hjelpemidler.oebs.listener.model.HotsakOrdrelinje
-import no.nav.hjelpemidler.oebs.listener.model.InfotrygdOrdrelinje
+import no.nav.hjelpemidler.oebs.listener.model.HotsakOrdrelinjeMessage
+import no.nav.hjelpemidler.oebs.listener.model.InfotrygdOrdrelinjeMessage
 import no.nav.hjelpemidler.oebs.listener.model.OrdrelinjeMessage
 import no.nav.hjelpemidler.oebs.listener.model.OrdrelinjeOebs
 import no.nav.hjelpemidler.oebs.listener.model.RåOrdrelinje
@@ -54,21 +54,13 @@ fun Route.ordrelinjeAPI(context: Context) {
                         secureLog.info { "Ignorert ordrelinje for delbestilling: '$ordrelinje'" }
                         return@post call.respond(HttpStatusCode.OK)
                     }
-                    OrdrelinjeMessage<HotsakOrdrelinje>(
-                        eventName = "hm-NyOrdrelinje-hotsak",
-                        fnrBruker = ordrelinje.fnrBruker,
-                        data = HotsakOrdrelinje(ordrelinje),
-                    )
+                    HotsakOrdrelinjeMessage(ordrelinje)
                 } else {
                     if (!infotrygdOrdrelinjeOK(ordrelinje)) {
                         log.warn { "Infotrygd-ordrelinje mottatt som ikke passerer validering. Ignorerer." }
                         return@post call.respond(HttpStatusCode.OK)
                     }
-                    OrdrelinjeMessage<InfotrygdOrdrelinje>(
-                        eventName = "hm-NyOrdrelinje",
-                        fnrBruker = ordrelinje.fnrBruker,
-                        data = InfotrygdOrdrelinje(ordrelinje),
-                    )
+                    InfotrygdOrdrelinjeMessage(ordrelinje)
                 }
 
             // Publiser resultat
@@ -137,7 +129,7 @@ private suspend fun hotsakOrdrelinjeOK(ordrelinje: OrdrelinjeOebs): Boolean {
         log.warn { "Melding fra OeBS mangler saksnummer fra Hotsak" }
         ordrelinje.fnrBruker = "MASKERT"
         val message = jsonMapper.writerWithDefaultPrettyPrinter().writeValueAsString(ordrelinje)
-        secureLog.warn { "Vedtak HOTSAK-melding med manglende informasjon: $message" }
+        secureLog.warn { "Vedtak Hotsak-melding med manglende informasjon: '$message'" }
         Slack.post(
             text = "*${Environment.current}* - Manglende felt i Hotsak OeBS ordrelinje: ```$message```",
             channel = "#digihot-hotsak-varslinger-dev",

src/main/kotlin/no/nav/hjelpemidler/oebs/listener/model/Message.kt

@@ -1,10 +1,10 @@
 package no.nav.hjelpemidler.oebs.listener.model
 
-import no.nav.hjelpemidler.domain.id.UUID
 import java.time.LocalDateTime
+import java.util.UUID
 
-@Suppress("unused")
-abstract class Message(val eventName: String) {
-    val eventId = UUID()
-    val opprettet: LocalDateTime = LocalDateTime.now()
+interface Message {
+    val eventId: UUID
+    val eventName: String
+    val opprettet: LocalDateTime
 }

src/main/kotlin/no/nav/hjelpemidler/oebs/listener/model/OrdrelinjeMessage.kt

@@ -1,18 +1,44 @@
 package no.nav.hjelpemidler.oebs.listener.model
 
-import no.nav.hjelpemidler.oebs.listener.api.ServiceforespørselEndring
+import com.fasterxml.jackson.annotation.JsonProperty
+import no.nav.hjelpemidler.domain.id.UUID
+import java.time.LocalDateTime
+import java.util.UUID
 
-class OrdrelinjeMessage<T : Ordrelinje>(
-    eventName: String,
-    val fnrBruker: String,
-    val data: T,
-) : Message(eventName)
+interface OrdrelinjeMessage<T : Ordrelinje> : Message {
+    val fnrBruker: String
+    val data: T
+}
+
+data class HotsakOrdrelinjeMessage(
+    override val fnrBruker: String,
+    override val data: HotsakOrdrelinje,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : OrdrelinjeMessage<HotsakOrdrelinje> {
+    override val eventName: String = "hm-NyOrdrelinje-hotsak"
+
+    constructor(oebs: OrdrelinjeOebs) : this(oebs.fnrBruker, HotsakOrdrelinje(oebs))
+}
+
+data class InfotrygdOrdrelinjeMessage(
+    override val fnrBruker: String,
+    override val data: InfotrygdOrdrelinje,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : OrdrelinjeMessage<InfotrygdOrdrelinje> {
+    override val eventName: String = "hm-NyOrdrelinje"
+
+    constructor(oebs: OrdrelinjeOebs) : this(oebs.fnrBruker, InfotrygdOrdrelinje(oebs))
+}
 
-class ServiceforespørselEndringMessage(val data: ServiceforespørselEndring) :
-    Message(eventName = "hm-EndretSF-oebs-v2")
+class UvalidertOrdrelinjeMessage(
+    @JsonProperty("orderLine")
+    val data: RåOrdrelinje,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : Message {
+    override val eventName: String = "hm-uvalidert-ordrelinje"
 
-class UvalidertOrdrelinjeMessage(val orderLine: RåOrdrelinje) :
-    Message(eventName = "hm-uvalidert-ordrelinje") {
-    @Suppress("unused") // leses kanskje nedstrøms
     val eventCreated = opprettet
 }

src/main/kotlin/no/nav/hjelpemidler/oebs/listener/model/ServiceforespørselEndringMessage.kt

@@ -0,0 +1,14 @@
+package no.nav.hjelpemidler.oebs.listener.model
+
+import no.nav.hjelpemidler.domain.id.UUID
+import no.nav.hjelpemidler.oebs.listener.api.ServiceforespørselEndring
+import java.time.LocalDateTime
+import java.util.UUID
+
+data class ServiceforespørselEndringMessage(
+    val data: ServiceforespørselEndring,
+    override val eventId: UUID = UUID(),
+    override val opprettet: LocalDateTime = LocalDateTime.now(),
+) : Message {
+    override val eventName: String = "hm-EndretSF-oebs-v2"
+}