HTTP server init, run and stop basic test

Author: VigneshVSV

.github/workflows/test-dev.yml

@@ -88,7 +88,7 @@ jobs:
       - name: Run unit tests and generate coverage report
         run: |
           pip install coverage
-          coverage run -m unittest discover -s tests -p 'test_*.py'
+          coverage run -m unittest
           coverage report -m
 
     

hololinked/core/zmq/brokers.py

@@ -780,6 +780,7 @@ def __init__(self, *,
         self.socket: zmq.Socket | zmq.asyncio.Socket
         self.poller: zmq.Poller | zmq.asyncio.Poller 
         self._poll_timeout = kwargs.get('poll_timeout', 1000)  # default to 1000 ms
+        self._stop = False # in general, stop any loop with this variaböe
 
     @property
     def poll_timeout(self) -> int:
@@ -849,6 +850,13 @@ def handled_default_message_types(self, response_message: RequestMessage) -> boo
         if response_message.type == HANDSHAKE:
             return True
         return False
+    
+
+    def stop(self) -> None:
+        """
+        stop the client. 
+        """
+        self._stop = True
 
 
 
@@ -955,7 +963,8 @@ def recv_response(self, message_id: bytes) -> ResponseMessage:
             if True, any exceptions raised during execution inside ``Thing`` instance will be raised on the client.
             See docs of ``raise_local_exception()`` for info on exception 
         """
-        while True:
+        self._stop = False
+        while not self._stop:
             if message_id in self._response_cache:
                 return self._response_cache.pop(message_id)
             sockets = self.poller.poll(self.poll_timeout)
@@ -1027,8 +1036,9 @@ def handshake(self, timeout: typing.Union[float, int] = 60000) -> None:
         """
         hanshake with server before sending first message
         """
+        self._stop = False
         start_time = time.time_ns()
-        while True:
+        while not self._stop:
             if timeout is not None and (time.time_ns() - start_time)/1e6 > timeout:
                 raise ConnectionError(f"Unable to contact server '{self.server_id}' from client '{self.id}'")
             self.socket.send_multipart(RequestMessage.craft_with_message_type(self.id, self.server_id, HANDSHAKE).byte_array)
@@ -1123,11 +1133,12 @@ async def _handshake(self, timeout: float | int | None = 60000) -> None:
         """
         hanshake with server before sending first message
         """
+        self._stop = False
         if self._monitor_socket is not None and self._monitor_socket in self.poller:
             self.poller.unregister(self._monitor_socket)
         self._handshake_event.clear()
         start_time = time.time_ns()    
-        while True:
+        while not self._stop:
             if timeout is not None and (time.time_ns() - start_time)/1e6 > timeout:
                 raise ConnectionError(f"Unable to contact server '{self.server_id}' from client '{self.id}'")
             await self.socket.send_multipart(RequestMessage.craft_with_message_type(self.id, self.server_id, HANDSHAKE).byte_array)
@@ -1237,7 +1248,8 @@ async def async_recv_response(self, message_id: str) -> typing.List[ResponseMess
         deserialize_response: bool
             deserializes the data field of the message
         """
-        while True:
+        self._stop = False
+        while not self._stop:
             if message_id in self._response_cache:
                 return self._response_cache.pop(message_id)
             sockets = await self.poller.poll(self._poll_timeout)
@@ -1700,6 +1712,8 @@ def stop_polling(self):
         stop polling for replies from server
         """
         self.stop_poll = True
+        for client in self.pool.values():
+            client.stop()
 
     async def async_execute_in_all(self, 
                                 objekt: str,