Persist QVeris config with atomic replace and 0600 permissions. Args: config: Configuration to persist. Returns: The normali

Send a message through Discord using discord.py.

Start the Feishu bot with WebSocket long connection.

Stop bot and cleanup resources.

Format the event as an SSE text frame. Returns: Text that conforms to the SSE specification.

Attach security warnings for selected string fields in a payload. Field selectors are dotted paths. The ``*`` component iterates lists, e.g.

Cross-sectional z-score per row (axis=1, sample std). Rows with zero or NaN standard deviation become NaN — never silent zero.

Coerce ``value`` to a finite positive-or-zero float, else ``None``.

Discover + live-wrap the robinhood channel for a given allowlist.

Attach price-context features in place, batching one fetch per symbol. Groups roundtrips by symbol, fetches each symbol's price window once over

Write one live-action audit event and return the redacted record. The returned record (identical to what was written to the ledger) is

Return the supplied API credential from the permitted source.

Pick a cluster count via simple silhouette heuristic (fallback k=2). Uses the supplied numeric features; scales by z-score to avoid any single

Required-only kwargs for a SwarmRun instance.

Extract the best summary from all assistant messages.

Build outbound text chunks, including attachment-failure fallback text.

Build common Telegram inbound metadata payload.

Margin (collateral) required for a position.

Realised PnL for a closed position.

Run ``_run_agent`` with all heavy deps stubbed, returning its ``on_event``. Replaces ``AgentLoop`` with a stub that captures the real ``event_cal

Return the parent channel key for a Discord thread-like channel.

Call an IM channel runtime endpoint on the local API server.

Normalise a numeric string with commas (ASCII or wide) to float.

Remove *connection* from every subscription set; safe to call multiple times.

Remove all pending reactions after bot replies.

Derive a client-order-id from a recorded order for dedupe. A client-order-id is the idempotency key the broker echoes back so a caller can re

Coerce a JSON-schema array-or-string value to a string list.

Return subprocess stdout after ensuring the process has exited.

Normalize a ``YYYY-MM-DD`` (or already-compact) date for the API filter. Args: date: A trade date such as ``"2024-01-02"`` or ``"20240102

Next-bar forward simple returns from close, aligned to factor timestamp.

Build the trading profile dict. Args: df: Standardized DataFrame (datetime parsed, sorted). Returns: Dict with avg_holding_d

Picklable worker for parallel bench. Normal parallel execution passes only an alpha id after ``_init_bench_worker`` has stored the large pane

Point the local loader at a temp config file.

Render a cookie mapping as a single ``Cookie:`` header value.

Count registered backtest data sources for the system prompt. Derived from the loader registry's ``VALID_SOURCES`` (the single source

Derive topic-scoped session key for Telegram chats with threads.

Detect disposition effect: holding losers longer than winners. Metric = avg_loss_hold / avg_win_hold. A ratio > 1 means the user holds losing

A suggest payload spanning A-share, HK, and US markets.

Best-effort host event emission for goal mutations.

Convert a ``YYYY-MM-DD`` date to UTC midnight epoch seconds. Computed from the parsed calendar date (not ``time.time()``) so the window is re

Build the failure envelope as a JSON string. Args: message: Human-readable error description. Returns: A ``{"ok": false, "er

Bar-by-bar execution with market rule enforcement.

Execute a single tool call. Args: tc: Tool call object. context: ContextBuilder. messages: Conversation m

Extract text and image keys from Feishu post (rich text) message. Handles three payload shapes: - Direct: {"title": "...", "content": [[..

Cluster profitable roundtrips, derive one rule per dense cluster.

Smart-format tool result preview.

Return the active emitter on the current thread, if any.

Group symbols by inferred source (back-compat). Args: codes: List of symbol strings. Returns: Mapping source -> list of code

Return True when an identifier refers to the bot account.

Return the chosen ordinal if ``text`` is a bare numeric pick, else None. Only a turn that is *exactly* a positive integer (e.g. ``"2"``) counts a

Check whether *addr* is non-globally-routable (private/internal/mesh). ``addr.is_global`` is False for loopback, link-local, RFC 1918 private,

Return True when *path* corresponds to a frontend SPA page that shadows an API endpoint and should fall back to ``index.html`` on browser navi

Return True for HTTPS Bot Framework service URLs trusted for bearer replies.

True if a label looks like a meaningful financial field name.

True when running on a Windows-like platform (win32, including Cygwin/MSYS).

Serialize a tool response.

Call an R6 live-runner endpoint and decode the JSON response. Args: method: HTTP verb (``"GET"`` or ``"POST"``). path: Endpoint p

Resolve the protected MCP server config for ``broker``. The config is read at boot from the user-side protected agent config file (never from