Render a cover page that declares an amendment, exactly as EDGAR nests it. Copied from DZ BANK's live 2020-09-30 amendments: ``isAmendment`` and

Create a dated OHLCV frame ending on the scanner target date.

Build a minimal FMP historical-price-full body.

Realised PnL for a closed position.

Equal risk contribution weights.

Normalize channel-like objects and ids to a stable string key.

Close an OpenD context, swallowing teardown errors.

Wrap one client contribution of ``size`` in a series. The amount is negated because ``CashFlow`` is holder-perspective: money the client pays

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

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.

Execute one fake MCP tool with a parsed FastMCP result.

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

Return the hand-built four-sector single-period attribution. Returns: The :class:`BrinsonResult` for the module-level fixture.

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).

Import ``agent/mcp_server.py`` without executing ``main()``. Returns: The imported mcp_server module.

Coerce an optional whole-number argument, rejecting malformed input. Args: value: Raw argument value; ``None`` and ``""`` mean "not suppl

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

Return whether *code* is a symbol this loader handles. Covers US/HK/India/Korea/Canada equities plus Yahoo's own futures (``GC=F``) and forex

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 a user-supplied code to the project's canonical loader symbol. The data loaders key US/HK/A-share instruments by an exchange-suffixed

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

Price an opening order without mutating portfolio state.

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

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

Refuse a code set whose members do not settle in one currency. The shared capital pool holds a single scalar of cash and sums position values

Return the shared CLI console.

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

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

Split raw Telegram Markdown without leaving fenced code blocks unbalanced.

Map a project interval string to Yahoo's chart interval string. Args: interval: Backtest interval such as ``1D`` or ``1H``. Returns:

Map project interval strings to yfinance interval strings. Args: interval: Backtest interval such as ``1D`` or ``5m``. Returns:

Open an immediate write transaction for cross-connection safety.

Run a deal-by-deal (American) waterfall. Each deal is its own miniature fund: its own contributed capital, its own preferred return accrued f

Percentile-bootstrap confidence interval for an arbitrary statistic. Resamples ``data`` with replacement ``n_bootstrap`` times, recomputes the

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.

Cancel one task by its tracked process group. Args: task_id: Identifier returned by :meth:`run`. Returns: JS

Raise :class:`TimeoutError` if the monotonic clock has crossed ``deadline``. Use this between pages of a paginated fetch to fail fast instead of

Evaluate one order intent against the mandate (fail-closed). Checks run in a fixed order and the first failure produces the verdict: exclude-

Reduce rolling correlation matrices to an edge-density series. Edge density is the fraction of distinct asset pairs whose rolling |correlatio

Summarize per-date weight changes in a target position frame. Args: target_pos: Target weights (dates x codes), e.g. the frame behind

Generate deterministic hash for deduplication.

Time-series view of an issuer's spread: level, z-score and percentile. .. warning:: ``historical_percentile`` is a **whole-sample** rank,

Deflate an observed Sharpe by the number of strategies searched. Args: observed_sharpe: Best observed Sharpe, per-observation. n_

Direct Alpha -- an annualized excess return over a public index. Every flow, of every kind (contribution, distribution or valuation mark), is

Total capital returned by the fund, as a positive magnitude. Args: series: The cash flows. distribution_kinds: Kind labels counte

Fit a normal-return model on an estimation window. Args: asset_returns: Asset returns over the estimation window. market_returns:

Fetch market data and return strict JSON.

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

Build a table from a sequence of individual quotes. Args: rates: The quotes, all against ``quote_currency``. quote_cu

Get a single artifact by ID. Returns ``None`` if not found.

Get bench history for an artifact, newest first.

Get decay snapshots for an artifact, newest first.

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

Return a process-wide singleton SessionSearchIndex. Thread-safe via double-checked locking. Used by both SessionService (indexing) and Sessio

Report whether *artifact* was both developed and approved by the same person. The four-eyes (maker-checker) principle requires the developer and

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

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

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

Convert raw JSON corpus to MemoryRecord list, IDF dict, and avg doc length. Returns: Tuple of (records, idf_dict, avg_doc_len).

Convert raw JSON queries to QueryRecord list.

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