From d10bca3d1a0acbc4062348b652060dce9eff3f01 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Mon, 22 Apr 2024 01:34:05 +0200
Subject: [PATCH] Adjustment

---
 .../main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt
index acc3f8cb..97a4dea8 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt
@@ -46,7 +46,7 @@ abstract class TaskCreator(coordinator: Coordinator):
      */
     override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
         val referenceId = event.referenceId
-        val eventIds = events.filter { it.event in requiredEvents }.map { it.eventId }
+        val eventIds = events.filter { it.event in requiredEvents + listensForEvents }.map { it.eventId }
 
         val current = processedEvents[referenceId] ?: setOf()
         current.toMutableSet().addAll(eventIds)
@@ -59,7 +59,7 @@ abstract class TaskCreator(coordinator: Coordinator):
         val referenceId = events.firstOrNull()?.referenceId ?:return false
         val preExistingEvents = processedEvents[referenceId]?: setOf()
 
-        val forwardedEvents = events.filter { it.event in requiredEvents }.map { it.eventId }
+        val forwardedEvents = events.filter { it.event in (requiredEvents + listensForEvents) }.map { it.eventId }
         val newEvents = forwardedEvents.filter { it !in preExistingEvents }
         return newEvents.isNotEmpty()