iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adjustment

Browse Source
This commit is contained in:
bskjon 2024-04-22 01:34:05 +02:00
parent ea992e6ea7
commit d10bca3d1a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Task.kt
View File

@ -46,7 +46,7 @@ abstract class TaskCreator(coordinator: Coordinator):
*/ */
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? { override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
val referenceId = event.referenceId 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() val current = processedEvents[referenceId] ?: setOf()
current.toMutableSet().addAll(eventIds) current.toMutableSet().addAll(eventIds)
@ -59,7 +59,7 @@ abstract class TaskCreator(coordinator: Coordinator):
val referenceId = events.firstOrNull()?.referenceId ?:return false val referenceId = events.firstOrNull()?.referenceId ?:return false
val preExistingEvents = processedEvents[referenceId]?: setOf() 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 } val newEvents = forwardedEvents.filter { it !in preExistingEvents }
return newEvents.isNotEmpty() return newEvents.isNotEmpty()