From d88c75a8cc065faf5400ae7f16d953cdd82d2b15 Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Thu, 14 Mar 2024 21:55:13 +0100
Subject: [PATCH] Fix

---
 .../mediaprocessing/processer/services/EncodeService.kt   | 8 ++++----
 .../mediaprocessing/processer/services/ExtractService.kt  | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt
index ac091ce4..8dd29dc7 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt
@@ -31,6 +31,9 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
     private val logDir = ProcesserEnv.encodeLogDirectory
 
     override val producesEvent = KafkaEvents.EVENT_WORK_ENCODE_PERFORMED
+    override val requiredEvents: List<KafkaEvents> = listOf(
+        KafkaEvents.EVENT_WORK_ENCODE_CREATED
+    )
 
     val scope = Coroutines.io()
     private var runner: FfmpegWorker? = null
@@ -40,9 +43,6 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
         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> {
         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? {
-        if (requiredEvents.contains(event.event)) {
+        if (!requiredEvents.contains(event.event)) {
             return null
         }
         if (event.data !is FfmpegWorkRequestCreated) {
diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/ExtractService.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/ExtractService.kt
index 854b7cd7..3173e357 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/ExtractService.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/ExtractService.kt
@@ -54,7 +54,7 @@ class ExtractService(@Autowired override var coordinator: Coordinator): TaskCrea
     }
 
     override fun onProcessEvents(event: PersistentProcessDataMessage, events: List<PersistentProcessDataMessage>): MessageDataWrapper? {
-        if (requiredEvents.contains(event.event)) {
+        if (!requiredEvents.contains(event.event)) {
             return null
         }
         if (event.data !is FfmpegWorkRequestCreated) {