Load OHLCV(+amount, +vwap) wide panel for the requested universe. Returns a dict keyed by panel column (open/high/low/close/volume/amount/vwap)

Log Matrix response errors — auth errors at ERROR level, rest at WARNING.

Build per-request headers (new UIN each call, matching reference).

Build a synthetic ``message.add`` event dict.

Build Tonghuashun-format rows from (datetime, symbol, side, qty, price). Tonghuashun requires columns: 成交时间 / 证券代码 / 操作 (see `trade_journal_p

Merge fundamental columns from daily_basic API. Args: result: Existing OHLCV frames. codes: All requested codes.

Return a unique module name for import tests.

Normalize nonnegative weights to sum 1.

Normalize forex symbol to 'XXX/YYY' format.

Return the current wall-clock time in epoch milliseconds. Returns: Milliseconds since the Unix epoch.

Render a success envelope as a JSON string. Args: market: Market label (e.g. ``"a_share"``, ``"us"``, ``"global"``).

Build a CallToolResult that mimics a successful remote call. The adapter's normalizer copies ``data`` / ``structured_content`` / text content

Parse inbound message, download attachments, and publish to the bus.

Build a fail-closed error payload carrying profile/guard context.

Normalize a CIK to the SEC's zero-padded 10-digit string form. Args: cik: A CIK as an int or a string that may already be padded or carry

Parse a string (or ``None``) into a boolean. Truthy values (case-insensitive): ``"1"``, ``"true"``, ``"yes"``, ``"on"``. Everything else — in

POST form-encoded data to the registration endpoint, return parsed JSON. The registration endpoint returns JSON even on HTTP errors (e.g. poll

Return a short, redacted argument preview for streamed events.

Render IM channel status.

Print a machine-readable run summary.

Render local QVeris config.

Return a minimal valid proposal payload for commit_mandate.

Return the contained proposal path for a valid opaque proposal id.

Append .SH/.SZ/.BJ suffix to a bare A-share ticker.

Monotonic close series of length n — drives RSI toward an extreme.

Read metrics from metrics.csv, return formatted string dict.

Return a diagnostic-safe base URL label for logs.

Return the configured Tiingo API key, or an empty string when unset. Returns: The trimmed ``TIINGO_API_KEY`` value, or ``""`` when absent

Return the first available data loader for ``asset_class``. Raises: UniverseDataUnavailable: When no loader in the market's fallback chai

Call ``fn`` up to ``tries`` times with exponential backoff.

An iWenCai robot-data response nesting two security rows.

Return the Shadow Account root directory (auto-created).

Flatten a ShadowRule into the scalar fields the template consumes.

Run an AgentLoop turn against the given scripted LLM. Args: monkeypatch: pytest monkeypatch fixture (zeroes the retry sleep). tmp

Public projection of a (live-hydrated) :class:`SwarmRun`. ``timed_out`` flips on only for the ``run_swarm`` wait-budget path. It does not cha

Return the persistent-runner identity key for ``broker`` (SPEC §7.5).

Evaluate a numeric arithmetic expression in the exact-Decimal domain. The expression is parsed and evaluated recursively with Decimal arithmetic,

Sanitised user-facing error string for unexpected exceptions. Always returns a fixed phrase — never echoes the exception message or type, bot

Persist a proposal with an arbitrary single profile + ceiling snapshot. Lets a test exercise commit-time validation against a profile the clampin

GET ``url`` as JSON through the shared SEC-bucket throttle. Args: url: Fully-qualified SEC endpoint URL. Returns: The decode

Send a JSON-RPC request via HTTP and wait for response.

Send m.room.message with E2EE options.

Send a typing START/STOP message via signal-cli.

Best-effort typing indicator update.

Return whether a group reply should create a Feishu thread/topic.

Trim an article body to a bounded plain-text snippet. Args: text: Raw body/summary value (any type). Returns: A whitespace-c

Extract the source names listed in the SKILL.md Source Overview table. Returns: The set of lowercase source identifiers named in the firs

Split raw Telegram Markdown without leaving fenced code blocks unbalanced.

Stop typing indicator for a chat.

Remove Rich markup from plain-text output.

Drop unpaired surrogate code points from ``text``.

Return the upper-cased exchange suffix of a symbol, or ``""`` when none.

Convert a ``YYYY-MM-DD`` date into Eastmoney's ``YYYYMMDD`` form. Args: value: Date string in any pandas-parseable form. Returns:

Convert a ``YYYY-MM-DD`` date to a UTC epoch-second bound. Args: date_str: Inclusive date string. end_of_day: When ``True`` push

Translate a project symbol into Finnhub's ticker convention. Args: code: Project-side symbol, e.g. ``AAPL.US`` or a bare ``MSFT``. R

Stack per-code OHLCV frames into wide panels keyed by field.

Write a plain-utf8 Tonghuashun-style CSV the parser can ingest.