From e2c2d01de6e848feefdf7578c6487ba706c1e2cc Mon Sep 17 00:00:00 2001
From: Aljoscha Sander <aljoscha@flucto.tech>
Date: Tue, 27 Feb 2024 19:10:38 +0800
Subject: [PATCH] Fix/exception verbose output only (#91)

* made the print statement of when unpacking a message fails controlled by the verbose flag

* bump to 0.5.3
---
 heisskleber/__init__.py       | 2 +-
 heisskleber/udp/subscriber.py | 7 ++++---
 pyproject.toml                | 2 +-
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/heisskleber/__init__.py b/heisskleber/__init__.py
index 7d8c619..17380a8 100644
--- a/heisskleber/__init__.py
+++ b/heisskleber/__init__.py
@@ -16,4 +16,4 @@ __all__ = [
     "AsyncSink",
     "AsyncSource",
 ]
-__version__ = "0.5.2"
+__version__ = "0.5.3"
diff --git a/heisskleber/udp/subscriber.py b/heisskleber/udp/subscriber.py
index 0810882..5925224 100644
--- a/heisskleber/udp/subscriber.py
+++ b/heisskleber/udp/subscriber.py
@@ -103,10 +103,11 @@ class AsyncUdpSource(AsyncSource):
         data = await self.queue.get()
         try:
             payload = self.unpacker(data.decode(self.config.encoding, errors="ignore"))
-        except UnicodeDecodeError:
-            print(f"Could not decode data, is not {self.config.encoding}")
+        # except UnicodeDecodeError: # this won't be thrown anymore, as the error flag is set to ignore!
+        #     print(f"Could not decode data, is not {self.config.encoding}")
         except Exception:
-            print(f"Could not deserialize data: {data!r}")
+            if self.config.verbose:
+                print(f"Could not deserialize data: {data!r}")
         else:
             return (self.topic, payload)
 
diff --git a/pyproject.toml b/pyproject.toml
index bfac70d..21017d7 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "heisskleber"
-version = "0.5.2"
+version = "0.5.3"
 description = "Heisskleber"
 authors = ["Felix Weiler <felix@flucto.tech>"]
 license = "MIT"