Push an event into the queue for its channel. In [`DedupMode::Drop`], events for any currently in-flight channel are silently discarded (debug-logged

Path to the bare repository — pass this to `upload-pack`/`info-refs`.

Return the canonical wire-format string for this scope (e.g. `"messages:read"`).

True if no peers remain in the room.

Insert `id`. Returns `true` if it was new (not a duplicate).

Format an OK message acknowledging an EVENT submission.

True when NetEq's buffer has no packets queued and the next `get_audio` call would emit expand/silence. Used by `huddle::playout` as part of the idle-

The community every scoped operation under this request must use.

Sends a data message to this connection's outbound channel. On a full buffer, increments the backpressure counter. The first `grace_limit` occurrence

Return the cached owner pubkey.

Retrieve an object's bytes.

Connect a WebSocket client to the relay.

The underlying UUID, for DB binds and Redis key construction.

A short stable string identifying the action kind, for fixture declarations and error messages.

CLI/env wire string (matches `buzz-acp`'s `--respond-to`).

Closes the WebSocket connection gracefully.

Delete the secret for `key`. A missing entry is not an error.

GET an object without digest verification. Prefer `get_verified` for pack/manifest reads — that is what enforces A1 detectability. This raw `get` exi

Remove an ID (used to un-deduplicate a dropped event so it can be replayed after reconnect).

Sends a signed event to the relay and waits for the OK response.

Parse a v2 header from the leading 8 bytes of `bytes`. Returns `(header, remainder)` so callers can pass the remainder straight to the Opus decoder.

Get the keypair.

Canonical string representation (matches DB enum and Nostr tags).

Parse a tag slice, mapping errors to `SdkError::InvalidTag`.

Sends a REQ message to open a subscription with the given `sub_id` and `filters`.

Try to flush the next batch. Returns `None` if all non-in-flight, non-throttled queues are empty. Otherwise picks the channel with the oldest pending

Store `value` for `key`. Reports `Err` on availability failures — callers decide whether to fall back to file storage.

Collects all events for `sub_id` until EOSE is received, waiting up to `timeout_dur`.

Build a QueuedEvent for the given channel.

Builds the relay's NIP-11 information document. `relay_self` is the relay's own signing pubkey (hex), advertised as the NIP-11 `self` field. NIP-11 d

Send a JSON value as a text frame.

Execute a one-shot query via the relay's HTTP bridge (`POST /query`). Filters are serialized as a JSON array. The request is authenticated with a NIP

Drop all listeners. Called on workspace teardown to match the legacy * pattern used for the reconnect listener set.

Validate 64-character lowercase hex string (event_id, pubkey).

Encode `self` into 8 bytes, network byte order. Suitable for direct concatenation onto an Opus payload.

Start a relay on a random port, return the WebSocket URL.

Receive the next text frame and parse it as JSON. Panics if no message arrives within 2 seconds.

Build an `EventBuilder` from the events module, sign it with the user's keys, and POST the signed event to `/events` with NIP-98 auth.

Emit a semantic event to the local observer feed, if enabled.

Sign an event builder, injecting the NIP-OA auth tag if configured. All event creation should go through this method to ensure consistent auth tag in

Mark the prompt for `channel_id` as complete. Removes the channel from `in_flight_channels` and `in_flight_deadlines`. If the channel was NOT requeu

Execute a one-shot query via the HTTP bridge. `filter` is a Nostr filter object (will be wrapped in an array). Returns the raw JSON response (array of

Execute a community-scoped FTS query.

Submit a signed Nostr event via POST /events.

Open a new JSONL tracer writing to `path`. Truncates any existing file at that path so a fresh test run starts clean.

Parse a YAML workflow definition, validate it, and return the canonical JSON. Returns `(WorkflowDef, canonical_json)` on success.

Lock the huddle state mutex, converting a poisoned-lock error to a String. Convenience wrapper — replaces 15+ instances of `state.huddle_state.lock()

Standard error envelope.