Close an OpenD context, swallowing teardown errors.

Return token usage for a single LLM call, real if available. Prefers the provider-reported counts attached to the response by :func:`ChatLLM.

Build a ccxt ``binance`` client bound to the configured environment.

Return the ``data`` list from an OKX response, or ``[]`` defensively. python-okx returns a dict shaped ``{"code": "0", "data": [...]}`` on succes

Convert a Longbridge SDK numeric value (Decimal/int) to float for JSON serialization.

Perform a read-only GET request against the Trading 212 REST API.

Get or create the SQLite connection (WAL mode).

Return the ``api_server`` module for late-access attribute reads. Tests monkeypatch ``ENV_PATH``, ``ENV_EXAMPLE_PATH``, ``_baostock_supported``

Return True if the tool result does not look like an error response.

Build a minimal valid mandate with a caller-chosen ``expires_at``.

Normalise a Futu kline DataFrame to the standard OHLCV schema. Args: df: Raw DataFrame returned by ``request_history_kline()``. Retu

Convert an FMP historical-price body into an ascending OHLCV frame. Args: payload: Decoded JSON body from the historical-price endpoint.

Build a tz-naive trade_date-indexed OHLCV frame like a loader returns.

Normalize a Futu data payload to a list of row dicts. Handles a pandas DataFrame (via ``to_dict('records')``), an existing list of dicts, a s

Return the shared CLI console.

Get the sub-engine that provides rules for this symbol.

Get close price with fallback.

Return a fn() that walks through scripted outcomes (return value or raise).

Write a durable last-known runtime_state.json for ``broker`` directly.

Install the active progress emitter for the current thread. Args: emit: Callable that consumes a ``ProgressEvent``. Pass ``None`` to clea

Parse a trade journal and return a JSON analysis. Args: file_path: Path to CSV/Excel file. analysis_type: "full" | "profile" | "b

Build the worker's system prompt with role, upstream context, and skills. Args: agent_spec: The agent's role specification. upstr

Call a remote MCP tool.

Resolve an exact command name or alias. Returns ``None`` if no match — callers handle the "unknown command" response themselves so error UX s

Deserialize a session from a dictionary. Args: data: Dictionary produced from parsed JSON. Returns: A Sessio

Return the full documentation for a skill (used by the load_skill tool). Falls back to disk lookup for user skills created mid-session.

Return a process-wide cached ``Registry`` for the bundled zoo. Thread-safe. First call builds and caches; subsequent calls return the same in

Read a session. Args: session_id: Session ID. Returns: The Session instance, or None when it does not exist.

Read-only check: is this ``running`` run silent past its threshold? Used by both the read paths (return ``is_stale`` to callers without

Return jobs, optionally filtered by status. Args: status: When provided, include only jobs whose status matches this

Return the root directory for all live-channel state. Returns: ``<runtime_root>/live``. The directory is NOT created here; callers

Load local IBKR settings from ``~/.vibe-trading/ibkr-local.json``.

Load Tiger settings from ``~/.vibe-trading/tiger.json``.

Load Longbridge settings from ``~/.vibe-trading/longbridge.json``.

Load the swarm-side AgentConfig using the M3 boot resolution order. This is the helper boot wiring (``mcp_server.py``, ``api_server.py``, CLI

Pure core: is ``market`` open at the instant ``now_ms``. Deterministic — reads no clock. 24/7 markets (``always_open``) are always open. Sess

Return commands that fuzzy-match ``input_text``. Only matches when the trimmed input starts with ``/``. The leading slash and any trailing ar

Shuffle trade PnL order to test path significance. Null hypothesis: the observed Sharpe / max-drawdown is no better than a random ordering of

Normalize user-facing QVeris mode names.

Render the SignalEngine Python source for a profile. Args: profile: ShadowProfile carrying the rules to replay. Returns: Pyt

Render a PASS/FAIL verdict from per-point verification results. Each result with a ``fetched_value`` is judged against the reported value at

GET ``url`` after waiting out the per-host minimum interval. Args: url: Fully-qualified request URL. host_key: Throttle/session b

Split backtest into sequential windows, check consistency. Each window is evaluated independently (returns normalised to window start). Args

Attach Gemini thought signatures to assistant replay tool calls. The replay message is later converted back into LangChain messages from a pl

Write one live-action audit record for a tick outcome. Audit failures are swallowed (logged) so a ledger problem can never make a *bl

Reshape Sina ``{d,o,h,l,c,v}`` bars into the standard OHLCV frame. Args: bars: List of per-day dicts with ``d/o/h/l/c/v`` keys. s

Layer 2: fold long text blocks in older messages without LLM call. Preserves head + tail of large text, collapses the middle. Zero API cost —

Relays (OpenRouter) emit finish_reason per chunk; AIMessageChunk.__add__ concatenates into 'stopstop', 'tool_callstool_calls', etc. Return the

Build the standard JSON response.

Convert any numeric to an exact Decimal, avoiding float binary traps.

Extract product code from futures symbol. Examples: 'IF2406.CFFEX' -> 'IF' 'rb2410.SHFE' -> 'rb' 'au2412' -> 'au'

Paginated candle download. Args: inst_id: OKX instrument id. start_ts: Start time (ms). end_ts: End time

Repair orphaned tool_call / tool_result pairs after compression. Two fixes: 1. Remove tool results whose matching tool_call was compressed

Return the shared finance goal store.

Lazy-init SwarmRuntime singleton.

Equity that grows linearly from 1M to 1.2M (20% return).

Build an IBKR local config from a trading profile and call overrides.

Detect forex pairs by matching against AKShare's symbol_market_map. Issue #54 — forex symbols (EURUSD, GBPUSD, etc.) have no exchange suffix

Resolve a profile to a live-capable connector key.

Look up tiered maintenance margin rate.

Build an AgentConfig from a server-name → config-dict map.

Build lightweight MCPRemoteTool stubs without a live adapter.

Layer 1: silently prune old tool results, keeping the most recent N intact. Args: messages: Message list (mutated in place).

文本归一化：NFKC 折叠全角/半角 + 去除内部空白。 应用场景（CR P2）：新浪页面会出现“５％以上股东”、“控股 股东”等变体， 原吝始“kw in text”会漏命中。归一化后“５％”→“5%”，中文间空格被吃掉。

Normalize ``run_dir`` in tool args to an absolute path when possible. If the model supplies a relative ``run_dir`` (for example ``"."`` or ``

Return a monkeypatched module-level override if present.