Fix MQTT JSON decoding

fbchat-dev · Jan 8, 2020 · 4714be5 · 4714be5
1 parent cb7f4a7
commit 4714be5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fbchat/_mqtt.py b/fbchat/_mqtt.py
@@ -74,8 +74,8 @@ def connect(cls, state, on_message, chat_on, foreground):
     def _on_message_handler(self, client, userdata, message):
         # Parse payload JSON
         try:
-            j = _util.parse_json(message.payload)
-        except _exception.FBchatFacebookError:
+            j = _util.parse_json(message.payload.decode("utf-8"))
+        except (_exception.FBchatFacebookError, UnicodeDecodeError):
             log.exception("Failed parsing MQTT data on %s as JSON", message.topic)
             return