Build a kind:30023 event with standard NIP-23 tags.

Build the single buffer appended to the rodio `Player` for one synthesised sentence. Every sentence chunk gets a short lead-in pad immediately before

Build a [`executor::TriggerContext`] from a [`buzz_core::StoredEvent`]. - `text` — event content (message body or reaction emoji character) - `author

Check that the session hasn't expired.

Detect responses that were intercepted by a captive portal or auth proxy. Returns `Some(msg)` when the response clearly did not come from the relay:

Build `-c` flag pairs that enable network access and allowlist the relay hostname in Codex's network sandbox. Codex sandboxes MCP subprocesses (inclu

Format a COUNT response (NIP-45).

Signal the audit worker to drain and wait up to `timeout` for it to finish.

Emit the current huddle state to the frontend via Tauri event. Acquires both locks (app_handle + huddle_state), clones a snapshot, releases both, the

Emit a relay-signed membership notification event stored globally (channel_id = None). kind:44100 = member added, kind:44101 = member removed. The p

Check that we're playing the expected role.

Check that we're in the expected state.

Extract value of a named tag.

Trim an oversized observer telemetry frame so its SERIALIZED form fits under `OBSERVER_MAX_PLAINTEXT_LEN`, instead of dropping the whole frame (silent

Get the channel_add_policy and agent_owner_pubkey for a user. Returns None if the pubkey is not in the users table. Returns Some((policy_str, owner_by

Fetches a single non-deleted event by its raw ID bytes. Returns `None` if the event does not exist or has been soft-deleted.

Returns the current presence status for `pubkey`, or `None` if not set or expired.

Read community-scoped sidecar JSON for a given sha256 (bare hash).

Helper: spawn a session with a fake MCP server exposing one regular tool plus an optional `_Stop` hook controlled by env vars.

Invalidate caches after a membership change (add/remove member). Drops the local moka entries AND fire-and-forget publishes the same drop to every ot

Check whether `actor_pubkey` is the agent owner of `target_pubkey`.

Returns `true` if the event is an author-only kind and the requester is NOT the author. Used as a per-event filter during historical delivery and fan-

Minimal SelfProfileCache fixture for policy helper tests.

A `community_id` known to exist in `communities` (FK target). Inserts a throwaway community row with a unique host and returns its id.

Helper: create a ZIP from name→data pairs.

Match a Nostr event against an ordered list of subscription rules. Rules are evaluated in order; the first rule whose conditions all pass wins. Retur

Merge pack defaults with per-persona values. Rules: - Persona field present (non-null) → use persona value - Persona field absent or null → use p

Compute the NIP-AP monotonic `created_at` for a write (`docs/nips/NIP-AP.md:117` step 3): `max(now, T + 1)` where `T` is the retained head's `created_

Construct the NIP-98 `u`-tag expected URL for a request bound to `tenant`. Conformance row 44 obligation: "NIP-98 `u` URL host must match `req.commun

Normalize the effort value for an OpenAI-shaped request body (Chat Completions or Responses). Two normalizations are applied in order: 1. **`max` →

Parse newline-delimited `KEY=VALUE` lines from a baked env blob. Blank lines are skipped. Each non-blank line must contain `=`; the key is everything

Numeric permission level for authorization comparisons. Higher = more privileged. Bot returns 0 (must use explicit grants). Use `role.permission_leve

Build a minimal persona event with the given d-tag and content.

Record a received event for dedup and `since` tracking. Returns `true` if the event is new (not a duplicate).

Like the (test-only) prefix-only `redact_secrets`, but also redacts every occurrence of each `extras` entry verbatim. Used to scrub user-supplied env