feat: add patient tracking event

Author: andrea-acampora

src/main/kotlin/entities/events/EventProperties.kt

@@ -27,6 +27,7 @@ object EventProperties {
         PATIENT_SATURATION_UPDATE_EVENT("process-events"),
         PATIENT_HEARTBEAT_UPDATE_EVENT("process-events"),
         EMPTY_EVENT(""),
+        PATIENT_TRACKED_EVENT("process-events"),
         TRACKING_EVENT("tracking-events"),
         SURGERY_BOOKINGS_EVENT("surgery-bookings-events")
     }

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

@@ -32,4 +32,23 @@ object ProcessData {
      * @param inUse true if the medical technology is in use, false otherwise.
      */
     data class MedicalTechnologyUsage(val medicalTechnologyID: String, val inUse: Boolean)
+
+    /**
+     * The event of patient tracking inside the operating block.
+     * @param patientId the id of the patient.
+     * @param roomId the id of the room.
+     * @param entered true if is entered in the room, false otherwise.
+     * @param roomType the type of the room.
+     */
+    data class PatientTracked(
+        val patientId: String,
+        val roomId: String,
+        val entered: Boolean,
+        val roomType: RoomType
+    )
+
+    /** The type of the room where the patient is tracked. **/
+    enum class RoomType {
+        PRE_OPERATING_ROOM, OPERATING_ROOM
+    }
 }

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

@@ -41,7 +41,12 @@ object RelationshipEvents {
         /**
          * The model of the relationship source.
          */
-        val sourceModel: String
+        val sourceModel: String,
+
+        /**
+         * The model of the relationship target.
+         */
+        val targetModel: String
     )
 
     /**

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

@@ -14,8 +14,12 @@ import entities.events.EventProperties.EventKey
 import entities.events.ProcessEvent
 import entities.events.TrackingEvent
 import entities.process.ProcessData
+import entities.process.ProcessData.RoomType.OPERATING_ROOM
+import entities.process.ProcessData.RoomType.PRE_OPERATING_ROOM
 import infrastructure.digitaltwins.events.RelationshipEvents
 import infrastructure.digitaltwins.events.TwinProperties.DTModelID.HEALTH_PROFESSIONAL_MODEL_ID
+import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PATIENT_MODEL_ID
+import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PRE_OPERATING_ROOM_MODEL_ID
 import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PROCESS_MODEL_ID
 
 /**
@@ -38,7 +42,24 @@ class RelationshipEventParser {
                         data = true,
                         dateTime = createdRelationship.eventDateTime
                     )
-
+                    else -> EmptyEvent()
+                }
+            }
+            PATIENT_MODEL_ID.id -> {
+                when (createdRelationship.data.relationshipName) {
+                    "rel_is_inside" -> ProcessEvent(
+                        key = EventKey.PATIENT_TRACKED_EVENT,
+                        data = ProcessData.PatientTracked(
+                            patientId = createdRelationship.data.sourceId,
+                            roomId = createdRelationship.data.targetId,
+                            entered = true,
+                            roomType =
+                            if (createdRelationship.data.targetModel == PRE_OPERATING_ROOM_MODEL_ID.id)
+                                PRE_OPERATING_ROOM
+                            else OPERATING_ROOM
+                        ),
+                        dateTime = createdRelationship.eventDateTime
+                    )
                     else -> EmptyEvent()
                 }
             }
@@ -65,12 +86,34 @@ class RelationshipEventParser {
      */
     fun manageDeletedRelationship(deletedRelationship: RelationshipEvents.RelationshipEvent): Event<Any> =
         when (deletedRelationship.data.relationshipName) {
-            "rel_is_inside" -> TrackingEvent(
-                healthProfessionalId = deletedRelationship.data.sourceId,
-                roomId = deletedRelationship.data.targetId,
-                data = false,
-                dateTime = deletedRelationship.eventDateTime
-            )
+            "rel_is_inside" -> {
+                when (deletedRelationship.data.sourceModel) {
+                    HEALTH_PROFESSIONAL_MODEL_ID.id -> {
+                        TrackingEvent(
+                            healthProfessionalId = deletedRelationship.data.sourceId,
+                            roomId = deletedRelationship.data.targetId,
+                            data = false,
+                            dateTime = deletedRelationship.eventDateTime
+                        )
+                    }
+                    PATIENT_MODEL_ID.id -> {
+                        ProcessEvent(
+                            key = EventKey.PATIENT_TRACKED_EVENT,
+                            data = ProcessData.PatientTracked(
+                                patientId = deletedRelationship.data.sourceId,
+                                roomId = deletedRelationship.data.targetId,
+                                entered = false,
+                                roomType =
+                                if (deletedRelationship.data.targetModel == PRE_OPERATING_ROOM_MODEL_ID.id)
+                                    PRE_OPERATING_ROOM
+                                else OPERATING_ROOM
+                            ),
+                            dateTime = deletedRelationship.eventDateTime
+                        )
+                    }
+                    else -> EmptyEvent()
+                }
+            }
             else -> EmptyEvent()
         }
 }

src/test/resources/SampleTrackingEvent.json

@@ -5,7 +5,8 @@
     "$sourceId":"health1",
     "$relationshipName":"rel_is_inside",
     "$targetId":"ProvaOperatingRoom",
-    "$sourceModel":"dtmi:io:github:smartoperatingblock:HealthProfessional;1"
+    "$sourceModel":"dtmi:io:github:smartoperatingblock:HealthProfessional;1",
+    "$targetModel":"dtmi:io:github:smartoperatingblock:OperatingRoom;1"
   },
   "contenttype":"application/json",
   "traceparent":"00-acc18931bfbcdac4cd520dc3b08fc871-53281297c87d648b-01",