Send one event. Terminal events (`Done`/`Error`) also resolve the final-result oneshot.

Lookup by name or alias. `name` is the bare command without `/`.

Render the whole feed to width-wrapped `ratatui` lines, ready to scroll/draw.

Register a harness-level lifecycle listener. Returns an unsubscriber closure. Listener panics are caught — see [`HarnessEvent`] for the isolation con

Accept an incoming [`Trigger`] from a notification adapter. Evaluates it against the runtime's dedup + cycle bookkeeping, persists a `SessionTreeEntry

Start a new prompt. Appends a user `AgentMessage`, runs the loop, awaits completion.

Inspect the current agent state. The lock guards against concurrent loop mutations.

Render one event to any `Write`. Stdout in production, a `Vec<u8>` in tests so we can inspect the exact ANSI-bearing byte stream the agent emits durin

Mint a new session file under `root` for the given `cwd`. The file is named `<uuidv7>.jsonl` to keep directory listings chronologically sorted.

Helper: wait until a predicate over the captured event log returns Some(value) or the deadline elapses. Polls every 20ms.

Prompt with retry. Same signature as `AgentHarness::prompt` but loops on retryable LLM errors with exponential backoff. If a `fallback_model` is confi

Base directory: `${PIE_DIR:-$HOME/.pie}`.

Emit a [`HarnessEvent`] to a snapshot of the listener registry, isolating each listener with `catch_unwind` so a single panicking listener cannot pois

Split `/cmd arg1 "arg with spaces"` into `(cmd, [arg1, arg with spaces])`. Returns `None` if `input` doesn't start with `/`. Quoting is minimal: balan

Decide whether a fresh trigger should be admitted, deduped, or cycle-suppressed. Pure (modulo wall-clock pruning); does NOT advance the trigger state

Open an existing session file. Path may be absolute or relative to `root`.

Strip ANSI SGR escapes so assertions can read the textual content directly. Operates on chars to preserve multi-byte UTF-8 glyphs (like the `⚙` gear).

Truncate to at most `max_chars` characters (not bytes — never splits a multi-byte glyph), appending an ellipsis when shortened.

Append a fresh entry. Deduplicates with the immediately-preceding entry so spamming the same prompt twice doesn't litter the file. Caps total entries

Cron jobs are session-scoped by default, parallel to dynamic trigger sidecars.

Push a user prompt block. Called directly by the loop on submit / on resume replay.

Load skills from one or more directories. Missing directories are silently skipped (they emit no diagnostic). Other filesystem failures DO emit diagno

Dynamic trigger rules are session-scoped sidecars next to the jsonl transcript.

Build a harness whose `reload_skills_from_disk` rescans a single test directory. Returns the harness handle, the cell to plug into the tool, and the t

Helper: build a hook over an mpsc, run it on a task, return the sender side so the test can push notifications and a receiver to observe sunk triggers