From 6c5b3b88bc934a533305f03bf7e9a231b1c0254e Mon Sep 17 00:00:00 2001 From: Brage Date: Tue, 18 Jul 2023 14:46:08 +0200 Subject: [PATCH] Updated reader --- .../streamit/content/reader/streams/StreamsReader.kt | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt index 27a07cdc..9925933d 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt @@ -1,5 +1,6 @@ package no.iktdev.streamit.content.reader.streams +import com.google.gson.Gson import kotlinx.coroutines.runBlocking import mu.KotlinLogging import no.iktdev.streamit.content.common.CommonConfig @@ -33,11 +34,16 @@ class StreamsReader { if (data.value().status.statusType != StatusType.SUCCESS) { logger.info { "Ignoring event: ${data.key()} as status is not Success!" } return - } else if (data.value().data !is FileWatcher.FileResult) { - logger.info { "Ignoring event: ${data.key()} as values is not of expected type!" } + } else if (data.value().data !is String) { + logger.info { "Ignoring event: ${data.key()} as values is not of expected type!, ${data.value().data}" } + return + } + val dataValue = try { + Gson().fromJson(data.value().data as String, FileWatcher.FileResult::class.java) + } catch (e: Exception) { + logger.info { "Ignoring event: ${data.key()} as value failed to be converted" } return } - val dataValue = data.value().data as FileWatcher.FileResult logger.info { "Preparing Probe for ${dataValue.file}" } val output = mutableListOf() val d = Daemon(executable = ReaderEnv.ffprobe, parameters = listOf("-v", "quiet", "-print_format", "json", "-show_streams", dataValue.file), daemonInterface = object: