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

Minor changes

Browse Source
This commit is contained in:
bskjon 2025-02-23 20:39:28 +01:00
parent 8b8a073216
commit 5a50c986f4
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,6 +2,7 @@ package no.iktdev.mediaprocessing.coordinator.tasksV2.implementations
import com.google.gson.Gson import com.google.gson.Gson
import mu.KotlinLogging import mu.KotlinLogging
import no.iktdev.eventi.data.referenceId
import no.iktdev.mediaprocessing.coordinator.CoordinatorEventListener import no.iktdev.mediaprocessing.coordinator.CoordinatorEventListener
import no.iktdev.mediaprocessing.shared.common.contract.Events import no.iktdev.mediaprocessing.shared.common.contract.Events
import no.iktdev.mediaprocessing.shared.common.contract.ProcessType import no.iktdev.mediaprocessing.shared.common.contract.ProcessType
@ -20,8 +21,10 @@ abstract class WorkTaskListener: CoordinatorEventListener() {
val startEvent = events.find { it.eventType == Events.ProcessStarted }?.az<MediaProcessStartEvent>() val startEvent = events.find { it.eventType == Events.ProcessStarted }?.az<MediaProcessStartEvent>()
val startType = startEvent?.data?.type val startType = startEvent?.data?.type
if (startType == null) { if (startType == null) {
log.error { "Start event not found. Requiring permitt event" } log.error { "Start event not found on ${incomingEvent.referenceId()}. Requiring permit event" }
log.error { Gson().toJson(events) } try {
log.error { Gson().toJson(startEvent) }
} catch (e: Exception) {}
return false return false
} }
return if (incomingEvent.eventType == Events.WorkProceedPermitted) { return if (incomingEvent.eventType == Events.WorkProceedPermitted) {