chore: add new handler to kafka client

SmartOperatingBlock · Mar 30, 2023 · fc1cb60 · fc1cb60
1 parent 0358e41
commit fc1cb60
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/kotlin/infrastructure/event/KafkaClient.kt b/src/main/kotlin/infrastructure/event/KafkaClient.kt
@@ -10,6 +10,7 @@ package infrastructure.event
 
 import application.controller.MedicalDeviceController
 import application.controller.PatientDataController
+import application.controller.SurgeryBookingController
 import application.controller.SurgicalProcessController
 import application.handler.EventHandler
 import application.handler.EventHandlers
@@ -50,7 +51,7 @@ class KafkaClient(private val provider: ManagerProvider) {
 
         val patientDataController = PatientDataController(provider.patientMedicalDataDatabaseManager)
 
-//        val surgeryBookingController = SurgeryBookingController(provider.surgeryBookingDigitalTwinManager)
+        val surgeryBookingController = SurgeryBookingController(provider.surgeryBookingDigitalTwinManager)
 
         eventHandlers = listOf(
             EventHandlers.MedicalDeviceUsageEventHandler(medicalDeviceController),
@@ -59,6 +60,10 @@ class KafkaClient(private val provider: ManagerProvider) {
             EventHandlers.BodyTemperatureUpdateEventHandler(patientDataController),
             EventHandlers.DiastolicPressureUpdateEventHandler(patientDataController),
             EventHandlers.SystolicPressureUpdateEventHandler(patientDataController),
+            EventHandlers.RespiratoryRateUpdateEventHandler(patientDataController),
+            EventHandlers.SaturationUpdateEventHandler(patientDataController),
+            EventHandlers.HeartbeatUpdateEventHandler(patientDataController),
+            EventHandlers.PatientTrackedEventHandler(surgicalProcessController, surgeryBookingController)
         )
     }