chore: add parser to event parser

SmartOperatingBlock · Feb 23, 2023 · 781fe29 · 781fe29
1 parent eaeeada
commit 781fe29
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/main/kotlin/infrastructure/digitaltwins/parser/DTEventParser.kt b/src/main/kotlin/infrastructure/digitaltwins/parser/DTEventParser.kt
@@ -13,7 +13,9 @@ import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
 import entities.events.EmptyEvent
 import entities.events.Event
+import infrastructure.digitaltwins.events.LifecycleEvents.LifecycleEvent
 import infrastructure.digitaltwins.events.RelationshipEvents.RelationshipEvent
+import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.CREATE
 import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.RELATIONSHIP_CREATE
 import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.RELATIONSHIP_DELETE
 import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.UPDATE
@@ -26,6 +28,7 @@ class DTEventParser : EventParser<String> {
 
     private val updateEventParser = UpdateEventParser()
     private val relationshipEventParser = RelationshipEventParser()
+    private val lifecycleEventParser = LifecycleEventParser()
 
     override fun parseEvent(inputEvent: String): Event<Any> {
         val mapper = jacksonObjectMapper()
@@ -36,6 +39,11 @@ class DTEventParser : EventParser<String> {
                     mapper.readValue(inputEvent, UpdateTwinEvent::class.java)
                 )
             }
+            CREATE.type -> {
+                lifecycleEventParser.manageEvent(
+                    mapper.readValue(inputEvent.replace("$", ""), LifecycleEvent::class.java)
+                )
+            }
             RELATIONSHIP_CREATE.type -> {
                 relationshipEventParser.manageCreatedRelationship(
                     mapper.readValue(inputEvent.replace("$", ""), RelationshipEvent::class.java)