Run `f` against the connection on the blocking thread pool. Every public I/O method below is a thin wrapper around this — it's the one place that act

Ensure a conversation with a stable ID exists.

Simple expression calculator. Evaluates basic math: +, -, *, /, parentheses, decimals. No dependencies — hand-written recursive descent parser.

Parse a configured service URL into a probe target for `genie-ctl`'s HTTP/TLS probe client. Behavior: - Bare URLs without a scheme are treated as `ht

Parse tool calls from model output without executing them. This is intentionally separate from `try_tool_call_with_context`: evaluation should never

Resolve `session_key` to a conversation id, creating one when absent.

Synthesize text and play directly through the speaker. Pipes text to Piper stdin, raw PCM stdout goes to aplay. Uses process pipes instead of shell t

Check if a tool call should be allowed.

Flush any buffered trailing fragment after the LLM stream ends. Returns the cleaned final fragment; unlike `try_emit`, no minimum-length check applies

First value for `name`, matched case-insensitively. Returns the raw (un-lowercased) value so callers see exactly what the peer sent.

Skills dir + a sibling trusted-key dir with one installed key, plus the sample `.so` copied in. Returns the directories, the installed `.so` path, and

Deterministic signing key from a fixed seed — no RNG needed in tests.

Set public web search provider configuration.

Assess whether a home action is safe to execute immediately. This is intentionally conservative. GenieClaw is a shared-room appliance, so risky physi

Execute a structured home control action via the HA provider.

Get all memories of a specific category (e.g. "identity").

Core text ingestion: split into chunks, extract facts, deduplicate, store.

Async wrapper around [`mem_available_mb`] for callers running on a shared `current_thread` executor. Moves the synchronous `/proc/meminfo` read to Tok

Probe targets for the optional HTTP services that `health`, `diag`, and the support bundle inspect alongside `genie-core`. Reads `[services.api]` and

Parse a single line of `tegrastats` output. Example line: ```text RAM 2345/7620MB (lfb 234x4MB) SWAP 0/3810MB (cached 0MB) CPU [20%@1510,15%@1510,10%

Delete old, unaccessed memories using exponential decay. Keeps evergreen and promoted memories.

Sox-only chain: downmix → bandpass → (optional noisered) → compand gate+lift → peak-normalize. Falls back to the raw WAV on sox failure.

Accept connections from an already-bound `TcpListener`. Prefer [`serve`](Self::serve) for production use. This entry-point exists so tests can pre-bi

Register a countdown timer. Returns an error (instead of growing memory unbounded or wrapping the end timestamp) when the duration is zero/oversized

Capture the `home_control` call that restores `prior` before `action` ran.

Assemble the boot-time system prompt for `model_name` over a fresh memory file hydrated with `identity_facts`, then return its SHA-256 — the same dige

Build memory context using explicit session/identity information. This is the internal contract the voice/app layers should use once they can resolve

Materialize `(name, probe_url)` pairs for every service the health monitor owns. Core's probe is derived from `[core].bind_host` and `[core].port` so

TCP `host:port` for local HTTP clients proxying to genie-core. Uses `[core].bind_host` and `[core].port`. Maps `0.0.0.0` / `::` to `127.0.0.1` becaus

Measure the steady-state gain `apply_voice_eq` applies at `freq_hz`. Drives a pure sine of known amplitude through the EQ and returns the ratio of ou

Get all entity states.

Build an HTTP `IncomingTurn` from a parsed chat JSON body.

LLM model to use in this mode.

Load profile.toml and store entries as evergreen memories. Returns the number of facts stored.

Scan and log if suspicious. This is an **observability** control: it emits a `tracing::warn!` on a match and returns whether the input looked suspici

Store a fact while resolving simple single-value conflicts. This keeps household memory coherent for facts that should have one current answer, such

Each test gets its own parent dir so SQLite WAL/SHM sidecars and audit-log JSONLs cannot collide and ConversationStore::open's CREATE-TABLE-IF-NOT-EXI

Simple spectral noise suppression. Estimates noise floor from the quietest frames, then subtracts it from all frames. This is a simplified version of