@@ -85,27 +85,33 @@ class AGUIAdapter(UIAdapter[RunAgentInput, Message, BaseEvent, AgentDepsT, Outpu
8585
8686 @classmethod
8787 def build_run_input (cls , body : bytes ) -> RunAgentInput :
88+ """Build an AG-UI run input object from the request body."""
8889 return RunAgentInput .model_validate_json (body )
8990
9091 def build_event_stream (self ) -> UIEventStream [RunAgentInput , BaseEvent , AgentDepsT , OutputDataT ]:
92+ """Build an AG-UI event stream transformer."""
9193 return AGUIEventStream (self .run_input , accept = self .accept )
9294
95+ @cached_property
96+ def messages (self ) -> list [ModelMessage ]:
97+ """Pydantic AI messages from the AG-UI run input."""
98+ return self .load_messages (self .run_input .messages )
99+
93100 @cached_property
94101 def toolset (self ) -> AbstractToolset [AgentDepsT ] | None :
102+ """Toolset representing frontend tools from the AG-UI run input."""
95103 if self .run_input .tools :
96104 return _AGUIFrontendToolset [AgentDepsT ](self .run_input .tools )
97105 return None
98106
99107 @cached_property
100108 def state (self ) -> dict [str , Any ] | None :
109+ """Frontend state from the AG-UI run input."""
101110 return self .run_input .state
102111
103- @cached_property
104- def messages (self ) -> list [ModelMessage ]:
105- return self .load_messages (self .run_input .messages )
106-
107112 @classmethod
108113 def load_messages (cls , messages : Sequence [Message ]) -> list [ModelMessage ]:
114+ """Transform AG-UI messages into Pydantic AI messages."""
109115 builder = MessagesBuilder ()
110116 tool_calls : dict [str , str ] = {} # Tool call ID to tool name mapping.
111117
0 commit comments