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

Update

Browse Source
This commit is contained in:
bskjon 2024-04-20 18:41:35 +02:00
parent 174e20e11f
commit 2fea47b841
3 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateEncodeWorkTask.kt
View File

@ -20,7 +20,13 @@ class CreateEncodeWorkTask(@Autowired override var coordinator: Coordinator) : C
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
log.info { "${event.referenceId} triggered by ${event.event}" }
return super.onProcessEvents(event, events)
val forwardEvent = if (event.event != KafkaEvents.EventMediaParameterEncodeCreated) {
events.findLast { it.event == KafkaEvents.EventMediaParameterEncodeCreated } ?: event
} else event
return super.onProcessEvents(forwardEvent, events)
}
}

6
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateExtractWorkTask.kt
View File

@ -21,6 +21,10 @@ class CreateExtractWorkTask(@Autowired override var coordinator: Coordinator) :
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
log.info { "${event.referenceId} triggered by ${event.event}" }
return super.onProcessEvents(event, events)
val forwardEvent = if (event.event != KafkaEvents.EventMediaParameterExtractCreated) {
events.findLast { it.event == KafkaEvents.EventMediaParameterExtractCreated } ?: event
} else event
return super.onProcessEvents(forwardEvent, events)
}
}

14
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/CreateProcesserWorkTask.kt
View File

@ -21,12 +21,14 @@ abstract class CreateProcesserWorkTask(override var coordinator: Coordinator) :
if (started == null) {
log.info { "${event.referenceId} couldn't find start event" }
return null
}
val proceed = events.find { it.event == KafkaEvents.EventMediaWorkProceedPermitted }
if (proceed == null && started.type == ProcessType.MANUAL) {
log.warn { "${event.referenceId} waiting for Proceed event due to Manual process" }
return null
} else if (started.type == ProcessType.MANUAL) {
val proceed = events.find { it.event == KafkaEvents.EventMediaWorkProceedPermitted }
if (proceed == null) {
log.warn { "${event.referenceId} waiting for Proceed event due to Manual process" }
return null
} else {
log.warn { "${event.referenceId} registered proceed permitted" }
}
}