fix: add warning if websocket connection isnt open (#83)

* fix: add warning if websocket connection isnt open

* fix: add warning if websocket connection isnt open

* 📝 Add docstrings to `fix/ws_open_chck` (#84)

* 📝 Add docstrings to `fix/ws_open_chck`

Docstrings generation was requested by @JarbasAl.

* #83 (comment)

The following files were modified:

* `hivemind_bus_client/client.py`

* Update client.py

---------

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
Co-authored-by: JarbasAI <33701864+JarbasAl@users.noreply.github.com>

* chore: avoid infinite recursion

---------

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

Author: JarbasAl

hivemind_bus_client/client.py

@@ -233,11 +233,23 @@ def on_close(self, *args):
         self.crypto_key = None
         super().on_close(*args)
 
-    def wait_for_handshake(self, timeout=5):
+    def wait_for_handshake(self, timeout=5, max_retries=15):
+        """
+        Waits for the HiveMind handshake to complete; if the handshake is not set and the websocket connection is open, starts the handshake, otherwise waits for the websocket to open and retries.
+
+        Parameters:
+            timeout (float): Number of seconds to wait for each handshake or connection attempt before retrying.
+        """
         self.handshake_event.wait(timeout=timeout)
         if not self.handshake_event.is_set():
-            self.protocol.start_handshake()
-            self.wait_for_handshake()
+            if max_retries <= 0:
+                raise RuntimeError("timed out waiting for handshake")
+            if self.connected_event.is_set():
+                self.protocol.start_handshake()
+            else:
+                LOG.warning("Can't start handshake because websocket connection is not yet open...")
+                self.connected_event.wait(timeout=timeout)
+            self.wait_for_handshake(timeout, max_retries - 1)
 
     @staticmethod
     def build_url(key, host='127.0.0.1', port=5678,
@@ -353,12 +365,12 @@ def emit(self, message: Union[MycroftMessage, HiveMessage],
             message = HiveMessage(msg_type=HiveMessageType.BUS,
                                   payload=message)
         if not self.connected_event.is_set():
-            LOG.warning("hivemind connection not ready")
+            LOG.warning("hivemind connection not ready!")
             if not self.connected_event.wait(10):
                 if not self.started_running:
                     raise ValueError('You must execute run_forever() '
                                      'before emitting messages')
-                self.connected_event.wait()
+                raise RuntimeError(f"Can not send messages before opening the websocket connection. Failed to emit : {message.serialize()}")
 
         try:
             # auto inject context for proper routing, this is confusing for