Updated code

CommonCode/src/main/java/no/iktdev/streamit/content/common/Naming.kt

@@ -5,18 +5,17 @@ class Naming(val fileName: String) {
         private set
 
     init {
-        cleanedFileName = fileName.apply {
-            removeBracketedText(this)
-            removeParenthesizedText(this)
-            removeResolutionAndTags(this)
-            removeInBetweenCharacters(this)
+        cleanedFileName = fileName
+            .let { removeBracketedText(it) }
+            .let { removeParenthesizedText(it) }
+            .let { removeResolutionAndTags(it) }
+            .let { removeInBetweenCharacters(it) }
+            .let { removeExtraWhiteSpace(it) }
 
-            removeExtraWhiteSpace(this)
-        }
     }
 
     fun guessDesiredFileName(): String {
-        val parts = fileName.split(" - ")
+        val parts = cleanedFileName.split(" - ")
         return when {
             parts.size == 2 && parts[1].matches(Regex("\\d{4}")) -> {
                 val title = parts[0]
@@ -36,7 +35,7 @@ class Naming(val fileName: String) {
                 "$title - $seasonEpisode - $episodeTitle"
             }
 
-            else -> fileName
+            else -> cleanedFileName
         }
     }
 

CommonCode/src/test/java/no/iktdev/streamit/content/common/NamingTest.kt

@@ -7,6 +7,15 @@ import org.junit.jupiter.params.ParameterizedTest
 import org.junit.jupiter.params.provider.MethodSource
 
 class NamingTest {
+
+    @Test
+    fun checkThatBracketsGetsRemoved() {
+        val input = "[AAA] Sir fancy - 13 [1080p HEVC][000000]"
+        val name = Naming(input)
+        assertThat(name.guessDesiredTitle()).doesNotContain("[")
+
+    }
+
 /*
     @ParameterizedTest
     @MethodSource("serieOnlyTest")

Reader/src/main/resources/application.properties

@@ -1,3 +1,3 @@
 spring.output.ansi.enabled=always
 logging.level.org.apache.kafka=WARN
-logging.level.root=DEBUG
+#logging.level.root=DEBUG

pyMetadata/app.py

@@ -76,13 +76,16 @@ class KafkaConsumerThread(threading.Thread):
                 if self.shutdown.is_set():
                     break
 
-                logger.info("Received message: key=%s, value=%s", message.key, message.value)
+                
 
                 # Sjekk om meldingen har målnøkkelen
                 if message.key == "request:metadata:obtain" or message.key == "event:reader:received-file":
+                    logger.info("Received message: key=%s, value=%s", message.key, message.value)
                     # Opprett en ny tråd for å håndtere meldingen
                     handler_thread = MessageHandlerThread(message)
                     handler_thread.start()
+                else:
+                    logger.info("Ignorert message: key=%s, value=%s", message.key, message.value)
 
         consumer.close()
         logger.info("Kafka Consumer stopped")