Hash a credential for storage. Plain SHA-256 is correct here and bcrypt/argon2 would be cargo cult: these are 256-bit random tokens, not user

How many payload bytes may ride the control stream. The negotiated value when the control plane has stated one, otherwise the executo

Whether this key still has authority to use an existing session.

Load an audio file, preprocess it, and convert to a PyTorch tensor. Args: fname (str): Path to the audio file. sample_rate (

A candidate interpreter path, safe to log. Every one of these paths runs through the user's home directory, so it carries their account name

Create a torch audio tensor of the given duration.

Map a time on the original timeline to its position on the fitted one. Finds the plan chunk whose original span contains ``t`` and interpolates

User-writable root for acquired binaries + the yt-dlp overlay. Lives in DATA_DIR so it survives app updates (the app bundle / venv are replac

Subscribe to task transitions (the UI's event feed hangs off this).

Open backend_err.log for a new run: append-only (a respawn must not destroy the previous run's evidence), rotated when oversized, with the run's start

Extract the loudnorm measure JSON from ffmpeg stderr → MeasuredLoudness, or ``None`` on ANY failure (caller falls back to single-pass). FFmpeg pri

The folder the app sits in — next to the executable, or next to the `.AppImage` file on Linux (the mounted exe path is an ephemeral squashfs mount, us

Directory that holds a portable install. Resolution order — first hit wins: 1. the pointer file beside the app. This is the one that KEEPS portabilit

Path of the pointer file (whether or not it exists).

Decide and (for the batched tier) execute the video retime for a Smart Fit plan. Returns ``None`` when no chunk actually needs retiming (audi

Reconcile one task against what a reconnecting worker claims to hold. Returns an action for the caller: ``"resume"`` (worker is still validly

Re-transcribe a written reference clip and return that transcript. `extract_speaker_clones`/`extract_segment_refs` pair each audio slice with

Set to let a deliberately-wedged worker return. Sleeping a wedged job for a fixed 30s and walking away leaks the thread past its own test: it

Record the id a panel assigned, so the next reconnect can sign for it.

Resolve a provider's base URL (env → stored override → default). ``substitute`` interpolates ``{account_id}`` for account-scoped providers (C

Resolve + validate the active TTS engine for a generation call. Returns the live backend instance (:func:`get_active_tts_backend`) — cached,

User-chosen backend data dir (voices/projects/db) → `OMNIVOICE_DATA_DIR`. `None` = backend platform default; we deliberately don't set the env var the

Publish revocation, then wait until retained work is cancelled.

Drive one dialled session until it ends. Mirrors ``Control``'s task set minus the writer: outbound writes to a servicer context, whil

True iff the calling thread is a gpu-pool worker (already holds a slot). Routes that dispatch backend work via run_on_gpu_pool_guarded are alread

Write the config to an explicit path (used by `complete_setup` to seed the portable folder before `config_path` starts resolving to it).

Files and directories a scope owns. Pure: `Roots` in, paths out. Paths that do not exist are included — the caller filters — so the scan can report an

Deterministic content hash for ONE rendered segment (a single spoken span). Same dimensions as :func:`chapter_cache_key` minus span order and

Deterministic hash of the inputs that actually affect TTS output. Any change to `_GEN_INPUT_FIELDS` flips the hash and the segment becomes a

Spawn into deterministic containment. No descendant discovery is involved: ordinary children inherit this process group/job at creation, while nested

Force-shut a specific engine's sidecar now (busy-guarded). Returns the number shut down (0 if it wasn't running or was busy).

True if ``path`` is a readable jpg/png within the size cap. Anything dubious (missing, wrong type, too big, unreadable) → False, and the caller

Cheap structural validity check for an existing venv — no subprocess spawned. Returns a human-readable reason when the venv can never work and must be

Probe writability of the nearest existing ancestor with a real write — permission bits lie (ACLs, read-only mounts, translocation), a temp file doesn'

Resolved at call time — a module-level binding could go stale when another suite purges omnivoice.* from sys.modules (CodeRabbit, #1565).

Durably reconcile off-loop, then publish on the owning loop.

Shared post-DSP for /generate: preset validation → mastering → effect chain → loudness normalization. ``skip_mastering`` honors a backend's `

Mirror of dub_core.py's post-diarization assignment loop (#486).

``(attempt, foreign)`` — the attempt, and whether another worker owns it. The two None cases must not be collapsed. "No record" is ordinary a

Resolve the on-disk path for the platform binary.

Bound a blocking call without losing ownership of its live thread.

An ``ensure_loaded`` that dies like a rotted deep import chain.