feat: add medical technology usage event

Author: andrea-acampora

src/main/kotlin/entities/process/ProcessData.kt

@@ -26,4 +26,10 @@ object ProcessData {
      * @param processId the id of the surgical process.
      */
     data class ProcessInfo(val info: String, val processId: String)
+
+    /**
+     * The event of medical technology usage given its [medicalTechnologyID].
+     * @param isInUse true if the medical technology is in use, false otherwise.
+     */
+    data class MedicalTechnologyUsage(val medicalTechnologyID: String, val isInUse: Boolean)
 }

src/main/kotlin/infrastructure/digitaltwins/events/TwinProperties.kt

@@ -24,6 +24,14 @@ object TwinProperties {
         PRESENCE("/presence_inside")
     }
 
+    /**
+     * The properties path of Process events.
+     * @param path the property path.
+     */
+    enum class ProcessProperties(val path: String) {
+        MEDICAL_TECHNOLOGY("/is_in_use")
+    }
+
     /**
      * The properties path of Patient Model.
      * @param path the property path.
@@ -35,7 +43,7 @@ object TwinProperties {
         IS_ON_OPERATING_TABLE("/is_on_operating_table"),
         RESPIRATORY_RATE("/respiratory_rate"),
         SATURATION_PERCENTAGE("/saturation_percentage"),
-        HEARTBEAT("/heart_beat")
+        HEARTBEAT("/heart_beat"),
     }
 
     /**
@@ -48,7 +56,8 @@ object TwinProperties {
         PROCESS_MODEL_ID("dtmi:io:github:smartoperatingblock:SurgicalProcess;1"),
         PATIENT_MODEL_ID("dtmi:io:github:smartoperatingblock:Patient;1"),
         HEALTH_PROFESSIONAL_MODEL_ID("dtmi:io:github:smartoperatingblock:HealthProfessional;1"),
-        SURGERY_BOOKING_MODEL_ID("dtmi:io:github:smartoperatingblock:SurgeryBooking;1")
+        SURGERY_BOOKING_MODEL_ID("dtmi:io:github:smartoperatingblock:SurgeryBooking;1"),
+        MEDICAL_TECHNOLOGY_MODEL_ID("dtmi:io:github:smartoperatingblock:MedicalTechnology;1")
     }
 
     /**

src/main/kotlin/infrastructure/digitaltwins/parser/UpdateEventParser.kt

@@ -25,7 +25,9 @@ import entities.process.PatientData.PatientData
 import entities.process.PatientData.RespiratoryRate
 import entities.process.PatientData.Saturation
 import entities.process.PatientData.SystolicPressure
-import entities.process.ProcessData
+import entities.process.ProcessData.MedicalTechnologyUsage
+import entities.process.ProcessData.ProcessInfo
+import infrastructure.digitaltwins.events.TwinProperties.DTModelID.MEDICAL_TECHNOLOGY_MODEL_ID
 import infrastructure.digitaltwins.events.TwinProperties.DTModelID.OPERATING_ROOM_MODEL_ID
 import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PATIENT_MODEL_ID
 import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PRE_OPERATING_ROOM_MODEL_ID
@@ -37,6 +39,7 @@ import infrastructure.digitaltwins.events.TwinProperties.PatientProperties.IS_ON
 import infrastructure.digitaltwins.events.TwinProperties.PatientProperties.RESPIRATORY_RATE
 import infrastructure.digitaltwins.events.TwinProperties.PatientProperties.SATURATION_PERCENTAGE
 import infrastructure.digitaltwins.events.TwinProperties.PatientProperties.SYSTOLIC_PRESSURE
+import infrastructure.digitaltwins.events.TwinProperties.ProcessProperties.MEDICAL_TECHNOLOGY
 import infrastructure.digitaltwins.events.TwinProperties.RoomProperties.HUMIDITY
 import infrastructure.digitaltwins.events.TwinProperties.RoomProperties.LUMINOSITY
 import infrastructure.digitaltwins.events.TwinProperties.RoomProperties.PRESENCE
@@ -58,7 +61,7 @@ class UpdateEventParser {
             OPERATING_ROOM_MODEL_ID.id, PRE_OPERATING_ROOM_MODEL_ID.id -> {
                 manageRoomEvents(updateTwinEvent)
             }
-            PATIENT_MODEL_ID.id, PROCESS_MODEL_ID.id -> {
+            PATIENT_MODEL_ID.id, PROCESS_MODEL_ID.id, MEDICAL_TECHNOLOGY_MODEL_ID.id -> {
                 manageProcessEvents(updateTwinEvent)
             }
             else -> EmptyEvent()
@@ -95,7 +98,7 @@ class UpdateEventParser {
         when (updateTwinEvent.data.patch[0].path) {
             IS_ON_OPERATING_TABLE.path -> {
                 ProcessEvent(
-                    data = ProcessData.ProcessInfo("Patient on Operating Bed", updateTwinEvent.id),
+                    data = ProcessInfo("Patient on Operating Bed", updateTwinEvent.id),
                     dateTime = updateTwinEvent.eventDateTime
                 )
             }
@@ -153,6 +156,15 @@ class UpdateEventParser {
                     dateTime = updateTwinEvent.eventDateTime
                 )
             }
+            MEDICAL_TECHNOLOGY.path -> {
+                ProcessEvent(
+                    data = MedicalTechnologyUsage(
+                        updateTwinEvent.id,
+                        updateTwinEvent.data.patch[0].value as Boolean
+                    ),
+                    dateTime = updateTwinEvent.eventDateTime
+                )
+            }
             else -> EmptyEvent()
         }
 }