feat: create parser for digital twin relationships events

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

@@ -0,0 +1,74 @@
+/*
+ * Copyright (c) 2023. Smart Operating Block
+ *
+ * Use of this source code is governed by an MIT-style
+ * license that can be found in the LICENSE file or at
+ * https://opensource.org/licenses/MIT.
+ */
+
+package infrastructure.digitaltwins.parser
+
+import entities.events.EmptyEvent
+import entities.events.Event
+import entities.events.ProcessEvent
+import entities.events.TrackingEvent
+import entities.process.ProcessData
+import infrastructure.digitaltwins.events.RelationshipEvents
+import infrastructure.digitaltwins.events.TwinProperties.DTModelID.PROCESS_MODEL_ID
+import infrastructure.digitaltwins.events.TwinProperties.DTModelID.HEALTH_PROFESSIONAL_MODEL_ID
+
+/**
+ * The parser of Azure Digital Twins Relationship Events.
+ */
+class RelationshipEventParser {
+
+    /**
+     * Manage the event of creation of a relationship between Digital Twins.
+     * @param createdRelationship the relationship.
+     *@return the specific [Event].
+     */
+    fun manageCreatedRelationship(createdRelationship: RelationshipEvents.RelationshipEvent): Event<Any> =
+        when (createdRelationship.data.sourceModel) {
+            HEALTH_PROFESSIONAL_MODEL_ID.id -> {
+                when (createdRelationship.data.relationshipName) {
+                    "rel_is_inside" -> TrackingEvent(
+                        healthProfessionalId = createdRelationship.data.sourceId,
+                        roomId = createdRelationship.data.targetId,
+                        data = true,
+                        dateTime = createdRelationship.eventDateTime
+                    )
+
+                    else -> EmptyEvent()
+                }
+            }
+            PROCESS_MODEL_ID.id -> {
+                when (createdRelationship.data.relationshipName) {
+                    "rel_use" -> ProcessEvent(
+                        data = ProcessData.MedicalDeviceUsage(
+                            createdRelationship.data.targetId,
+                            createdRelationship.data.sourceId
+                        ),
+                        dateTime = createdRelationship.eventDateTime
+                    )
+                    else -> EmptyEvent()
+                }
+            }
+            else -> EmptyEvent()
+        }
+
+    /**
+     * Manage the event of delete of a relationship between Digital Twins.
+     * @param deletedRelationship the relationship.
+     *@return the specific [Event]
+     */
+    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
+            )
+            else -> EmptyEvent()
+        }
+}