From 7638f573ddf1fcd72aec02d221532a399eee2242 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Fri, 19 Apr 2024 02:43:06 +0200
Subject: [PATCH] Update

---
 .../no/iktdev/mediaprocessing/coordinator/Coordinator.kt    | 6 +++---
 .../coordinator/tasks/event/CreateConvertWorkTask.kt        | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
index 44be3eb6..258d7241 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
@@ -35,7 +35,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
         } else {
             io.launch {
                 delay(1000) // Give the database a few sec to update
-                readAllMessagesFor(event.value.referenceId, event.value.eventId)
+                readAllMessagesFor(event.value.referenceId, event.value.eventId, event.key.event)
             }
         }
     }
@@ -110,10 +110,10 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
         }
     }
 
-    fun readAllMessagesFor(referenceId: String, eventId: String) {
+    fun readAllMessagesFor(referenceId: String, eventId: String, event: String) {
         val messages = eventManager.getEventsWith(referenceId)
         if (messages.find { it.eventId == eventId && it.referenceId == referenceId } == null) {
-            log.warn { "EventId ($eventId) for ReferenceId ($referenceId) has not been made available in the database yet." }
+            log.warn { "EventId ($eventId) for ReferenceId ($referenceId) with event $event has not been made available in the database yet." }
             io.launch {
                 val fixedDelay = 1000L
                 delay(fixedDelay)
diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
index 17f0b5fb..4fa8f556 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
@@ -27,7 +27,7 @@ class CreateConvertWorkTask(@Autowired override var coordinator: Coordinator) :
         )
 
     override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
-        log.info { "${event.referenceId} triggered by ${event.event}" }
+        log.info { "${event.referenceId} @ ${event.eventId} triggered by ${event.event}" }
 
         if (!event.data.isSuccess()) {
             return null