Module agent 

Channel-based Agent handle - the public consumer surface.

Agent::spawn constructs a ForgeSdkBridge under the hood and spawns one background task: the command dispatcher, which drains mpsc::UnboundedReceiver<AgentCommand> and calls the matching inherent method on the bridge. The bridge’s AgentEvent receiver is handed back to consumers via take_events().

Direct-return accessors (config_dir, settings_documents, etc.) live on AgentHandle as method passthroughs to the bridge.

Re-exports

use std::collections::HashMap; 🔒

use std::path::Path; 🔒

use std::path::PathBuf; 🔒

use std::sync::Arc; 🔒

use forge_primitives::AgentCommand; 🔒

use forge_primitives::PermissionMode; 🔒

use parking_lot::Mutex; 🔒

use tokio::sync::mpsc; 🔒

use tracing::Instrument; 🔒

use crate::forge_sdk_bridge::ForgeSdkBridge; 🔒

Structs

Agent

Agent factory - wraps a private ForgeSdkBridge behind a channel API.

AgentHandle

Handle returned by Agent::spawn. Owns the channels + a thin passthrough to the bridge’s direct-return accessors.

Enums

AgentError

Errors surfaced from AgentHandle’s fire-and-forget command methods. The underlying claude subprocess work flows back asynchronously via the events stream - these are dispatch-time failures only.

Functions

decode_launch_settings 🔒

Decode launch settings off the dispatcher channel. Symmetric to the encode-side ?-propagation in AgentHandle::new_session.

dispatch 🔒

Dispatch one AgentCommand to the matching ForgeSdkBridge method. Internal - kept on anyhow because the bridge surface itself returns anyhow::Result and the dispatcher task only logs the error before continuing. The public AgentHandle surface above uses the typed AgentError.

dispatch_commands 🔒