Struct Harness 

pub struct Harness {
    pub handle: SessionHandle,
    pub provider: Arc<ScriptedProvider>,
    pub seen: Vec<String>,
    pub ask_reply: AskReply,
    pub steer_on_tool_start: Option<String>,
    pub snapshots: Arc<Mutex<Vec<String>>>,
    /* private fields */
}

Fields

handle: SessionHandle

provider: Arc<ScriptedProvider>

seen: Vec<String>

Debug strings of every event seen, in order.

ask_reply: AskReply

Answer for every Ask event (T1: defaults to Allow).

steer_on_tool_start: Option<String>

One-shot steer to send when the next ToolStart is observed.

snapshots: Arc<Mutex<Vec<String>>>

Labels of every shadow snapshot the engine requested, in order.

Implementations

impl Harness

pub fn dir(&self) -> &Path

The harness working directory (the engine’s cwd for subdir hints; also a scratch space for files the scripted tools touch).

pub fn keep_dir(&mut self, dir: TempDir)

Tie a fixture temp dir’s lifetime to the harness (it is removed when the harness drops, instead of being forgotten and leaked on disk).

impl Harness

pub fn new( scripts: Vec<Vec<Result<StreamEvent, ProviderError>>>, config: EngineConfig, ) -> Self

pub fn with_items( scripts: Vec<Vec<Result<StreamEvent, ProviderError>>>, config: EngineConfig, initial_items: Vec<Item>, ) -> Self

Construct a harness with a pre-seeded projection (resume scenarios).

pub fn with_hooks( scripts: Vec<Vec<Result<StreamEvent, ProviderError>>>, config: EngineConfig, hooks: Arc<dyn Hooks>, ) -> Self

Construct a harness with extension hooks (M5 scenarios).

pub fn with_registry( scripts: Vec<Vec<Result<StreamEvent, ProviderError>>>, config: EngineConfig, registry: Registry, ) -> Self

Construct a harness with a custom tool registry (concurrency probes, scripted tools).

pub fn with_rules( scripts: Vec<Vec<Result<StreamEvent, ProviderError>>>, config: EngineConfig, rules: Rules, ) -> Self

Construct a harness with custom permission rules (mode/deny/admin scenarios).

pub async fn prompt_and_wait(&mut self, text: &str) -> Outcome

Send a prompt and drain events until the turn finishes.

pub async fn wait_for_outcome(&mut self) -> Outcome

pub fn kinds(&self) -> Vec<String>

The persisted entry kinds, in order — the coarse golden signature.

pub fn transcript(&self) -> String

The full normalized transcript: ids/parents/timestamps zeroed so runs are byte-comparable.

pub fn entries(&self) -> Vec<Entry>

pub fn items(&self) -> Vec<Item>

Conversation items as persisted, in order.

pub fn tool_calls(&self) -> Vec<(String, Value)>

(tool name, input) for every persisted assistant tool_use, in log order — the trajectory a scenario produced.

pub fn assert_trajectory(&self, expected: &[&str], mode: TrajectoryMatch)

Assert on the tool-call sequence a scenario produced (not just entry kinds). Panics — with both sequences — when the mode’s relation fails.