Format a [`FlushBatch`] into the per-section prompt blocks for the agent. Produces a stable prompt with these sections (in order): 0. `[Base]` — base

Build the Anthropic thinking/effort request fields for the given model and effort level. API shape selection (per Anthropic extended-thinking support

* Cleanly tear down the connection without scheduling a reconnect. * Used during workspace switches to reset the singleton before the * new work

Run `git` with the Buzz credential helper and isolated config. Asserts the command succeeds; returns stdout.

Parse `<id>`, `<id>:<relay-url>`, or `<id>:<relay-url>:<pubkey>`. The relay-url segment may itself contain `:` (e.g. `wss://host:port`), so splitting

Idempotent. Safe to call from `connect()` completion.

Parse a `.persona.md` file into a [`PersonaConfig`]. Expects YAML frontmatter between `---` delimiters followed by a markdown body. The body becomes

Receives the next relay message, waiting up to `timeout_dur`.

Submit an event via the HTTP bridge and return (accepted, message).

Returns a minimal RelayEvent with the given tags.

Upsert a persona event into the retention store. Only replaces if the new event has a newer or equal `created_at` (NIP-33 semantics).

Send the result and disarm the guard. Uses `try_send` (sync) so there is no await boundary between marking `sent` and actually enqueueing — cancellati

Spawn the agent binary as a subprocess and connect to its stdio pipes. After spawning, call [`initialize`](Self::initialize) before any other method.

Locator scoped to the mention autocomplete dropdown inside the composer.

Creates a Buzz nest at the given `root` path. - Creates the root directory and all subdirectories. - Writes `AGENTS.md` only if it doesn't already ex

Build a test event with the given content and kind.

Build an abort event. Returns `None` if no peer is known yet (nothing to encrypt to), but still transitions to [`SessionState::Aborted`]. Rejects cal

Build a signed event for testing with the given kind, content, and tags.

* Build a Reminder fixture. `notBefore` and `status` are the only fields the * filters read besides `createdAt` (for done-group ordering).

Resolve `{{trigger.X}}` and `{{steps.ID.output.X}}` placeholders in a string. Supports filters: - `| truncate(N)` — truncate to N characters - `| tru

Builds and sends a text message event to `channel_id` using the given `kind`.

Parse a raw JSON WebSocket frame into a [`ClientMessage`].

Build a valid kind:30300 reminder event with the given tags.

Evaluate a boolean `if:` expression against the current execution context. Returns `true` if the step should run, `false` if it should be skipped. T

Open (or create) the retention database at the given path. Sets WAL journaling and a `busy_timeout` on every connection so the flush-loop connection

Build a minimal Config for testing without CLI parsing.

Validate a persona pack directory. Step 1: delegate all structural validation to `load_pack()`. If loading fails, the pack is broken — report the err

Decode a `nostrpair://` URI into a [`QrPayload`]. # Errors Returns [`PairingError::InvalidQr`] if: - The scheme is not `nostrpair` - The public key

Invalidate the session (and turn counter) for a specific prompt source.

* Query the relay via POST /query (pure Nostr HTTP bridge). * Returns an array of raw Nostr events matching the filters.

Emit a local observer event.

Look up a single retained event by its coordinate.