Adding test API

navikt · Jun 4, 2021 · 029e76d · 029e76d
1 parent 19b757c
commit 029e76d
Show file tree

Hide file tree

Showing 3 changed files with 36 additions and 37 deletions.
diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/config/ApplicationContext.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/config/ApplicationContext.kt
@@ -20,10 +20,10 @@ class ApplicationContext {
 //        topic = environment.kafkaTopics.varselKvitteringOutgoing
 //    )
 
-//    val varselProducer = VarselEventProducer(
-//        env = environment.kafka,
-//        topic = environment.kafkaTopics.varselIncoming
-//    )
+    val varselProducer = VarselEventProducer(
+        env = environment.kafka,
+        topic = environment.kafkaTopics.varselIncoming
+    )
 
 
 //    val beskjedProducer = BrukernotifikasjonBeskjedProducer(

diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/config/system/rest.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/config/system/rest.kt
@@ -34,7 +34,6 @@ fun Application.healthModule(appContext: ApplicationContext) {
             application.log.debug(it.buildText())
         }
         healthApi(appContext.metrics)
-        //varselApi(appContext.varselProducer)
-        varselApi()
+        varselApi(appContext.varselProducer)
     }
 }
diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/varsel/VarselApi.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/varsel/VarselApi.kt
@@ -6,9 +6,11 @@ import io.ktor.request.*
 import io.ktor.response.*
 import io.ktor.routing.*
 import org.slf4j.LoggerFactory
+import java.time.LocalDateTime
+import java.util.*
 
 fun Route.varselApi(
-    //varselEventProducer: VarselEventProducer
+    varselEventProducer: VarselEventProducer
 ) {
 
     val logger = LoggerFactory.getLogger(javaClass)
@@ -17,43 +19,41 @@ fun Route.varselApi(
 
         post {
             val varsel = call.receive<Varsel>()
-            println("Here 4")
-
-//            varselEventProducer.send(
-//                CreateVarselVarselEvent(
-//                    UUID.randomUUID(),
-//                    LocalDateTime.now(),
-//                    varsel.system,
-//                    varsel.id,
-//                    varsel.type,
-//                    varsel.fodselsnummer,
-//                    varsel.groupId,
-//                    varsel.message,
-//                    varsel.link.toString(),
-//                    varsel.sikkerhetsnivaa,
-//                    varsel.visibleUntil,
-//                    varsel.externalVarsling
-//                )
-//            )
+
+            varselEventProducer.send(
+                CreateVarselVarselEvent(
+                    UUID.randomUUID(),
+                    LocalDateTime.now(),
+                    varsel.system,
+                    varsel.id,
+                    varsel.type,
+                    varsel.fodselsnummer,
+                    varsel.groupId,
+                    varsel.message,
+                    varsel.link.toString(),
+                    varsel.sikkerhetsnivaa,
+                    varsel.visibleUntil,
+                    varsel.externalVarsling
+                )
+            )
 
             call.respond(HttpStatusCode.Created)
 
         }
 
         post("/done") {
             val done = call.receive<Done>()
-            println("Here 5")
-
-//            varselEventProducer.send(
-//                DoneVarselEvent(
-//                    UUID.randomUUID(),
-//                    LocalDateTime.now(),
-//                    done.system,
-//                    done.id,
-//                    done.fodselsnummer,
-//                    done.groupId
-//                )
-//            )
+
+            varselEventProducer.send(
+                DoneVarselEvent(
+                    UUID.randomUUID(),
+                    LocalDateTime.now(),
+                    done.system,
+                    done.id,
+                    done.fodselsnummer,
+                    done.groupId
+                )
+            )
 
             call.respond(HttpStatusCode.Created)
         }