Struct DaemonHost 

pub struct DaemonHost { /* private fields */ }

Server-specific host for the daemon. Owns event channels and session state.

Trait Implementations

impl Clone for DaemonHost

fn clone(&self) -> DaemonHost

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Host for DaemonHost

async fn dispatch_ask_user( &self, args: &str, conversation_id: Option<u64>, ) -> Result<String, String>

Handle ask_user — block until user replies.

async fn dispatch_delegate( &self, args: &str, _agent: &str, ) -> Result<String, String>

Handle delegate — spawn sub-agent tasks.

fn conversation_cwd(&self, conversation_id: u64) -> Option<PathBuf>

Resolve the working directory for a conversation. Returns None to fall back to the runtime’s base cwd.

fn on_agent_event(&self, agent: &str, conversation_id: u64, event: &AgentEvent)

Called when an agent event occurs. The daemon uses this to broadcast protobuf events to console subscribers. Default: no-op.

async fn reply_to_ask(&self, session: u64, content: String) -> Result<bool>

Deliver a user reply to a pending ask_user tool call. Returns true if a pending ask was found and resolved.

async fn set_conversation_cwd(&self, conversation: u64, cwd: PathBuf)

Set the working directory override for a conversation.

async fn clear_conversation_state(&self, conversation: u64)

Clear all per-conversation state (pending asks, CWD overrides).

fn subscribe_events(&self) -> Option<Receiver<AgentEventMsg>>

Subscribe to agent events. Returns None if event broadcasting is not supported by this host.

fn dispatch_custom_tool( &self, name: &str, _args: &str, _agent: &str, _conversation_id: Option<u64>, ) -> impl Future<Output = Result<String, String>> + Send

Handle a tool call not matched by the built-in dispatch table. Downstream hosts override this to inject private tools.