feat/ggwave

hivemind_core/protocol.py

@@ -403,9 +403,11 @@ def handle_handshake_message(self, message: HiveMessage,
 
     def handle_bus_message(self, message: HiveMessage,
                            client: HiveMindClientConnection):
-        self.handle_inject_mycroft_msg(message.payload, client)
+        msg = message.payload
+        print(6666, client.sess.serialize())
+        self.handle_inject_mycroft_msg(msg, client)
         if self.mycroft_bus_callback:
-            self.mycroft_bus_callback(message.payload)
+            self.mycroft_bus_callback(msg)
 
     def handle_broadcast_message(self, message: HiveMessage, client: HiveMindClientConnection):
         """
@@ -498,8 +500,6 @@ def handle_inject_mycroft_msg(self, message: Message, client: HiveMindClientConn
             LOG.warning(client.peer + " sent an unauthorized bus message")
             return
 
-        # ensure client specific session data is injected in query to ovos
-        message.context["session"] = client.sess.serialize()
         if message.msg_type == "speak":
             message.context["destination"] = ["audio"]
         elif message.context.get("destination") is None:
@@ -510,7 +510,7 @@ def handle_inject_mycroft_msg(self, message: Message, client: HiveMindClientConn
         message.context["peer"] = message.context["source"] = client.peer
         message.context["source"] = client.peer
 
-        # validate slave session
+        # ensure client specific session data is injected in query to ovos
         message = self.update_slave_session(message, client)
 
         bus = self.get_bus(client)

hivemind_core/service.py

@@ -230,6 +230,7 @@ def run(self):
         self.presence.start()
         if self.ggwave is not None:
             self.ggwave.start()
+            LOG.info("listening for ggwave audio handshakes")
 
         self.status.set_ready()