Struct AcpController 

pub struct AcpController {
    tab_id: String,
    block_id: String,
    inner: Arc<Mutex<AcpInner>>,
    broker: Option<Arc<Broker>>,
    event_bus: Option<Arc<EventBus>>,
    wstore: Option<Arc<WaveStore>>,
    filestore: Option<Arc<FileStore>>,
    health_monitor: Arc<HealthMonitor>,
    next_rpc_id: Arc<AtomicU64>,
}

AcpController manages an ACP-speaking agent process.

Fields

tab_id: String

block_id: String

inner: Arc<Mutex<AcpInner>>

broker: Option<Arc<Broker>>

event_bus: Option<Arc<EventBus>>

wstore: Option<Arc<WaveStore>>

filestore: Option<Arc<FileStore>>

health_monitor: Arc<HealthMonitor>

next_rpc_id: Arc<AtomicU64>

Monotonically increasing JSON-RPC request ID.

Implementations

impl AcpController

pub fn new( tab_id: String, block_id: String, broker: Option<Arc<Broker>>, event_bus: Option<Arc<EventBus>>, wstore: Option<Arc<WaveStore>>, filestore: Option<Arc<FileStore>>, ) -> Self

fn next_id(&self) -> u64

fn set_status(inner: &mut AcpInner, status: &str)

fn get_status_snapshot(&self) -> BlockControllerRuntimeStatus

fn publish_status(&self)

fn is_running(&self) -> bool

fn make_request(&self, method: &str, params: Value) -> String

Build a JSON-RPC 2.0 request.

fn make_notification(&self, method: &str, params: Value) -> String

Build a JSON-RPC 2.0 notification (no id field).

pub fn send_message( &self, message: String, cli_command: String, cli_args: Vec<String>, working_dir: String, env_vars: HashMap<String, String>, ) -> Result<(), String>

Send a user message via ACP session/prompt. If the process isn’t spawned yet, spawns it first (the first prompt is deferred until the session is established — see pending_prompt).

fn spawn_process( &self, cli_command: String, cli_args: Vec<String>, working_dir: String, env_vars: HashMap<String, String>, ) -> Result<(), String>

Spawn the ACP agent process and perform the initialize handshake.

Trait Implementations

impl Controller for AcpController

fn start( &self, block_meta: HashMap<String, Value>, _rt_opts: Option<Value>, _force: bool, ) -> Result<(), String>

Start the controller. May spawn background tasks. force restarts even if already running.

fn stop(&self, _graceful: bool, _new_status: &str) -> Result<(), String>

Stop the controller. graceful waits for process to exit; new_status is the target state.

fn get_runtime_status(&self) -> BlockControllerRuntimeStatus

Get the current runtime status.

fn send_input( &self, input: BlockInputUnion, _seq: Option<u64>, ) -> Result<(), String>

Send input (terminal data, signal, or resize) to the controller. seq is the per-TermViewModel monotonic counter; None means fire-and-forget (no ordering).

fn controller_type(&self) -> &str

Get the controller type (e.g., “shell”, “cmd”).

fn block_id(&self) -> &str

Get the block ID.

fn as_any(&self) -> &dyn Any

Downcast support for concrete controller types.