fix: messages are None when no message is received

ref: N25B-265

src/control_backend/agents/bdi/behaviours/belief_setter.py

@@ -17,7 +17,9 @@ class BeliefSetterBehaviour(CyclicBehaviour):
 
     async def run(self):
         """Polls for messages and processes them."""
-        msg = await self.receive()
+        msg = await self.receive(timeout=1)
+        if not msg:
+            return
         self.agent.logger.debug(
             "Received message from %s with thread '%s' and body: %s",
             msg.sender,

src/control_backend/agents/bdi/behaviours/receive_llm_resp_behaviour.py

@@ -11,7 +11,9 @@ class ReceiveLLMResponseBehaviour(CyclicBehaviour):
     """
 
     async def run(self):
-        msg = await self.receive()
+        msg = await self.receive(timeout=1)
+        if not msg:
+            return
 
         sender = msg.sender.node
         match sender:

src/control_backend/agents/bdi/behaviours/text_belief_extractor.py

@@ -38,8 +38,8 @@ class BeliefFromText(CyclicBehaviour):
     beliefs = {"mood": ["X"], "car": ["Y"]}
 
     async def run(self):
-        msg = await self.receive()
-        if msg is None:
+        msg = await self.receive(timeout=1)
+        if not msg:
             return
 
         sender = msg.sender.node

src/control_backend/agents/belief_collector/behaviours/continuous_collect.py

@@ -14,7 +14,9 @@ class ContinuousBeliefCollector(CyclicBehaviour):
     """
 
     async def run(self):
-        msg = await self.receive()
+        msg = await self.receive(timeout=1)
+        if not msg:
+            return
         await self._process_message(msg)
 
     async def _process_message(self, msg: Message):

src/control_backend/agents/llm/llm.py

@@ -30,7 +30,9 @@ class LLMAgent(BaseAgent):
             Receives SPADE messages and processes only those originating from the
             configured BDI agent.
             """
-            msg = await self.receive()
+            msg = await self.receive(timeout=1)
+            if not msg:
+                return
 
             sender = msg.sender.node
             self.agent.logger.debug(

src/control_backend/agents/ri_command_agent.py

@@ -54,7 +54,9 @@ class RICommandAgent(BaseAgent):
         """Behaviour for sending commands received from other Python agents."""
 
         async def run(self):
-            message: spade.agent.Message = await self.receive(timeout=0.1)
+            message: spade.agent.Message = await self.receive(timeout=1)
+            if not message:
+                return
             if message and message.to == self.agent.jid:
                 try:
                     speech_command = SpeechCommand.model_validate_json(message.body)