From 24db5444f2b7cde10d1d2d85cbe3aabe7f717210 Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Thu, 14 Mar 2024 01:29:29 +0100
Subject: [PATCH] Fix

---
 .../coordinator/tasks/event/ReadVideoFileStreams.kt            | 3 ++-
 .../tasks/event/ffmpeg/EncodeArgumentCreatorTask.kt            | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ReadVideoFileStreams.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ReadVideoFileStreams.kt
index 63109551..f221e805 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ReadVideoFileStreams.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ReadVideoFileStreams.kt
@@ -12,6 +12,7 @@ import no.iktdev.mediaprocessing.shared.common.runner.CodeToOutput
 import no.iktdev.mediaprocessing.shared.common.runner.getOutputUsing
 import no.iktdev.mediaprocessing.shared.kafka.core.KafkaEvents
 import no.iktdev.mediaprocessing.shared.kafka.dto.MessageDataWrapper
+import no.iktdev.mediaprocessing.shared.kafka.dto.SimpleMessageData
 import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.ProcessStarted
 import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.ReaderPerformed
 import no.iktdev.mediaprocessing.shared.kafka.dto.Status
@@ -53,7 +54,7 @@ class ReadVideoFileStreams(@Autowired override var coordinator: Coordinator) : T
             val jsoned = Gson().fromJson(joined, JsonObject::class.java)
             ReaderPerformed(Status.COMPLETED, file = started.file, output = jsoned)
         } else {
-            MessageDataWrapper(Status.ERROR, "File in data is not a file or does not exist")
+            SimpleMessageData(Status.ERROR, "File in data is not a file or does not exist")
         }
     }
 
diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/EncodeArgumentCreatorTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/EncodeArgumentCreatorTask.kt
index 9c3dfbb4..d248fea8 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/EncodeArgumentCreatorTask.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/EncodeArgumentCreatorTask.kt
@@ -10,6 +10,7 @@ import no.iktdev.mediaprocessing.shared.common.persistance.PersistentMessage
 import no.iktdev.mediaprocessing.shared.contract.ffmpeg.*
 import no.iktdev.mediaprocessing.shared.kafka.core.KafkaEvents
 import no.iktdev.mediaprocessing.shared.kafka.dto.MessageDataWrapper
+import no.iktdev.mediaprocessing.shared.kafka.dto.SimpleMessageData
 import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.*
 import no.iktdev.mediaprocessing.shared.kafka.dto.Status
 import org.springframework.beans.factory.annotation.Autowired
@@ -75,7 +76,7 @@ class EncodeArgumentCreatorTask(@Autowired override var coordinator: Coordinator
 
         val vaArgs = toFfmpegWorkerArguments(vArg, aArg)
         return if (vaArgs.isEmpty()) {
-            MessageDataWrapper(Status.ERROR, message = "Unable to produce arguments")
+            SimpleMessageData(Status.ERROR, message = "Unable to produce arguments")
         } else {
             FfmpegWorkerArgumentsCreated(
                 status = Status.COMPLETED,