Leser også eventer fra tms-ekstern-varsling.

Author: chris-santa

src/main/kotlin/no/nav/tms/statistikk/eksternVarsling/EksternVarslingSubscriber.kt

@@ -11,7 +11,7 @@ class EksternVarslingSubscriber(
     private val eksternVarslingRepository: EksternVarslingRepository
 ) : Subscriber() {
 
-    override fun subscribe() = Subscription.forEvent("eksternStatusOppdatert")
+    override fun subscribe() = Subscription.forEvents("eksternStatusOppdatert", "eksternVarslingStatusOppdatert")
         .withFields(
             "kanal",
             "varselId",

src/test/kotlin/no/nav/tms/statistikk/eksternVarsling/EksternVarslingSinkTest.kt renamed to src/test/kotlin/no/nav/tms/statistikk/eksternVarsling/EksternVarslingSubscriberTest.kt

@@ -15,7 +15,7 @@ import org.junit.jupiter.api.TestInstance
 import java.util.*
 
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
-class EksternVarslingSinkTest {
+class EksternVarslingSubscriberTest {
 
     private val db = LocalPostgresDatabase.cleanDb()
     private val varselRepository = VarselRepository(db)
@@ -104,6 +104,15 @@ class EksternVarslingSinkTest {
         varsel3.eksternVarslingSendtSms shouldBe true
         varsel3.eksternVarslingSendtEpost shouldBe true
     }
+
+    @Test
+    fun `leser også eventer fra ny ekstern-varsling app`() {
+        broadcaster.broadcastJson(SMS.testMessageNew("123"))
+        broadcaster.broadcastJson(EPOST.testMessageNew("124"))
+
+        db.getEksternVarsling("123").first() shouldNotBe null
+        db.getEksternVarsling("124").first() shouldNotBe null
+    }
 }
 
 
@@ -121,3 +130,19 @@ private fun String.testMessage(eventId: String, ident: String = eksternVarslingT
     "kanal": "${this}",
     "tidspunkt": "${nowAtUtcZ()}"
 }"""
+
+private fun String.testMessageNew(eventId: String, ident: String = eksternVarslingTestIdent) = """{
+    "@event_name": "eksternVarslingStatusOppdatert",
+    "ident": "$ident",
+    "status": "sendt",
+    "varselId": "$eventId",
+    "varseltype": "oppgave",
+    "produsent": {
+        "cluster": "dev-gcp",
+        "namespace": "pto",
+        "appnavn": "veilarbaktivitet"                        
+    },
+    "kanal": "${this}",
+    "batch": true,
+    "tidspunkt": "${nowAtUtcZ()}"
+}"""