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

Fix

Browse Source
This commit is contained in:
Brage 2024-03-14 21:55:13 +01:00
parent 2d263d009e
commit d88c75a8cc
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt
View File

@ -31,6 +31,9 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
private val logDir = ProcesserEnv.encodeLogDirectory private val logDir = ProcesserEnv.encodeLogDirectory
override val producesEvent = KafkaEvents.EVENT_WORK_ENCODE_PERFORMED override val producesEvent = KafkaEvents.EVENT_WORK_ENCODE_PERFORMED
override val requiredEvents: List<KafkaEvents> = listOf(
KafkaEvents.EVENT_WORK_ENCODE_CREATED
)
val scope = Coroutines.io() val scope = Coroutines.io()
private var runner: FfmpegWorker? = null private var runner: FfmpegWorker? = null
@ -40,9 +43,6 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
log.info { "Starting with id: $serviceId" } log.info { "Starting with id: $serviceId" }
} }
override val requiredEvents: List<KafkaEvents>
get() = listOf(KafkaEvents.EVENT_WORK_ENCODE_CREATED)
override fun prerequisitesRequired(events: List<PersistentProcessDataMessage>): List<() -> Boolean> { override fun prerequisitesRequired(events: List<PersistentProcessDataMessage>): List<() -> Boolean> {
return super.prerequisitesRequired(events) + listOf { return super.prerequisitesRequired(events) + listOf {
@ -51,7 +51,7 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
} }
override fun onProcessEvents(event: PersistentProcessDataMessage, events: List<PersistentProcessDataMessage>): MessageDataWrapper? { override fun onProcessEvents(event: PersistentProcessDataMessage, events: List<PersistentProcessDataMessage>): MessageDataWrapper? {
if (requiredEvents.contains(event.event)) { if (!requiredEvents.contains(event.event)) {
return null return null
} }
if (event.data !is FfmpegWorkRequestCreated) { if (event.data !is FfmpegWorkRequestCreated) {

2
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/ExtractService.kt
View File

@ -54,7 +54,7 @@ class ExtractService(@Autowired override var coordinator: Coordinator): TaskCrea
} }
override fun onProcessEvents(event: PersistentProcessDataMessage, events: List<PersistentProcessDataMessage>): MessageDataWrapper? { override fun onProcessEvents(event: PersistentProcessDataMessage, events: List<PersistentProcessDataMessage>): MessageDataWrapper? {
if (requiredEvents.contains(event.event)) { if (!requiredEvents.contains(event.event)) {
return null return null
} }
if (event.data !is FfmpegWorkRequestCreated) { if (event.data !is FfmpegWorkRequestCreated) {