Struct CodingHarness 

pub struct CodingHarness { /* private fields */ }

Harness wiring config, tools, system prompt, hooks, and Agent.

Implementations

impl CodingHarness

pub fn builder( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, ) -> CodingHarnessBuilder

Start building a harness for SDK/embedder use.

pub fn new( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, ) -> Self

Create a new harness with the given provider, model, config, and workspace root.

pub fn new_with_selection( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, tool_selection: ToolSelection, ) -> Self

Create a new harness with an explicit tool selection.

pub fn new_with_tool_config( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, tool_config: ToolRuntimeConfig, ) -> Self

Create a new harness with already resolved tool runtime config.

pub fn new_with_hooks( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, hooks: Box<dyn AgentHooks>, user_system_prompt: Option<String>, initial_messages: Vec<AgentMessage>, tool_selection: ToolSelection, ) -> Self

Create a new harness with custom hooks.

pub fn new_with_hooks_and_resume( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, hooks: Box<dyn AgentHooks>, user_system_prompt: Option<String>, initial_messages: Vec<AgentMessage>, resume: Option<ResumeInfo>, tool_selection: ToolSelection, ) -> Self

Create a new harness, optionally adopting an existing session (resume).

pub fn new_with_hooks_and_resume_tool_config( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, hooks: Box<dyn AgentHooks>, user_system_prompt: Option<String>, initial_messages: Vec<AgentMessage>, resume: Option<ResumeInfo>, tool_config: ToolRuntimeConfig, ) -> Self

Create a new harness, optionally adopting an existing session (resume), with already resolved tool runtime config.

pub fn new_with_global_config_dir( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, hooks: Box<dyn AgentHooks>, user_system_prompt: Option<String>, initial_messages: Vec<AgentMessage>, resume: Option<ResumeInfo>, tool_selection: ToolSelection, global_config_dir: Option<PathBuf>, ) -> Self

Create a new harness with an explicit global config directory override.

When global_config_dir is None, uses the platform default from crate::config::user_config_dir. Pass Some(path) in tests to isolate global context file discovery from the real user config dir.

pub fn new_with_global_config_dir_tool_config( provider: Box<dyn Provider>, model: String, config: OpiConfig, workspace_root: PathBuf, hooks: Box<dyn AgentHooks>, user_system_prompt: Option<String>, initial_messages: Vec<AgentMessage>, resume: Option<ResumeInfo>, tool_config: ToolRuntimeConfig, global_config_dir: Option<PathBuf>, ) -> Self

Create a new harness with an explicit global config directory override and already resolved tool runtime config.

pub fn add_tool(&mut self, tool: Box<dyn Tool>)

Add an extra tool to the harness (for testing with mock tools).

pub fn queue_images(&mut self, images: Vec<InputContent>)

Queue images to be injected into the next prompt.

pub fn take_pending_images(&mut self) -> Vec<InputContent>

Take and clear queued images.

pub fn model_picker_items(&self) -> Vec<SelectItem>

Return model picker items from the active provider.

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

Change the model used by subsequent prompts.

pub fn set_model_validated(&mut self, model: String) -> Result<&str, String>

Validate and change the model used by subsequent prompts.

pub fn set_thinking_level( &mut self, level: &str, ) -> Result<RuntimeThinkingState, String>

Change the thinking level used by subsequent provider requests.

pub fn resume_session_id(&mut self, session_id: &str) -> Result<usize, String>

Resume an existing session by ID into this harness.

pub fn branch_picker_items(&self) -> Result<Vec<SelectItem>, String>

Return branch picker items for the currently active session.

pub fn resume_session_branch_tip( &mut self, tip_id: &str, ) -> Result<usize, String>

Switch the current session to the branch ending at tip_id.

pub async fn prompt( &mut self, text: &str, ) -> Result<Vec<AgentMessage>, AgentError>

Send a user prompt and run the agent loop.

pub async fn prompt_with_content( &mut self, content: Vec<InputContent>, ) -> Result<Vec<AgentMessage>, AgentError>

Send a user message with arbitrary content (text + images) and run the agent loop.

pub async fn continue_( &mut self, text: &str, ) -> Result<Vec<AgentMessage>, AgentError>

Continue the conversation with an additional message.

pub fn model(&self) -> &str

Return the current model name.

pub fn steer(&self, message: String)

Queue a steering message for the next provider call.

pub fn follow_up(&self, message: String)

Queue a follow-up message for when the agent would otherwise stop.

pub fn subscribe(&mut self, callback: Box<dyn Fn(&AgentEvent) + Send + Sync>)

Register an event subscriber.

pub fn system_prompt(&self) -> &str

Return the assembled system prompt (for testing).

pub fn resource_metadata(&self) -> &DiscoveredResourceMetadata

Return read-only discovered resource metadata.

pub fn resource_metadata_json(&self) -> Value

Return resource metadata in the compact RPC/session-info shape.

pub fn resolve_theme(&self, name: &str) -> Result<Theme, ThemeDiscoveryError>

Resolve a theme using discovered themes first, then built-ins.

pub fn config(&self) -> &OpiConfig

Return a reference to the config.

pub fn cancel(&self)

Cancel the running operation.

pub fn cancel_token(&self) -> CancellationToken

Return a clonable cancellation token for external cancellation.

pub fn control_handle(&self) -> AgentControl

Return a clonable control handle for an active agent turn.

pub fn reset_cancel_if_cancelled(&mut self)

Reset cancellation state before cloning a control handle for a new turn.

pub fn session(&self) -> Option<&SessionCoordinator>

Return the session coordinator, if active.

pub fn compact( &mut self, reason: CompactionReason, ) -> Result<Option<CompactionResult>, String>

Execute manual compaction on the session, if one is active. Returns the compaction result, or None if compaction produced no output or no session exists.