From f2758e5c4942620cdc7ccc06966438ccb194511d Mon Sep 17 00:00:00 2001
From: dullfig <dan.u@grmcompany.com>
Date: Wed, 7 Jan 2026 16:39:55 -0800
Subject: [PATCH] fixing docs

---
 agentserver/message_bus/message_state.py  | 29 +++++++++++++++++++++++
 agentserver/message_bus/steps/__init__.py |  0
 2 files changed, 29 insertions(+)
 create mode 100644 agentserver/message_bus/message_state.py
 create mode 100644 agentserver/message_bus/steps/__init__.py

diff --git a/agentserver/message_bus/message_state.py b/agentserver/message_bus/message_state.py
new file mode 100644
index 0000000..15a96bb
--- /dev/null
+++ b/agentserver/message_bus/message_state.py
@@ -0,0 +1,29 @@
+from dataclasses import dataclass, field
+from lxml.etree import Element
+from typing import Any
+
+@dataclass
+class HandlerMetadata:
+    """Trustworthy context passed to every handler."""
+    thread_id: str
+    from_id: str
+    own_name: str | None = None          # Only for agent: true listeners
+    is_self_call: bool = False           # Convenience flag
+
+
+@dataclass
+class MessageState:
+    """Universal intermediate representation flowing through all pipelines."""
+    raw_bytes: bytes | None = None
+    envelope_tree: Element | None = None
+    payload_tree: Element | None = None
+    payload: Any | None = None           # Deserialized @xmlify instance
+
+    thread_id: str | None = None
+    from_id: str | None = None
+
+    target_listeners: list['Listener'] | None = None   # Forward reference
+
+    error: str | None = None
+
+    metadata: dict[str, Any] = field(default_factory=dict)  # Extension point
\ No newline at end of file
diff --git a/agentserver/message_bus/steps/__init__.py b/agentserver/message_bus/steps/__init__.py
new file mode 100644
index 0000000..e69de29