From 48d76fdc3126568c99154c84c121082e91127e17 Mon Sep 17 00:00:00 2001 From: Brage Date: Sun, 30 Jul 2023 23:14:41 +0200 Subject: [PATCH] Update --- .../streamit/content/reader/collector/VideoConsumer.kt | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt index fb139450..25834e8a 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt @@ -87,9 +87,14 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle val coverFile = metadata?.cover?.let { coverUrl -> runBlocking { try { - Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download() + val _file = Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download() + if (_file == null || !_file.exists()) { + logger.info { "Failed to download the file" } + } + _file } catch (e: Exception) { // No cover + e.printStackTrace() null } }