From 66f35401bcb9d56bf1b5bc408e53ab6764b6cb3c Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Sat, 13 Apr 2024 20:41:46 +0200
Subject: [PATCH] Adjustments

---
 .../iktdev/mediaprocessing/processer/Coordinator.kt  | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
index 9e5f3463..35c30468 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
@@ -97,11 +97,13 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
         val existing = eventManager.getAllProcessEvents().map { it.eventId }
         val messages = eventManager.getEventsUncompleted()
 
-        val validMessages = messages.filter { list -> list.any { it.event in processKafkaEvents } }
-            .filter { list ->
-                list.any { it.event == KafkaEvents.EventMediaProcessStarted } ||
-                        (list.any { it.event == KafkaEvents.EventMediaWorkProceedPermitted } && list.any { it.event == KafkaEvents.EVENT_REQUEST_PROCESS_STARTED })
-            }.flatten().filter { it.event in processKafkaEvents }
+
+        val usableMessages = messages.filter { lists -> lists.any { it.event in processKafkaEvents } }
+
+
+        val validMessages = usableMessages.filter { lists -> lists.any { it.event == KafkaEvents.EventMediaProcessStarted } ||
+                (lists.any { it.event == KafkaEvents.EVENT_REQUEST_PROCESS_STARTED } && lists.any { it.event == KafkaEvents.EventMediaWorkProceedPermitted } )
+        }.flatten().filter { it.event in processKafkaEvents }
 
         validMessages.filter { it.eventId !in existing }.forEach {
             eventManager.setProcessEvent(it.event, Message(