From 0f5ffe36943ced3c3751fb4ec7305a520b8495ee Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Thu, 7 Mar 2024 00:44:21 +0100
Subject: [PATCH] Logging

---
 .../main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt   | 2 ++
 .../mediaprocessing/processer/services/EncodeService.kt       | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
index 5029d643..b0dfb51c 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
@@ -1,5 +1,6 @@
 package no.iktdev.mediaprocessing.processer
 
+import com.google.gson.Gson
 import mu.KotlinLogging
 import no.iktdev.mediaprocessing.shared.common.persistance.PersistentProcessDataMessage
 import no.iktdev.mediaprocessing.shared.kafka.core.CoordinatorProducer
@@ -59,6 +60,7 @@ abstract class TaskCreator: TaskCreatorListener {
         if (prerequisitesRequired(events).all { it.invoke() }) {
             val result = onProcessEvents(event, events)
             if (result != null) {
+                log.info { "Event handled on ${this::class.simpleName} ${event.eventId} is: \nSOM\n${Gson().toJson(result)}\nEOM" }
                 onResult(result)
             }
         } else {
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 1e0fb449..5bb5f4fa 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
@@ -136,7 +136,7 @@ class EncodeService: TaskCreator() {
                     readbackIsSuccess = PersistentDataReader().isProcessEventDefinedAsConsumed(runner.referenceId, runner.eventId, serviceId)
                 }
                 producer.sendMessage(referenceId = runner.referenceId, event = producesEvent,
-                    ProcesserEncodeWorkPerformed(status = Status.COMPLETED, producedBy = serviceId, derivedFromEventId =  runner.eventId, outFile = runner.info.outFile)
+                    data = ProcesserEncodeWorkPerformed(status = Status.COMPLETED, producedBy = serviceId, derivedFromEventId =  runner.eventId, outFile = runner.info.outFile)
                 )
                 clearWorker()
             }
@@ -151,7 +151,7 @@ class EncodeService: TaskCreator() {
             }
             log.info { "Encode failed for ${runner.referenceId}" }
             producer.sendMessage(referenceId = runner.referenceId, event = producesEvent,
-                ProcesserEncodeWorkPerformed(status = Status.ERROR, message = errorMessage, producedBy = serviceId, derivedFromEventId =  runner.eventId)
+                data = ProcesserEncodeWorkPerformed(status = Status.ERROR, message = errorMessage, producedBy = serviceId, derivedFromEventId =  runner.eventId)
             )
             sendProgress(info = info, ended = true)
             clearWorker()