Validate a WASM binary file. Checks: 1. File size within limits 2. Magic bytes (0x00 0x61 0x73 0x6D = "\0asm") 3. Import analysis: only allowed names

Announce all locally-uploaded tracks to a specific peer using paginated queries. Called when a new peer connects to sync existing catalogs. Sends one

Clear all entries.

Extract metadata from an audio file using lofty

Read the listing URL from instance settings, falling back to env var then default.

Read a single instance_setting by key.

Remove a cached connection (e.g., after a stream error). Call this when `open_bi()` or a write fails so the next attempt will establish a fresh conne

Record an access to a blob, adding it to the cache if not already tracked. This should be called every time a blob is read from or written to the sto

Upsert an instance_setting key/value pair.

Format a vector as pgvector-compatible string: `[0.1,0.2,...]`

Verify a password against an Argon2id hash

Acquire a permit from the recovery semaphore. Used to limit concurrent recovery operations for backpressure. # Panics Panics if the semaphore is clos

Build the `api_sig` required by the Last.fm API protocol. # Security MD5 is used here because the Last.fm API *requires* it for request signing. This

Return the build version string. Uses `CARGO_PKG_VERSION` (from Cargo.toml) as the base. If `SOUNDTIME_BUILD_NUMBER` is set at compile time (via CI),

─── Helper: create a minimal WAV file ───────────────────────────

Decrypt a stored Last.fm session key.

Emit a custom event. Returns true if the event name is valid. The actual dispatch is handled by the registry, not here.

Retrieve a track's data from the local blob store by hash.

Check if a peer is blocked, either by its iroh NodeId string or readable name. We reuse the `blocked_domains` table — the `domain` column stores eithe

Parse a pgvector text representation `[0.1,0.2,...]` into a Vec<f32>.

Count of known peers.

Rebuild the local Bloom filter from a full list of tracks. Called at startup to populate the index from the database.

Record a successful recovery/access for a track, resetting its failure count.

Remove a peer from the registry.

Helper: upsert a user setting.

Try to acquire a recovery permit without blocking. Returns `None` if all permits are in use (system is at capacity).

Discover peers by exchanging peer lists with a known peer (Peer Exchange / PEX). Sends our known peers, receives theirs, and connects to any new ones.

Encode year into 4-dimensional era representation.

Encode duration into 4-dimensional profile.

Encrypt a Last.fm session key for storage using AES-256-GCM. The encryption key is derived from `jwt_secret` via HKDF-SHA256. Returns base64-encoded

Enrich a single track with MusicBrainz metadata. Returns a `MetadataResult` describing what was found/updated.

Connect to a remote peer and fetch a track by its content hash.

Read the listing token from instance settings.

Check if a track has been dereferenced (exhausted all retries).

Check if the `listing_public` setting is enabled. Defaults to `false` — listing is opt-in.

Check if a file extension is supported

Load a WASM plugin from disk into a sandboxed environment. Reads the WASM binary, configures memory limits (in 64 KB pages), and enables fuel-based e

Look up the currently active theme from instance_settings + themes table.

Mark the search index as dirty, requiring a full rebuild. Bloom filters don't support removal, so when a track is deleted this flag is set. The next

Create a new sync task tracker.

Normalize a node ID for comparison with the `instance_domain` column. `instance_domain` stores values like `"p2p://node_id_here"`. This helper ensure

Internal: process a single track announcement — de-duplicate, auto-fetch blob, create artist/album/track/remote_track records in the local database. U

Publish cover art data to the local blob store. Returns the content hash (BLAKE3) that identifies the blob.

Remove the injected theme stylesheet.

Remove a record (e.g., when a track is deleted from the catalog).

Update a plugin's status in the database.

Set a metadata field on a track. Requires `write_tracks` permission.

Unload a plugin, removing it from memory and subscriptions.

Validate that a path is safe (no `..` components, not absolute).

Attempt to recover a single track from a specific peer. Returns the recovered data bytes on success.

Call a WASM function by name with raw byte input/output. Sets a fresh fuel budget before each call. Errors are classified into fuel exhaustion, memor

Check if a track's data exists locally in the blob store. This is the fast path — no network IO needed.

Check if a remote instance is reachable by hitting its NodeInfo endpoint.

Clone a git repository to the given directory.

Clone a git repository to the given directory.

Get the current configuration.

Convert an AIFF file to FLAC using ffmpeg, preserving all metadata. Returns the path to the newly created FLAC file. The original AIFF file is remove

Recursively copy only files with allowed extensions from src to dest. Returns total bytes copied.

Cosine distance (1 - cosine_similarity) for testing.

Returns the base directory for cover art storage. Uses `metadata_storage_path` if set, otherwise falls back to `audio_storage_path`.

Get the database connection.

Helper: delete all Last.fm settings for a user.

Delete the listing token from instance settings (used when the server rejects it).

Calculate total size of a directory tree in bytes.

Perform a distributed search across the P2P network. Uses Bloom filters to route the query only to peers likely to have results. Queries up to 10 matc

Evict least-recently-used blobs until total size is within the limit. Blobs are evicted by removing their tags from the `FsStore`, which makes them e

Fetch trending tracks from PostgreSQL (fallback when Redis is unavailable).

Find tracks most similar to a given embedding using cosine distance. Returns `(track_id, distance)` pairs sorted by similarity (closest first).

Mark a fetch as completed (whether success or failure).

Inner generation function (reusable from scheduler and endpoint)

Get a config value for this plugin. Requires `config_access` permission.

Get the current UTC timestamp in ISO 8601 format.

Extract p2p node from type-erased state

Extract p2p node from type-erased state

Extract p2p node from type-erased state