Struct Runtime 

pub struct Runtime {
    pub watcher_exit_path: Option<PathBuf>,
    /* private fields */
}

The core runtime — manages API communication, tool execution, authentication, and streaming for all SynapsCLI binaries (chat, chatui, server, agent, watcher).

Fields

watcher_exit_path: Option<PathBuf>

Path for watcher_exit tool to write handoff state (agent mode only)

Implementations

impl Runtime

pub async fn new() -> Result<Self>

pub fn set_system_prompt(&mut self, prompt: String)

pub fn system_prompt(&self) -> Option<&str>

pub fn set_model(&mut self, model: String)

pub fn set_tools(&mut self, tools: ToolRegistry)

pub fn subagent_registry(&self) -> &Arc<Mutex<SubagentRegistry>>

pub fn event_queue(&self) -> &Arc<EventQueue>

pub fn hook_bus(&self) -> &Arc<HookBus>

Get a shared reference to the extension hook bus.

pub fn tools_shared(&self) -> Arc<RwLock<ToolRegistry>>

Get a shared reference to the tool registry (for MCP lazy loading).

pub fn model(&self) -> &str

pub fn http_client(&self) -> &Client

pub fn set_thinking_budget(&mut self, budget: u32)

pub fn set_compaction_model(&mut self, model: Option<String>)

pub fn set_context_window(&mut self, window: Option<u64>)

pub fn compaction_model(&self) -> &str

Effective context window for the current model — user override if set, otherwise the model’s native window from models::context_window_for_model.

pub fn context_window(&self) -> u64

pub fn apply_config(&mut self, config: &SynapsConfig)

Apply a parsed config file to this runtime (model, thinking budget, etc.)

pub fn thinking_budget(&self) -> u32

pub fn max_tool_output(&self) -> usize

pub fn bash_timeout(&self) -> u64

pub fn bash_max_timeout(&self) -> u64

pub fn subagent_timeout(&self) -> u64

pub fn api_retries(&self) -> u32

pub fn set_max_tool_output(&mut self, v: usize)

pub fn set_bash_timeout(&mut self, v: u64)

pub fn set_bash_max_timeout(&mut self, v: u64)

pub fn set_subagent_timeout(&mut self, v: u64)

pub fn set_api_retries(&mut self, v: u32)

pub fn thinking_level(&self) -> &str

pub async fn refresh_if_needed(&self) -> Result<()>

Check if the OAuth token is expired and refresh it if needed.

pub async fn compact_call(&self, messages: Vec<Value>) -> Result<String>

Make a simple non-streaming API call for compaction (no tools).

Uses a dedicated summarization system prompt (not the user’s), omits all tools, and returns the raw text response. Caller supplies the full message array including the serialized conversation.

pub async fn run_single(&self, prompt: &str) -> Result<String>

Run a single prompt synchronously (non-streaming). Handles tool execution internally, looping until the model produces a final text response.

pub async fn run_stream( &self, prompt: String, cancel: CancellationToken, ) -> Pin<Box<dyn Stream<Item = StreamEvent> + Send>>

Run a prompt as a cancellable stream of StreamEvents. Convenience wrapper around [run_stream_with_messages] for single-turn usage.

pub async fn run_stream_with_messages( &self, messages: Vec<Value>, cancel: CancellationToken, steering_rx: Option<UnboundedReceiver<String>>, secret_prompt: Option<SecretPromptHandle>, ) -> Pin<Box<dyn Stream<Item = StreamEvent> + Send>>

Run a multi-turn conversation as a cancellable stream of StreamEvents. This is the main entry point for chat UIs and agents. Handles tool execution, API retries, and dynamic tool registration (MCP) internally.

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.