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

Changed order

Browse Source
This commit is contained in:
bskjon 2025-04-10 02:15:46 +02:00
parent 073d0a4d8d
commit 66589ffaf6
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ConvertWorkTaskListener.kt
View File

@ -42,14 +42,6 @@ class ConvertWorkTaskListener: WorkTaskListener() {
return false return false
} }
val producedEvents = events.filter { it.eventType == produceEvent }
val shouldIHandleAndProduce = producedEvents.none { it.derivedFromEventId() == incomingEvent.eventId() }
val extractedEvent = events.findFirstEventOf<ExtractWorkPerformedEvent>()
if (extractedEvent?.isSuccessful() == true && shouldIHandleAndProduce) {
log.info { "Permitting handling of event: ${extractedEvent.data?.outputFile}" }
}
val startOperation = events.findFirstOf(Events.ProcessStarted)?.dataAs<StartEventData>() val startOperation = events.findFirstOf(Events.ProcessStarted)?.dataAs<StartEventData>()
if (startOperation == null) { if (startOperation == null) {
log.error { "Could not find 'ProcessStarted' event" } log.error { "Could not find 'ProcessStarted' event" }
@ -59,6 +51,15 @@ class ConvertWorkTaskListener: WorkTaskListener() {
if (incomingEvent.isOfEvent(Events.ProcessStarted)) { if (incomingEvent.isOfEvent(Events.ProcessStarted)) {
return startOperation.operations.isOnly(OperationEvents.CONVERT) return startOperation.operations.isOnly(OperationEvents.CONVERT)
} }
val producedEvents = events.filter { it.eventType == produceEvent }
val shouldIHandleAndProduce = producedEvents.none { it.derivedFromEventId() == incomingEvent.eventId() }
val extractedEvent = events.findFirstEventOf<ExtractWorkPerformedEvent>()
if (extractedEvent?.isSuccessful() == true && shouldIHandleAndProduce) {
log.info { "Permitting handling of event: ${extractedEvent.data?.outputFile}" }
}
return shouldIHandleAndProduce return shouldIHandleAndProduce
} }
override fun onEventsReceived(incomingEvent: ConsumableEvent<Event>, events: List<Event>) { override fun onEventsReceived(incomingEvent: ConsumableEvent<Event>, events: List<Event>) {