Using existing if found

Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt

@@ -85,7 +85,9 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
         }
 
         val coverUrl = metadata?.cover
-        val coverFile: File? = if (coverUrl != null) {
+        val currentCover = getExistingCover(outDir)
+        val coverFile = if (currentCover == null || !currentCover.exists()) {
+            if (coverUrl != null) {
                 logger.info { "Downloading Cover: $coverUrl" }
                 runBlocking {
                     try {
@@ -104,6 +106,9 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
                 logger.info { "No cover url received" }
                 null
             }
+        } else currentCover
+
+
 
 
         // Serie må alltid fullføres før catalog. dette i tilfelle catalog allerede eksisterer og den thrower slik at transaskjonen blir versertert!
@@ -162,4 +167,17 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
         return SerieQuery(data.episodeTitle, data.episode, data.season, data.title,  baseName)
     }
 
+    val validCoverFormat = listOf(
+        "png",
+        "jpg",
+        "jpeg",
+        "webp",
+        "bmp",
+        "tiff"
+    )
+    fun getExistingCover(contentDir: File): File? {
+        val possibleCovers = contentDir.walkTopDown().filter { it.isFile && validCoverFormat.contains(it.extension)}
+        return possibleCovers.firstOrNull()
+    }
+
 }