From d8837f8ad0c6da2849c30222c50d925b45d1a59f Mon Sep 17 00:00:00 2001
From: JarbasAI <33701864+JarbasAl@users.noreply.github.com>
Date: Wed, 16 Aug 2023 19:35:21 +0100
Subject: [PATCH] fix/gui upload (#17)

---
 ovos_messagebus/event_handler.py | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/ovos_messagebus/event_handler.py b/ovos_messagebus/event_handler.py
index ac028e4..b131103 100644
--- a/ovos_messagebus/event_handler.py
+++ b/ovos_messagebus/event_handler.py
@@ -19,6 +19,7 @@
 
 from ovos_utils.messagebus import FakeMessage as Message
 from ovos_utils.log import LOG
+from ovos_config import Configuration
 from pyee import EventEmitter
 from tornado.websocket import WebSocketHandler
 
@@ -33,13 +34,23 @@ def __init__(self, application, request, **kwargs):
     def on(self, event_name, handler):
         self.emitter.on(event_name, handler)
 
+    @property
+    def max_message_size(self) -> int:
+        return Configuration().get("websocket", {}).get("max_msg_size", 10) * 1024 * 1024
+
     def on_message(self, message):
-        LOG.debug(message)
+
         try:
             deserialized_message = Message.deserialize(message)
         except Exception:
             return
 
+        filter_ogs = ["gui.status.request", "gui.page.upload"]
+        if deserialized_message.msg_type not in filter_ogs:
+            LOG.debug(deserialized_message.msg_type +
+                      f' source: {deserialized_message.context.get("source", [])}' +
+                      f' destination: {deserialized_message.context.get("destination", [])}')
+
         try:
             self.emitter.emit(deserialized_message.msg_type,
                               deserialized_message)