Build the structured refusal envelope returned to the agent loop.

Reject unsafe browser requests from untrusted cross-site origins.

Remember known bot identifiers for mention matching.

Cache Telegram thread context by chat/message id for follow-up replies.

Remove emoji reaction from a message (best-effort, non-blocking).

Render values as a stable ``.env`` body (KEY=value lines).

Render with Jinja2 autoescape if available; else manual ``html.escape``.

Send an ephemeral interaction response and report success.

True iff a non-empty report.md was actually produced by the worker.

Reset client and typing state.

Return the configured Alpha Vantage API key, or empty when unset. Returns: The trimmed key, or ``""`` when the env var is absent or a pla

Return ``(broker_key, sdk_module)`` for the first available India broker. Prefers Shoonya, then Dhan. Returns ``(None, None)`` when neither the S

Resolve a Discord channel from cache first, then network fetch.

Return ``(node_path, npm_path)`` if both are on PATH, else ``(None, None)``. Used by ``cmd_setup`` to fail fast with a clear message instead of

Map run results to stable exit codes.

Build an AgentLoop, wire up a scratch run_dir, and execute.

Run an async operation from sync code. Args: operation: Async callable to execute. Returns: Result returned by the async cal

Execute an attempt with the V5 AgentLoop. Args: attempt: Current execution attempt. messages: Session message history

Run a worker with automatic retry on failure. Retries up to agent_spec.max_retries times. Emits a "task_retry" event before each retr

Return *value* if it's a dict, else empty dict.

Safely traverse nested dicts.

Validate a user-supplied path against explicit import roots. Args: p: User-supplied path. `~` expansion is supported. purpose: Hu

Return whether *current* is the same scheduled run we started. ``created_at`` is assigned once at creation, so a replacement POST for

Drop structurally-invalid OHLC bars from every fetched frame. Each loader only drops NaN rows, so a bar that violates the OHLC invariants (``

Normalize a server or tool name segment for stable local naming. Args: value: Raw server or tool name. Returns: Lowercase AS

Return whether scheduled research execution is enabled.

Send a control event (attached, error, ...) to a single connection.

Send a single message and return the message_id on success.

Send a text message matching the exact protocol from send.ts.

Send a plain text message with HTML fallback.

Send a plain/markdown text message.

Return True if any normalized variant of sender_id is on allow_list. Both ``sender_id`` and each allow_list entry can be a single ide

Set CardKit streaming_mode using a strictly increasing sequence.

Apply sender and room policy checks.

Show current runtime settings.

Read a derived-field spec entry from either a mapping or an object.

Split card elements into groups with at most *max_tables* table elements each. Feishu cards have a hard limit of one table per card (API erro

Start the IM channel runtime.

Start sending 'typing...' indicator for a chat.

Start periodic typing refresh (spec-recommended keepalive).

Return the durable runtime-state path for ``broker``.

Build a ProviderStreamError mimicking a transient mid-stream reset. Returns: ProviderStreamError wrapping a ``ConnectionResetError``.

Scope streaming buffers to the inbound message when available.

Strip markdown formatting markers from text for plain display. Feishu table cells do not support markdown rendering, so we remove the

Return the connector-specific sweep tool name for audit records.

Mirror package-level monkeypatches onto ``_legacy``'s module globals. Tests reach into ``cli.<NAME>`` to override constants, but legacy calla

Return the file path for a task. Args: task_id: Task ID. Returns: Path to the task JSON file.

Return the message_id that should receive a Reply API response.

Coerce a cell to ``float``, or ``None`` when absent/non-numeric.

Map an internal code to Sina's bare ticker (``"AAPL.US"`` -> ``"AAPL"``).

Map a project symbol to a Tiingo ticker, or ``None`` when unsupported. Args: code: Project symbol such as ``AAPL.US`` or ``AAPL``. R

Return today's date (indirection kept for test monkeypatching).

Build a ProviderStreamError mimicking a transient mid-stream reset. Returns: ProviderStreamError wrapping a ``ConnectionResetError`` (no

Stringify and truncate an event preview payload.

Attempt sendRichMessage (Bot API 10.1). Returns True on success.

Unlock the trade context for live profiles; paper (SIMULATE) is a no-op. Live trading requires the MD5 of the Futu trade password, read from the

Return today's UTC calendar date as ``YYYY-MM-DD``.

UTF-16 code-unit length, matching Signal BodyRange semantics.

Validate configured auth, preserving loopback-only dev mode.

Reject import-time execution in function definitions.

Validate a journal_path kwarg that may be missing/empty. Returns the resolved path string, or None when the caller didn't pass one. Raises Va