fix: manage unhandled process interruption

SmartOperatingBlock · Jun 5, 2023 · 4f228d4 · 4f228d4
1 parent e82a9a4
commit 4f228d4
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 2 deletions.
diff --git a/src/main/kotlin/application/handler/ProcessEventHandlers.kt b/src/main/kotlin/application/handler/ProcessEventHandlers.kt
@@ -9,7 +9,6 @@
 package application.handler
 
 import application.controller.manager.EventProducer
-import application.handler.ProcessEventHandlers.cast
 import application.presenter.event.model.Event
 import application.presenter.event.model.ProcessEvent
 import application.presenter.event.model.SurgeryReportEvent
@@ -366,6 +365,9 @@ object ProcessEventHandlers {
      */
     class ProcessManualEventHandler(
         private val surgicalProcessRepository: SurgicalProcessRepository,
+        private val surgeryBookingRepository: BookingRepository,
+        private val patientRepository: PatientRepository,
+        private val medicalDeviceRepository: MedicalDeviceRepository,
     ) : EventHandler {
 
         override fun canHandle(event: Event<*>): Boolean = event.cast<ProcessEvent<*>> {
@@ -399,6 +401,32 @@ object ProcessEventHandlers {
                                 ProcessData.ProcessState.valueOf(this.data.manualEvent),
                                 surgicalProcessRepository,
                             ).execute()
+                            SurgicalProcessServices.DeleteSurgicalProcess(
+                                surgicalProcess.id,
+                                surgicalProcessRepository,
+                            ).execute()
+                            SurgeryBookingServices.GetSurgeryBookingByPatient(
+                                PatientData.PatientId(surgicalProcess.patientId.id),
+                                surgeryBookingRepository,
+                            ).execute()?.let { booking ->
+                                SurgeryBookingServices.DeleteSurgeryBooking(
+                                    booking.id,
+                                    surgeryBookingRepository,
+                                ).execute()
+                                PatientDataServices.DeletePatient(
+                                    surgicalProcess.patientId,
+                                    patientRepository,
+                                ).execute()
+                                MedicalDeviceServices.GetMedicalDeviceUsageByProcessId(
+                                    surgicalProcess.id,
+                                    medicalDeviceRepository,
+                                ).execute().forEach { device ->
+                                    MedicalDeviceServices.DeleteImplantableMedicalDevice(
+                                        device,
+                                        medicalDeviceRepository,
+                                    ).execute()
+                                }
+                            }
                         }
                         else -> {}
                     }

diff --git a/src/main/kotlin/infrastructure/event/KafkaClient.kt b/src/main/kotlin/infrastructure/event/KafkaClient.kt
@@ -80,7 +80,12 @@ class KafkaClient(private val provider: ManagerProvider) : EventProducer {
                 this,
             ),
             ProcessEventHandlers.EmergencySurgeryEventHandler(surgicalProcessController, patientDataController),
-            ProcessEventHandlers.ProcessManualEventHandler(surgicalProcessController),
+            ProcessEventHandlers.ProcessManualEventHandler(
+                surgicalProcessController,
+                surgeryBookingController,
+                patientDataController,
+                medicalDeviceController,
+            ),
         )
     }