feat: intitial commit, containing comments for myself

ref: N25B-401

.logging_config.yaml

@@ -1,5 +1,7 @@
 version: 1
 
+# Maak nieuwe (obvervation action)
+# tussen 20-30
 custom_levels:
   OBSERVATION: 25
   ACTION: 26
@@ -19,6 +21,8 @@ formatters:
     format: "{name} {levelname} {levelno} {message} {created} {relativeCreated}"
     style: "{"
 
+# Maak class = logging.fileHandler
+# 
 handlers:
   console:
     class: logging.StreamHandler
@@ -35,6 +39,8 @@ root:
   level: WARN
   handlers: [console]
 
+# Maak research logger, laagste level (21)
+# Handler: UI Handler
 loggers:
   control_backend:
     level: LLM

src/control_backend/core/agent_system.py

@@ -60,9 +60,6 @@ class BaseAgent(ABC):
         self._tasks: set[asyncio.Task] = set()
         self._running = False
 
-        self._internal_pub_socket: None | azmq.Socket = None
-        self._internal_sub_socket: None | azmq.Socket = None
-
         # Register immediately
         AgentDirectory.register(name, self)
 
@@ -133,22 +130,16 @@ class BaseAgent(ABC):
 
         :param message: The message to send.
         """
-        message.sender = self.name
+        target = AgentDirectory.get(message.to)
-        to = message.to
+        if target:
-        receivers = [to] if isinstance(to, str) else to
+            await target.inbox.put(message)
-
+            self.logger.debug(f"Sent message {message.body} to {message.to} via regular inbox.")
-        for receiver in receivers:
+        else:
-            target = AgentDirectory.get(receiver)
+            # Apparently target agent is on a different process, send via ZMQ
-
+            topic = f"internal/{message.to}".encode()
-            if target:
+            body = message.model_dump_json().encode()
-                await target.inbox.put(message)
+            await self._internal_pub_socket.send_multipart([topic, body])
-                self.logger.debug(f"Sent message {message.body} to {message.to} via regular inbox.")
+            self.logger.debug(f"Sent message {message.body} to {message.to} via ZMQ.")
-            else:
-                # Apparently target agent is on a different process, send via ZMQ
-                topic = f"internal/{receiver}".encode()
-                body = message.model_dump_json().encode()
-                await self._internal_pub_socket.send_multipart([topic, body])
-                self.logger.debug(f"Sent message {message.body} to {message.to} via ZMQ.")
 
     async def _process_inbox(self):
         """

src/control_backend/schemas/internal_message.py

@@ -1,5 +1,3 @@
-from collections.abc import Iterable
-
 from pydantic import BaseModel
 
 
@@ -7,13 +5,13 @@ class InternalMessage(BaseModel):
     """
     Standard message envelope for communication between agents within the Control Backend.
 
-    :ivar to: The name(s) of the destination agent(s).
+    :ivar to: The name of the destination agent.
     :ivar sender: The name of the sending agent.
     :ivar body: The string payload (often a JSON-serialized model).
     :ivar thread: An optional thread identifier/topic to categorize the message (e.g., 'beliefs').
     """
 
-    to: str | Iterable[str]
+    to: str
     sender: str
     body: str
     thread: str | None = None

test/unit/core/test_agent_system.py

@@ -99,75 +99,12 @@ async def test_send_to_local_agent(monkeypatch):
     # Patch inbox.put
     target.inbox.put = AsyncMock()
 
-    message = InternalMessage(to=target.name, sender=sender.name, body="hello")
+    message = InternalMessage(to="receiver", sender="sender", body="hello")
 
     await sender.send(message)
 
     target.inbox.put.assert_awaited_once_with(message)
-
+    sender.logger.debug.assert_called_once()
-
-@pytest.mark.asyncio
-async def test_send_to_zmq_agent(monkeypatch):
-    sender = DummyAgent("sender")
-    target = "remote_receiver"
-
-    # Fake logger
-    sender.logger = MagicMock()
-
-    # Fake zmq
-    sender._internal_pub_socket = AsyncMock()
-
-    message = InternalMessage(to=target, sender=sender.name, body="hello")
-
-    await sender.send(message)
-
-    zmq_calls = sender._internal_pub_socket.send_multipart.call_args[0][0]
-    assert zmq_calls[0] == f"internal/{target}".encode()
-
-
-@pytest.mark.asyncio
-async def test_send_to_multiple_local_agents(monkeypatch):
-    sender = DummyAgent("sender")
-    target1 = DummyAgent("receiver1")
-    target2 = DummyAgent("receiver2")
-
-    # Fake logger
-    sender.logger = MagicMock()
-
-    # Patch inbox.put
-    target1.inbox.put = AsyncMock()
-    target2.inbox.put = AsyncMock()
-
-    message = InternalMessage(to=[target1.name, target2.name], sender=sender.name, body="hello")
-
-    await sender.send(message)
-
-    target1.inbox.put.assert_awaited_once_with(message)
-    target2.inbox.put.assert_awaited_once_with(message)
-
-
-@pytest.mark.asyncio
-async def test_send_to_multiple_agents(monkeypatch):
-    sender = DummyAgent("sender")
-    target1 = DummyAgent("receiver1")
-    target2 = "remote_receiver"
-
-    # Fake logger
-    sender.logger = MagicMock()
-
-    # Fake zmq
-    sender._internal_pub_socket = AsyncMock()
-
-    # Patch inbox.put
-    target1.inbox.put = AsyncMock()
-
-    message = InternalMessage(to=[target1.name, target2], sender=sender.name, body="hello")
-
-    await sender.send(message)
-
-    target1.inbox.put.assert_awaited_once_with(message)
-    zmq_calls = sender._internal_pub_socket.send_multipart.call_args[0][0]
-    assert zmq_calls[0] == f"internal/{target2}".encode()
 
 
 @pytest.mark.asyncio