Struct DaemonClient 

pub struct DaemonClient { /* private fields */ }

A client that connects to the Astrid daemon via WebSocket.

Unlike the CLI client, this does not auto-start the daemon. The daemon must already be running.

Implementations

impl DaemonClient

pub async fn connect_url(url: &str) -> Result<Self, TelegramBotError>

Connect to the daemon at the given URL.

pub async fn connect_discover() -> Result<Self, TelegramBotError>

Connect to the daemon, auto-discovering the port from ~/.astrid/daemon.port.

pub async fn connect(daemon_url: Option<&str>) -> Result<Self, TelegramBotError>

Connect using an explicit URL or fall back to auto-discovery.

pub async fn create_session( &self, workspace_path: Option<PathBuf>, ) -> Result<SessionInfo, TelegramBotError>

Create a new session.

pub async fn end_session( &self, session_id: &SessionId, ) -> Result<(), TelegramBotError>

End a session.

pub async fn send_input( &self, session_id: &SessionId, input: &str, ) -> Result<(), TelegramBotError>

Send user input to a session.

pub async fn subscribe_events( &self, session_id: &SessionId, ) -> Result<Subscription<DaemonEvent>, TelegramBotError>

Subscribe to session events.

pub async fn send_approval( &self, session_id: &SessionId, request_id: &str, decision: ApprovalDecision, ) -> Result<(), TelegramBotError>

Respond to an approval request.

pub async fn send_elicitation( &self, session_id: &SessionId, request_id: &str, response: ElicitationResponse, ) -> Result<(), TelegramBotError>

Respond to an elicitation request.

pub async fn cancel_turn( &self, session_id: &SessionId, ) -> Result<(), TelegramBotError>

Cancel the current turn.

pub async fn status(&self) -> Result<DaemonStatus, TelegramBotError>

Get daemon status.

pub async fn session_budget( &self, session_id: &SessionId, ) -> Result<BudgetInfo, TelegramBotError>

Get budget info for a session.