From 204af0279b56be8034b2d7bfa4687ba8d582bef3 Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Sat, 23 Mar 2024 16:01:20 +0100
Subject: [PATCH] Suppresses known events

---
 apps/pyMetadata/app.py | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/apps/pyMetadata/app.py b/apps/pyMetadata/app.py
index 5d7860b2..e1fb1f54 100644
--- a/apps/pyMetadata/app.py
+++ b/apps/pyMetadata/app.py
@@ -2,7 +2,7 @@ import logging
 import signal
 import sys
 import os
-from typing import Optional
+from typing import List, Optional
 import uuid
 import threading
 import json
@@ -22,6 +22,22 @@ bootstrap_servers = os.environ.get("KAFKA_BOOTSTRAP_SERVER") or "127.0.0.1:9092"
 consumer_group = os.environ.get("KAFKA_CONSUMER_ID") or f"MetadataConsumer"
 kafka_topic = os.environ.get("KAFKA_TOPIC") or "mediaEvents"
 
+
+suppress_ignore: List[str] = [
+    "event:process:started",
+    "event::save",
+    "event:process:completed",
+    "event:work-encode:created",
+    "event:work-extract:created",
+    "event:work-convert:created",
+    "event:media-read-out-cover:performed",
+    "event:media-read-out-name-and-type:performed",
+    "event:media-parse-stream:performed",
+    "event:media-extract-parameter:created",
+    "event:media-encode-parameter:created",
+    "event:media-metadata-search:performed"
+]
+
 # Konfigurer logging
 logging.basicConfig(
     level=logging.INFO,
@@ -96,7 +112,8 @@ class KafkaConsumerThread(threading.Thread):
                     handler_thread = MessageHandlerThread(message)
                     handler_thread.start()
                 else:
-                    logger.info("Ignorert message: key=%s", message.key)
+                    if (message.key not in suppress_ignore):
+                        logger.info("Ignored message: key=%s", message.key)
             # Introduce a small sleep to reduce CPU usage
             time.sleep(1)
         if consumer is not None: