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

Simplified canStart

Browse Source
This commit is contained in:
bskjon 2025-02-23 23:30:07 +01:00
parent 62e0453ce9
commit ad02f40085
1 changed files with 4 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/implementations/WorkTaskListener.kt
View File

@ -19,34 +19,14 @@ abstract class WorkTaskListener: CoordinatorEventListener() {
}
fun canStart(incomingEvent: Event, events: List<Event>): Boolean {
assert(events.isNotEmpty()) {
"Events are nor present"
val autoStart = events.find { it.eventType == Events.ProcessStarted }?.az<MediaProcessStartEvent>()?.data
if (autoStart == null) {
log.error { "Start event not found. Requiring permit event" }
}
val startEvent = events.find { it.eventType == Events.ProcessStarted }?.az<MediaProcessStartEvent>()
if (startEvent == null) {
log.error { "Start event not found on ${incomingEvent.referenceId()}." }
try {
log.error { WGson.toJson(startEvent) }
log.warn { "EvenTypes:\n" + events.map { it.eventType }.map { "\n\t$it" } }
log.warn { "Events provided:\n ${WGson.toJson(events)}" }
} catch (e: Exception) {}
return false
}
val startType = startEvent?.data?.type
if (startEvent == null) {
log.error { "Start type on ${incomingEvent.referenceId()}. Requiring permit event" }
try {
log.error { WGson.toJson(startEvent) }
} catch (e: Exception) {}
return false
}
return if (incomingEvent.eventType == Events.WorkProceedPermitted) {
return true
} else {
if (startType == ProcessType.MANUAL) {
if (autoStart == null || autoStart.type == ProcessType.MANUAL) {
log.warn { "${incomingEvent.metadata.referenceId} waiting for Proceed event due to Manual process" }
false
} else true