Added more logging

Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertEnv.kt

@@ -1,4 +1,7 @@
 package no.iktdev.streamit.content.convert
 
 class ConvertEnv {
+    companion object {
+        val allowOverwrite = System.getenv("ALLOW_OVERWRITE").toBoolean() ?: false
+    }
 }

Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt

@@ -59,7 +59,8 @@ class RunnerCoordinator(private var maxConcurrentJobs: Int = 1) {
                 job.invokeOnCompletion {
                     logger.info { "OnCompletion invoked!\n\nWorkId: ${workItem.workId}-${workItem.type} \n\tCurrent active worksers: ${jobsInProgress.get()}" }
                     val workers = jobsInProgress.decrementAndGet()
-                    logger.info { "Worker Released: Available: ${workers}/${maxConcurrentJobs}" }
+                    logger.info { "Worker Released: $workers" }
+                    logger.info { "Available: ${workers}/${maxConcurrentJobs}" }
                     inProgressJobs.remove(job)
                 }
             }

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

@@ -83,8 +83,9 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
             } else null
         }
 
-
-        val coverFile = metadata?.cover?.let { coverUrl ->
+        val coverUrl = metadata?.cover
+        val coverFile: File? = if (coverUrl != null) {
+            logger.info { "Downloading Cover: $coverUrl" }
             runBlocking {
                 try {
                     val _file = Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download()
@@ -98,8 +99,12 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
                     null
                 }
             }
+        } else {
+            logger.info { "No cover url received" }
+            null
         }
 
+
         // Serie må alltid fullføres før catalog. dette i tilfelle catalog allerede eksisterer og den thrower slik at transaskjonen blir versertert!
 
         val status = try {