Return the timestamp of the last line in ``events.jsonl``. Used by the stale-run reaper. Returns ``None`` when the file is missing, empty, or

Detect a leading Signal mention placeholder when mention metadata is missing. Some clients/integrations deliver mentions as a leadin

Return True when the source line contains ``# noqa: env-gate``.

Return the base URL of the running API server for runner-control calls. Mirrors :func:`cli.main._commit_mandate`: the base is read from ``VIB

Load JSON from disk if present.

Load refs from disk with compatibility fallback for legacy layouts.

Load a skill from a directory. Args: dir_path: Skill directory path (must contain SKILL.md). Returns: Skill instance or None

Load saved account state. Returns True if a valid token was found.

Keep local FastMCP fixture traffic out of developer/system HTTP proxies.

Build a minimal SwarmAgentSpec for direct worker invocation.

Create a fake frontend directory with a placeholder Vite binary so that ``cmd_dev``'s pre-flight check (``node_modules/.bin/vite``) passes dur

Return an on_progress closure that updates the job entry in-place.

Build a minimal SwarmTask bound to ``test_agent``.

Convert markdown to Telegram-safe HTML.

Extract possible identifier fields from a mention payload.

Extract a safe (start, length) span from a mention.

Recursively merge two plain dictionaries. Args: base: Base dictionary. override: Override dictionary applied on top of ``base``.

Resolve the minimum interval between QVeris requests.

Extract non-zero per-asset balances from a ccxt ``fetch_balance`` result. ccxt returns a dict keyed by asset (each ``{free, used, total}``) plus

Normalize an address or mailbox-like identifier for comparisons.

Normalize common HTML whitespace/entities from Teams into plain text spacing.

Project ``source`` onto canonical limit names for ceiling comparison. Only the keys that name a clamped limit (those in :data:`_CEILING_ALIASES`)

Normalize an explicit preset name and validate it against bundled presets.

Normalize stored price rows for charting. Args: rows: Raw rows loaded from CSV or generated data frames. Returns: Normalized

Current wall-clock time in epoch milliseconds, UTC. Returns: Epoch milliseconds for the current instant.

Return whether an OAuth token cache exists for a broker (C2 auth state).

Run OCR on a numpy image; return joined lines or empty string.

Three ascending observations with one FRED missing-value gap (".").

Build a fail-closed order error envelope tagged with the profile.

Interpret an OKX order/cancel response, failing closed on any non-zero code. Success requires both the outer ``code == "0"`` and the first data r

Parse a base64-encoded AES key, handling both encodings seen in the wild. From ``pic-decrypt.ts parseAesKey``: * ``base64(raw 16 bytes)``

Mirror ``invoke``: convert the raw OpenAI-format input first (where ``_convert_input`` re-attaches signatures), then build the request payload

Absolute relative percent difference (inf when reported is 0 and fetched isn't).

Project selected Yahoo fields into a flat, raw-unwrapped row.

Pick a thinking verb via the shared helper, with a local fallback.

Build the autonomous-turn prompt with the full mandate pinned inline. The mandate text is embedded directly in the prompt this runner owns so it

Build a panel where the close price *is* the latent factor — the test can then ask for a factor that uses close.pct_change(5) and knows the an

Determine price limit based on board. Args: symbol: Stock code (e.g. 300001.SZ, 688001.SH, 000001.SZ). Returns: Limit as fra

Print the assistant answer after the rail without boxed run panels.

Print a static status bar using Rich (fallback without prompt_toolkit). Args: stats: Session statistics.

Print actionable JSON diagnostics for ``--swarm-run`` vars.

Print the welcome screen.

Process a queued slash command.

Process a queued Telegram message update.

Return the numeric feature set used for clustering. Always includes the journal-derived ``_NUMERIC_FEATURES``. A price feature joins only whe

Read a masked secret. Returns string, BACK, or CANCEL.

Return the credential environment variable for a provider.

Remove stale and unsupported conversation refs from memory.

Drop completed/errored bench + compare jobs older than ``_JOB_TTL_SECONDS``.

Perform QR code login flow. Returns True on success.

Stash ``prompt`` on ``ctx.pending_prompt`` for the loop to consume. Returns ``True`` if the context exposes a writable ``pending_prompt`` att

Open an ``OpenQuoteContext`` against the local OpenD gateway.

Resolve a path through the read_file tool and return the parsed body. Args: path: Path argument passed to read_file (no run_dir; skills/

Read the persisted QVeris config without env overrides.

Read user input with arrow key support if prompt_toolkit is available. Falls back to Rich Prompt.ask() when prompt_toolkit is not installed or

Safely read JSON.

Parse a document-reader JSON envelope.

Return connector-specific read tools, falling back to legacy names.

Read trace.jsonl entries from a run directory.

Rebuild MEMORY.md from all existing entry files.

Pure: derive a terminal SwarmRun from already-terminal tasks.

Return a fresh context_token if the cached one is too old. iLink context_token expires server-side after a short idle period (empiric