publisering av ordrefeilmelding til ntfy

Author: di0nys1us

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

@@ -0,0 +1,78 @@
+package no.nav.hjelpemidler
+
+import com.fasterxml.jackson.annotation.JsonValue
+import io.ktor.client.HttpClient
+import io.ktor.client.call.body
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
+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 kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.runBlocking
+import mu.KotlinLogging
+
+object Ntfy {
+    private val log = KotlinLogging.logger {}
+    private val client = HttpClient(CIO) {
+        expectSuccess = false
+        install(ContentNegotiation) {
+            jackson()
+        }
+    }
+
+    fun publish(notification: Notification) = runBlocking(Dispatchers.IO) {
+        val response = client.post("https://ntfy.sh") {
+            contentType(ContentType.Application.Json)
+            setBody(notification)
+        }
+        when (response.status) {
+            HttpStatusCode.OK -> Unit
+            else -> log.warn("Feil ved publisering til ntfy: ${response.body<Map<String, Any?>>()}")
+        }
+    }
+
+    data class Notification(
+        val topic: String = "teamdigihot.hm-oebs-listener",
+        val title: String? = null,
+        val message: String? = null,
+        val priority: Priority = Priority.DEFAULT,
+        val tags: Set<String> = emptySet(),
+        val click: String? = null,
+        val icon: String? = null,
+        val actions: Set<Action> = emptySet(),
+        val attach: String? = null,
+        val filename: String? = null,
+        val email: String? = null,
+        val delay: String? = null,
+    )
+
+    data class Action(
+        val action: ActionType,
+        val label: String,
+        val clear: Boolean = false,
+        val url: String? = null,
+        val method: String? = null,
+        val headers: Map<String, String> = emptyMap(),
+        val body: String? = null,
+        val intent: String? = null,
+        val extras: Map<String, String> = emptyMap(),
+    )
+
+    enum class Priority(@JsonValue val value: Int) {
+        MIN(1),
+        LOW(2),
+        DEFAULT(3),
+        HIGH(4),
+        MAX(5),
+    }
+
+    enum class ActionType(@JsonValue val value: String) {
+        VIEW("view"),
+        BROADCAST("broadcast"),
+        HTTP("http"),
+    }
+}

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

@@ -7,6 +7,7 @@ import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
 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 kotlinx.coroutines.Dispatchers
@@ -17,6 +18,7 @@ import no.nav.hjelpemidler.configuration.Configuration
 object Slack {
     private val log = KotlinLogging.logger {}
     private val client = HttpClient(CIO) {
+        expectSuccess = false
         install(ContentNegotiation) {
             jackson()
         }
@@ -36,6 +38,9 @@ object Slack {
                         )
                     )
                 }
-            log.info(response.body<String>())
+            when (response.status) {
+                HttpStatusCode.OK -> Unit
+                else -> log.info(response.body<String>())
+            }
         }
 }

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

@@ -7,6 +7,7 @@ import io.ktor.server.routing.Route
 import io.ktor.server.routing.post
 import mu.KotlinLogging
 import no.nav.hjelpemidler.Context
+import no.nav.hjelpemidler.Ntfy
 import no.nav.hjelpemidler.Slack
 import no.nav.hjelpemidler.configuration.Configuration
 import java.time.LocalDateTime
@@ -39,6 +40,21 @@ fun Route.ordreAPI(context: Context) {
             text = "*${Configuration.profile}* - $feilmelding",
             channel = "#papaya-alerts"
         )
+        Ntfy.publish(
+            Ntfy.Notification(
+                title = "Mottok ordrefeilmelding",
+                message = "Status: ${feilmelding.status}",
+                priority = Ntfy.Priority.HIGH,
+                actions = setOf(
+                    Ntfy.Action(
+                        action = Ntfy.ActionType.VIEW,
+                        label = "Se detaljer i Slack",
+                        clear = true,
+                        url = "https://nav-it.slack.com/archives/C02LS2W05E1"
+                    )
+                )
+            )
+        )
         call.response.status(HttpStatusCode.OK)
     }
 }