Fix CoreEvent vague json converting in temp events

opexdev · Oct 22, 2023 · 5520012 · 5520012
1 parent eabac88
commit 5520012
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...es/src/main/kotlin/co/nilin/opex/accountant/ports/postgres/impl/TempEventPersisterImpl.kt b/...es/src/main/kotlin/co/nilin/opex/accountant/ports/postgres/impl/TempEventPersisterImpl.kt
@@ -37,7 +37,7 @@ class TempEventPersisterImpl(
     override suspend fun loadTempEvents(ouid: String): List<CoreEvent> {
         return tempEventRepository
             .findByOuid(ouid)
-            .map { objectMapper.readValue<CoreEvent>(it.eventBody) }
+            .map { objectMapper.readValue(it.eventBody, Class.forName(it.eventType)) as CoreEvent }
             .toList()
     }
 
@@ -56,7 +56,7 @@ class TempEventPersisterImpl(
                 TempEvent(
                     it.id!!,
                     it.ouid,
-                    objectMapper.readValue(it.eventBody),
+                    objectMapper.readValue(it.eventBody, Class.forName(it.eventType)) as CoreEvent,
                     it.eventDate
                 )
             }