Merge pull request #54 from JarbasHiveMind/release-0.2.1a1

Release 0.2.1a1

Author: JarbasAl

CHANGELOG.md

@@ -1,12 +1,12 @@
 # Changelog
 
-## [0.2.0a1](https://github.com/JarbasHiveMind/hivemind-websocket-client/tree/0.2.0a1) (2025-01-03)
+## [0.2.1a1](https://github.com/JarbasHiveMind/hivemind-websocket-client/tree/0.2.1a1) (2025-01-03)
 
-[Full Changelog](https://github.com/JarbasHiveMind/hivemind-websocket-client/compare/0.1.6...0.2.0a1)
+[Full Changelog](https://github.com/JarbasHiveMind/hivemind-websocket-client/compare/0.2.0...0.2.1a1)
 
 **Merged pull requests:**
 
-- feat:add chacha20 cipher + z85 encoding [\#50](https://github.com/JarbasHiveMind/hivemind-websocket-client/pull/50) ([JarbasAl](https://github.com/JarbasAl))
+- fix:binarization\_protocol [\#53](https://github.com/JarbasHiveMind/hivemind-websocket-client/pull/53) ([JarbasAl](https://github.com/JarbasAl))
 
 
 

hivemind_bus_client/client.py

@@ -294,8 +294,17 @@ def on_message(self, *args):
         if (isinstance(message, HiveMessage) and message.msg_type == HiveMessageType.BINARY):
             self._handle_binary(message)
             return
-        self.emitter.emit('message', message)  # raw message
-        self._handle_hive_protocol(HiveMessage(**message))
+
+        if isinstance(message, HiveMessage):
+            self.emitter.emit('message', message.serialize())  # raw message
+            self._handle_hive_protocol(message)
+        elif isinstance(message, str):
+            self.emitter.emit('message', message)  # raw message
+            self._handle_hive_protocol(HiveMessage(**json.loads(message)))
+        else:
+            assert isinstance(message, dict)
+            self.emitter.emit('message', json.dumps(message, ensure_ascii=False))  # raw message
+            self._handle_hive_protocol(HiveMessage(**message))
 
     def _handle_binary(self, message: HiveMessage):
         assert message.msg_type == HiveMessageType.BINARY

hivemind_bus_client/version.py

@@ -1,6 +1,6 @@
 # START_VERSION_BLOCK
 VERSION_MAJOR = 0
 VERSION_MINOR = 2
-VERSION_BUILD = 0
-VERSION_ALPHA = 0
+VERSION_BUILD = 1
+VERSION_ALPHA = 1
 # END_VERSION_BLOCK