SubagentManager

Add a serialized message to a subagent from stream events.

This method handles the raw serialized message data from SSE events. Uses MessageTupleManager for proper chunk concatenation, matching how the main stream handles messages.

Complete a subagent with a result.

Called when a tool message is received for the subagent.

Get all currently running subagents.

Look up a single subagent stream by its tool call ID.

Get all subagents as a Map.

Retrieve all subagent streams associated with a specific AI message.

Retrieve all subagent streams matching a given tool name / type.

Get the tool call ID for a given namespace ID. Returns the namespace ID itself if no mapping exists.

Check if any subagents are currently tracked.

Check if a tool call is a subagent invocation.

Mark a subagent as running and update its namespace.

Called when update events are received with a namespace indicating which subagent is streaming.

Mark a subagent as running using a namespace ID. Resolves the namespace ID to the actual tool call ID via the mapping.

Try to match a subgraph to a pending subagent by description. Creates a mapping from namespace ID to tool call ID if a match is found.

Uses a multi-pass matching strategy:

1. Exact description match
2. Description contains/partial match
3. Any unmapped pending subagent (fallback)

Process a tool message to complete a subagent.

Reconstruct subagent state from historical messages.

This method parses an array of messages (typically from thread history) to identify subagent executions and their results. It's used to restore subagent state after:

• Page refresh (when stream has already completed)
• Loading thread history
• Navigating between threads

The reconstruction process:

1. Find AI messages with tool calls matching subagent tool names
2. Find corresponding tool messages with results
3. Create SubagentStream entries with "complete" status

Note: Internal subagent messages (their streaming conversation) are not reconstructed since they are not persisted in the main thread state.

Register new subagent(s) from AI message tool calls.

Called when an AI message is received with tool calls. Creates pending subagent entries for each subagent tool call.

Update a reconstructed subagent's messages and values from its subgraph checkpoint state.

This is called after fetching the subgraph's history to restore the internal conversation that was lost on page refresh. Only updates if messages are currently empty (does not overwrite live streaming data).

Update subagent values from a values stream event.

Called when a values event is received from a subagent's namespace. This populates the subagent's state values, making them accessible via the values property.