endepunkt for kvittering for rekvisisjon

Author: di0nys1us

build.gradle.kts

@@ -38,6 +38,7 @@ dependencies {
     // Testing
     testImplementation(kotlin("test"))
     testImplementation("io.ktor:ktor-server-test-host:$ktorVersion")
+    testImplementation("io.mockk:mockk:1.12.4")
 }
 
 tasks.withType<KotlinCompile> {

src/main/kotlin/no/nav/hjelpemidler/Application.kt

@@ -12,6 +12,7 @@ import no.nav.helse.rapids_rivers.KafkaConfig
 import no.nav.helse.rapids_rivers.RapidApplication
 import no.nav.helse.rapids_rivers.RapidsConnection
 import no.nav.hjelpemidler.api.ordrelinjeAPI
+import no.nav.hjelpemidler.api.rekvisisjonAPI
 import no.nav.hjelpemidler.api.serviceforespørselAPI
 import no.nav.hjelpemidler.configuration.Configuration
 import java.net.InetAddress
@@ -65,6 +66,7 @@ fun main() {
             authenticate("oebsToken") {
                 ordrelinjeAPI(context)
                 serviceforespørselAPI(context)
+                rekvisisjonAPI(context)
             }
         }
     }.build()

src/main/kotlin/no/nav/hjelpemidler/Context.kt

@@ -1,10 +1,20 @@
 package no.nav.hjelpemidler
 
+import com.fasterxml.jackson.databind.SerializationFeature
+import com.fasterxml.jackson.databind.json.JsonMapper
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
+import com.fasterxml.jackson.module.kotlin.jacksonMapperBuilder
 import no.nav.helse.rapids_rivers.MessageContext
 import no.nav.hjelpemidler.metrics.SensuMetrics
 
 class Context(
     private val messageContext: MessageContext,
 ) : MessageContext by messageContext {
+    val jsonMapper: JsonMapper = jacksonMapperBuilder()
+        .addModule(JavaTimeModule())
+        .disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)
+        .build()
     val metrics: SensuMetrics = SensuMetrics(messageContext)
+
+    fun <T> publish(key: String, message: T) = publish(key, jsonMapper.writeValueAsString(message))
 }

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

@@ -0,0 +1,40 @@
+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.routing.Route
+import io.ktor.server.routing.post
+import mu.KotlinLogging
+import no.nav.hjelpemidler.Context
+import java.time.LocalDateTime
+import java.util.UUID
+
+private val logg = KotlinLogging.logger { }
+
+fun Route.rekvisisjonAPI(context: Context) {
+    post("/rekvisisjon-kvittering") {
+        val kvittering = call.receive<RekvisisjonKvittering>()
+        logg.info { "Mottok kvittering for rekvisisjon, id=${kvittering.id}" }
+        context.publish(
+            kvittering.saksnummer,
+            RekvisisjonKvitteringMottatt(kvittering = kvittering)
+        )
+        call.response.status(HttpStatusCode.OK)
+    }
+}
+
+data class RekvisisjonKvittering(
+    val id: String,
+    val saksnummer: String,
+    val ordrenummer: String,
+    val system: String,
+    val status: String,
+)
+
+data class RekvisisjonKvitteringMottatt(
+    val eventId: UUID = UUID.randomUUID(),
+    val eventName: String = "hm-rekvisisjon-kvittering-mottatt",
+    val opprettet: LocalDateTime = LocalDateTime.now(),
+    val kvittering: RekvisisjonKvittering,
+)

src/test/kotlin/no/nav/hjelpemidler/api/RekvisisjonAPITest.kt

@@ -0,0 +1,65 @@
+package no.nav.hjelpemidler.api
+
+import io.ktor.client.request.bearerAuth
+import io.ktor.client.request.post
+import io.ktor.client.request.setBody
+import io.ktor.http.ContentType
+import io.ktor.http.HttpStatusCode
+import io.ktor.http.contentType
+import io.ktor.serialization.jackson.jackson
+import io.ktor.server.auth.Authentication
+import io.ktor.server.auth.authenticate
+import io.ktor.server.plugins.contentnegotiation.ContentNegotiation
+import io.ktor.server.testing.ApplicationTestBuilder
+import io.ktor.server.testing.testApplication
+import io.mockk.mockk
+import io.mockk.verify
+import no.nav.hjelpemidler.Context
+import no.nav.hjelpemidler.shouldBe
+import no.nav.hjelpemidler.token
+import kotlin.test.Test
+
+internal class RekvisisjonAPITest {
+
+    private val context = Context(mockk(relaxed = true))
+
+    @Test
+    internal fun `sender ut rekvisisjon på rapid`() = testApplication {
+        configure()
+        val body = context.jsonMapper.writeValueAsString(
+            RekvisisjonKvittering(
+                id = "1",
+                saksnummer = "2",
+                ordrenummer = "3",
+                system = "HOTSAK",
+                status = "ENTERED"
+            )
+        )
+        client.post("/rekvisisjon-kvittering") {
+            bearerAuth("qwer1234")
+            contentType(ContentType.Application.Json)
+            setBody(body)
+        }.apply {
+            status shouldBe HttpStatusCode.OK
+            verify {
+                context.publish("2", match { it.contains(body) })
+            }
+        }
+    }
+
+    private fun ApplicationTestBuilder.configure() {
+        install(ContentNegotiation) {
+            jackson()
+        }
+        install(Authentication) {
+            token("oebsToken") {
+                validate("qwer1234")
+            }
+        }
+        routing {
+            authenticate("oebsToken") {
+                rekvisisjonAPI(context)
+            }
+        }
+    }
+}

src/test/resources/logback-test.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{YYYY-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+    <root level="WARN">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>