Whether the pool is empty.

Push a new entry, evicting the oldest if at capacity.

Returns the plugin name.

Return the number of entries currently stored.

Number of currently cached connections.

Parse a plugin manifest from a TOML string.

Get a reusable connection to a peer, or establish a new one. If a cached connection exists and is not stale, it is returned. Otherwise, a new connect

Register or update a peer.

Record a failed access attempt for a track. Returns the updated health status.

Create a test HostContext with the given http_hosts permission.

Generate access + refresh token pair

Check if a URL's host is in the allowed list (supports glob patterns).

Insert searchable terms for a track into the local Bloom filter. Call this when a track is added locally or replicated from a peer.

Build the JSON payload for the listing server announcement.

Helper to create a mock Plugin object with sensible defaults.

Automatically attempt to repair a track that failed to play locally. Strategy: 1. Try the origin peer first (fast path). 2. If that fails, select the

SECURITY: Block requests to private/reserved IP addresses.

Validate all fields of a parsed manifest.

Validate a git URL for security. Only HTTPS URLs are allowed. File, HTTP, SSH, and git protocols are blocked to prevent SSRF and local file access.

Export the local Bloom filter as a compact serializable structure.

Look up a recording by title and artist name. Returns the best match if found with a score >= 80.

Mark a track as healthy (e.g., after initial successful fetch).

Remove a specific blob from the cache tracker (without deleting from store).

Get this node's unique identifier (public key).

Process a batch of tracks for health checking (lazy-fetch model). Uses the health manager for state tracking. The `check_fn` is called for each track

Get the peer registry.

Validate a JWT token and return claims

Get a specific peer by node_id.

Extract the plugin registry from type-erased application state. Returns `None` if the plugin system is not enabled (`PLUGIN_ENABLED=false`).

Hash a password using Argon2id

Send the announce payload to the listing server and return the response body. Returns `Ok((status_code, body))` — the caller decides what to do with

Get the health record for a specific track.

Import a peer's Bloom filter for search routing.

Mark a peer as offline.

Generate a waveform summary (peak amplitudes) for visualization. Returns a vector of normalized peak values (0.0..1.0) with `num_points` entries.

Helper: extract `Arc<P2pNode>` from type-erased AppState field.

Persist the listing heartbeat status so the admin panel can display it.

Create a test HostContext with fine-grained permissions.

Update the Media Session playback position state.

Get all known peers.

Dispatch an event to all subscribed plugins. Iterates over subscribed plugins in load order. Each plugin's WASM call runs without holding the registr

Return all entries (oldest first). Optionally filter by level and limit count.

Send a ping to a peer and wait for pong.

Process host function requests from a plugin's event handler response.

Record access and ensure a persistent tag exists in the blob store. This is the preferred method when a blob store is available. It performs the same

Select the best peer copy from a list of duplicate track sources. Returns `None` if no copies are available.

Send a message to a specific peer with retry and exponential backoff. Serializes the message once, then attempts to deliver it up to 3 times with dou

Register or update a peer with version information.

Validate a git URL for security. Only HTTPS URLs are allowed. File, HTTP, SSH, and git protocols are blocked to prevent SSRF and local file access.

Add a single track's tokens to the search index without a full rebuild. Called immediately when a new track is added to the local catalog so it becom

Read the domain to announce to the listing server. Priority: DB setting `listing_domain` → env var `SOUNDTIME_DOMAIN` → "localhost:8080".

Helper: get a user setting by key.

Get online peers only.

Parse "bytes=start-end" range header

Get the NodeIds of peers that might have results for a query. Returns peers whose Bloom filter matches the query terms.

Re-reference a previously dereferenced track. Called when a dereferenced track becomes available again (the peer came back online, the blob was re-an

Sanitize a log message from a plugin. Strips control characters (except newline/tab), truncates to max length.

Seed algorithm: track-based radio. Builds a mix from three phases, each fetching up to `count * 2` candidates then truncating to its quota before mer