endepunkt for ordrekvittering

Author: di0nys1us

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

@@ -12,7 +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.ordreAPI
 import no.nav.hjelpemidler.api.serviceforespørselAPI
 import no.nav.hjelpemidler.configuration.Configuration
 import java.net.InetAddress
@@ -66,7 +66,7 @@ fun main() {
             authenticate("oebsToken") {
                 ordrelinjeAPI(context)
                 serviceforespørselAPI(context)
-                rekvisisjonAPI(context)
+                ordreAPI(context)
             }
         }
     }.build()

src/main/kotlin/no/nav/hjelpemidler/api/OrdreAPI.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.ordreAPI(context: Context) {
+    post("/ordrekvittering") {
+        val kvittering = call.receive<Ordrekvittering>()
+        logg.info { "Mottok ordrekvittering, id=${kvittering.id}" }
+        context.publish(
+            kvittering.saksnummer,
+            OrdrekvitteringMottatt(kvittering = kvittering)
+        )
+        call.response.status(HttpStatusCode.OK)
+    }
+}
+
+data class Ordrekvittering(
+    val id: String,
+    val saksnummer: String,
+    val ordrenummer: String,
+    val system: String,
+    val status: String,
+)
+
+data class OrdrekvitteringMottatt(
+    val eventId: UUID = UUID.randomUUID(),
+    val eventName: String = "hm-ordrekvittering-mottatt",
+    val opprettet: LocalDateTime = LocalDateTime.now(),
+    val kvittering: Ordrekvittering,
+)

src/test/kotlin/no/nav/hjelpemidler/api/OrdreAPITest.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 OrdreAPITest {
+
+    private val context = Context(mockk(relaxed = true))
+
+    @Test
+    internal fun `sender ut ordrekvittering på rapid`() = testApplication {
+        configure()
+        val body = context.jsonMapper.writeValueAsString(
+            Ordrekvittering(
+                id = "1",
+                saksnummer = "2",
+                ordrenummer = "3",
+                system = "HOTSAK",
+                status = "ENTERED"
+            )
+        )
+        client.post("/ordrekvittering") {
+            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") {
+                ordreAPI(context)
+            }
+        }
+    }
+}