Find the first tag whose name matches `name` and return its first value. e.g. for tag `["name", "general"]` with `name="name"` returns `Some("general

Parse a v2 header from the leading 8 bytes of `bytes`. Returns the header and the remaining payload slice (the opaque Opus body the relay forwards). O

Store an object from a byte slice. Used for images, sidecars, and thumbnails. For large video files use [`put_file`] to avoid loading the entire blob

session_secret = 0xa1b2c3d4…

The value stamped into the `BUZZ_MANAGED_AGENT` env var of every agent we spawn, identifying *which* desktop instance owns it. We use the app's bundle

Ensure a user record exists for the given pubkey (upsert). Creates with minimal fields if not present; no-op if already exists.

Build a QueuedEvent with a specific `received_at` offset from now.

Merge persona env vars and per-agent env vars. Precedence: persona env first, then agent overrides, last-wins on key collision. Returns a `BTreeMap`

Build the full config surface for an agent, merging all four tiers. Pre-spawn (no session cache): tiers 2a (env vars / record) and 2b (config files).

Create a real channel via a signed kind:9007 event submitted to POST /events.

Walk a config JSON object and extract every key that is present, returning a flat `BTreeMap<String, String>` suitable for `RuntimeFileConfig::extra`.

Parse a UUID string into a `uuid::Uuid`. Returns `CliError::Usage` on failure. Note: `validate_uuid` (below) returns `()` for validation only; this f

Load, validate, merge, and resolve a pack directory. Returns a `ResolvedPack` with fully typed, ACP-ready output for each persona. All merge policy (

Bind a raw connection host to a [`TenantContext`], failing closed. This is the single row-zero entry point. It normalizes the host with the one share

Connect `agent_keys` to the relay with NIP-OA, establishing owner→agent in the DB. Returns the connected (authenticated) client for the agent.

Insert a community row, return its id.

Called when a successfully-decoded audio frame arrives from a remote peer. Mirrors the production logic in relay_api.rs: 1. Check tts_active — skip if

Rewrite a `.persona.md` file with updated frontmatter fields and, when safe, an updated body (system prompt). Returns the full rewritten file content,

Return `agent` to the pool via `result_tx`, clearing any steer receiver first. Every path that returns an `OwnedAgent` to the pool via `PromptResult`

* Cancel the active attempt. Safe to call without a running attempt. * Bumps the cancellation token so any in-flight async continuations * (incl

Channel-id Set view of the summary array — keeps legacy assertions terse.

Load the secret for `key`. `Ok(None)` when there is no entry; `Err` only when the backend errored in a way that is not "missing". On first launch aft

Build a minimal deps object with controllable preconnect behaviour.

Extract `@mention` names from message content using known member names. At each `@` preceded by whitespace or start-of-string, tries known names long

Fetches a channel record by ID.

Atomically insert an event and its optional thread metadata. `insert_event` and `insert_thread_metadata` calls could leave reply counters inconsisten

Build an event with specific tags for thread testing.

Build a minimal PersonaRecord with the fields that `rewrite_persona_md` reads.

The authenticated public key.

Compute a NIP-OA `auth` tag authorizing `agent_pubkey` under `conditions`. Signs the preimage with `owner_keys` using BIP-340 Schnorr. Returns a JSO