Convert a kind:30620 workflow definition event into a [`WorkflowWire`].

Serialize `value` as a single NDJSON line and flush to the agent's stdin. Bounded by a 30-second write timeout. If the agent stops reading stdin (e.g

Convert kind:10100 agent profile events to the agent discovery format. Returns a JSON array of `{pubkey, name, ...}` objects parsed from each event's

Stable string representation used in hash computation and DB storage.

Build a `SamplesBuffer` of length `n` samples filled with `value`.

Assemble a build-time env map from optional raw bake-in values. Separated from `baked_build_env` so the assembly logic can be exercised in unit tests

Build a global text note (kind:1, NIP-01). `reply_to_event_id`: adds a single `["e", <id>, "", "reply"]` tag. This is intentionally simpler than the

Build a kind:30175 event from a `PersonaRecord`. Returns an unsigned `EventBuilder` — the caller signs and submits.

Build a kind:30315 event with a d-tag and content.

Cache key construction matches the auth module: sha256(discovery|client|scopes).

Owner + a known sibling, none of them on the explicit allowlist.

Map a UUID channel id into a [`ChannelLabel`]. Channels are not secret — they appear in event `h` tags — so this is a direct wrap.

Validate an exact-length hex string (event ids), returning it lowercased.

Removes the presence entry for `pubkey`. Call on clean disconnect.

Build a `channel_id → membership` map from a batch of kind:39002 events. Events without a `d` tag are skipped; member dedupe is delegated to [`nostr_c

Connect to relay and authenticate via NIP-42. `auth_tag` is an optional NIP-OA owner attestation included in the AUTH event for relay membership dele

Create a fresh **private** channel owned by `agent_keys`, return the channel UUID string.

Pure decoder: given the relay's JSON array, decide whether we have a readable core, confirmed absence, or an ambiguous unreadable-state. - Empty arra

Deduplicate `PersonaRecord`s that share a `(source_team, source_team_persona_slug)` pair — the result of repeated imports before the matching predicat

Returns the discovery-failure fallback catalog for a Databricks provider. This is the list of models advertised by `session/new` when `discover_datab

Serialize and NIP-44 encrypt an observer payload for `recipient`.

Extract the first `d` tag value from an event.

Fetch channel members, optionally filtered by role (e.g., "bot" for agents).

Find the team whose `team_persona_key` equals `source_team`. This matches the same key that `sync_team_from_dir` uses, covering both modern teams (whe

Fetch one channel window: top-level rows (depth = 0, missing metadata, or broadcast depth-1 replies) in `(created_at DESC, id ASC)` keyset order, with

GET the pointer object, returning its ETag and bytes *from the same response* — atomic snapshot. Returns `Ok(None)` if the pointer does not exist (fi

Fetch all replies under a root event, ordered chronologically. - `depth_limit` -- if `Some(n)`, only returns replies at depth <= n. - `cursor` -- key

GET an object and verify its bytes hash to `expected_digest` (hex SHA-256). This is the read-side enforcement of A1 — any deviation from the content-

Construct the repo-root NIP-98 `u` URL expected for a git HTTP request. The host is always the server-resolved tenant host. `config_relay_url` only c

Return true if the event has a tag with the given name (any value).

Lookup with HUMAN as a human and AGENT_A / AGENT_B as agents.

An inbound persona as `persona_from_event` would produce it: id = d-tag, slug = Some(d-tag), empty env_vars, source_team None.

Send the `initialize` request and return the agent's response result value. Must be called exactly once, before any other ACP method. The caller may

Extract p-tag mentions from an event and insert into the `event_mentions` table. Called after event insertion. Failures are logged but do not block e

Install the global metrics recorder and spawn the Prometheus HTTP exporter. `build()` returns the recorder + exporter future and internally spawns th

Install a per-turn steer request channel for goose-native non-cancelling mid-turn delivery. Called by the dispatch path immediately before [`session_

Interval prefilter decision + cold-start anchor seed. See the [`WorkflowEngine::interval_prefilter_should_fire`] wrapper for the liveness rationale. F

Elevated roles that only existing owners/admins may grant.