From a395efdbd9a36ed36d4e10b1faefe32f6e829af8 Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 31 Jul 2023 01:47:29 +0200 Subject: [PATCH] Adjustment to error logging --- .../no/iktdev/streamit/content/convert/ConvertRunner.kt | 5 +++++ .../streamit/content/convert/kafka/SubtitleConsumer.kt | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertRunner.kt b/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertRunner.kt index f0aea48a..d88604dc 100644 --- a/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertRunner.kt +++ b/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertRunner.kt @@ -2,6 +2,7 @@ package no.iktdev.streamit.content.convert import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.withContext +import mu.KotlinLogging import no.iktdev.library.subtitle.Syncro import no.iktdev.library.subtitle.export.Export import no.iktdev.library.subtitle.reader.BaseReader @@ -11,6 +12,9 @@ import no.iktdev.streamit.content.common.dto.reader.work.ConvertWork import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork import java.io.File +private val logger = KotlinLogging.logger {} + + class ConvertRunner(val referenceId: String, val listener: IConvertListener) { private fun getReade(inputFile: File): BaseReader? { @@ -22,6 +26,7 @@ class ConvertRunner(val referenceId: String, val listener: IConvertListener) { val reader = getReade(inFile) val dialogs = reader?.read() if (dialogs.isNullOrEmpty()) { + logger.error { "$referenceId ${subtitleInfo.inputFile}: Dialogs read from file is null or empty!" } withContext(Dispatchers.Default) { listener.onError(referenceId, subtitleInfo, "Dialogs read from file is null or empty!") } diff --git a/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/kafka/SubtitleConsumer.kt b/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/kafka/SubtitleConsumer.kt index 8196470c..f914adb1 100644 --- a/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/kafka/SubtitleConsumer.kt +++ b/Convert/src/main/kotlin/no/iktdev/streamit/content/convert/kafka/SubtitleConsumer.kt @@ -59,7 +59,7 @@ class SubtitleConsumer: DefaultKafkaReader("convertHandlerSubtitle"), IConvertLi } override fun onError(referenceId: String, info: SubtitleInfo, message: String) { - produceMessage(KafkaEvents.EVENT_CONVERTER_SUBTITLE_FILE_ENDED, Message(referenceId = referenceId, Status(statusType = StatusType.ERROR)), null) + produceMessage(KafkaEvents.EVENT_CONVERTER_SUBTITLE_FILE_ENDED, Message(referenceId = referenceId, Status(statusType = StatusType.ERROR, message = message)), null) } override fun onEnded(referenceId: String, info: SubtitleInfo, work: ConvertWork) {