Create a minimal MCPServerConfig-like object for testing.

Build a ccxt-shaped OrderBook dict, as ``fetch_order_book`` returns it.

Reload base.py with bottleneck enabled or disabled.

Fetch one DataFrame through the opt-in local cache. Convenience wrapper over :func:`loader_cache_get` / :func:`loader_cache_put` for the comm

Register a new artifact. Returns the artifact_id.

Override or reset the connector client factory (used by unit tests).

Money-weighted return of an irregularly dated cash-flow series. Solves ``sum(amount_i / (1 + r) ** t_i) == 0`` where ``t_i`` is the year offs

Load a Python module from a file path via importlib. Args: file_path: Path to the ``.py`` file. module_name: Logical module name.

Build the Rich renderable shown while the run is active.

Fan a redacted live-action record out to up to three sinks (SPEC §5). The record is redacted via :func:`src.tools.redaction.redact_payload` FIRST

Bar-by-bar execution with market rule enforcement.

Return a TestClient that simulates a loopback caller.

Return a JSON-safe goal snapshot.

Per-bar market-rule hook (funding fees, liquidation, etc.). Default: no-op. Override in subclass as needed.

Resolve a profile id or the saved selected profile. Args: profile_id: Optional explicit profile id. Returns: Matching profil

Run the ReAct loop synchronously. Args: user_message: User message. history: Prior conversation messages.

Market-aware VWAP-equivalent reference price. - ``equity_cn``: ``(amount * 1000) / (volume * 100 + 1)`` — Tushare's ``daily.amount`` is in

Return a unique module name for import tests.

Parse *source*, run the visitor, return (violations, warnings).

Per-bar simple returns, defined only where the prior price is positive. ``close.pct_change()`` silently assumes ``price[t-1] > 0``. That holds fo

Keyword search across all entries, weighted by importance.

Return the capability record for a provider/model pair. Args: provider: Configured provider name. model: Configured model name, u

Return all persisted memory entries, filename-sorted.

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

Load eToro settings from ``~/.vibe-trading/etoro.json`` and env fallbacks.

Return the first due epoch-ms strictly after ``after_ms``. Supports the scheduled-research schedule format: a bare positive integer string fo

Return the directory path for a given run. Args: run_id: Run identifier. Returns: Path to the run directory.

Insert or replace a job by id. Validates the schedule string and the timezone's shape before persisting. The timezone key is delibera

Measure the abnormal return around a set of dated events. Args: returns: Simple returns, rows indexed by date, one column per symbol.

Run a bench end-to-end and return the API-shaped summary. Args: zoo: Zoo id (e.g. ``gtja191``, ``alpha101``, ``qlib158``). univer

Update a goal status with stale-goal and completion validation.

Infer market type from symbol format. Args: code: Ticker / symbol string. Returns: Market type (a_share/us_equity/hk_equity/

Build a CashFlow on 2024-01-<day> for terse test construction.

A ledger that has retrieved one AAPL.US quote through *tool*.

Create a synthetic equity curve.

Build a return frame generated by a known market model.

Return the per-broker state directory under the live root. Args: broker: Broker key, e.g. ``"robinhood"``. Normalized to lower-case and

Remove a job by id. Args: job_id: Identifier of the job to remove. Returns: ``True`` when the job was found

Run one read-only snapshot query. Args: **kwargs: ``action`` plus that action's parameters — ``stock_ids``, ``sta

Check sender permission: star > allowlist > pairing store > deny.

Return criteria for a goal.

Run a complete DCF from a flat mapping of named inputs. This is the entry point :mod:`contracts` was written for: every required field is nam

Rolling argmax (0-based index into the window), warmup → NaN. Uses ``bottleneck.move_argmax`` when available (~350x faster). Correction: ``bn

Build a runner wired entirely to the tracker stubs, with overrides.

A small, valid ``run_dcf`` inputs mapping (target capital structure).

Build a content-based cache key for MCP tool discovery results. Every field that can change the tool specs a server returns must participate

Import the SDK connector module for a ``broker_sdk`` connector key.

Compute the five Black-Scholes-Merton Greeks. Args: S: Underlying spot price. K: Strike price. T: Time to expiry in years

Construct the configured LangChain chat model. Args: model_name: Model name; defaults to LANGCHAIN_MODEL_NAME. callbacks: Optiona

Classify one remote tool via the 3-tier precedence ladder. The curated map is authoritative: when it names the tool, its class is returned re

Write a mandate — the ONLY code path that activates live-trading authority. Re-validates that ``proposal_id`` is live and that the resolved profi

Compute the risk x-ray for a weighted basket. Args: closes: Close-price panel, one column per symbol, sorted by date. weights: Sy

Build and publish an event in one step. Args: session_id: Session ID. event_type: Event type. data: Event

Resolve a per-provider minimum request interval from the environment. Args: env_name: Env var carrying an override in seconds (e.g.

Run a full comparable-companies valuation: EV bridge, multiples, implied range. Args: target: The company being valued. peers: Th

Return a ``_sec_get`` stub serving a whole quarter's chain of filings. Each entry is ``{adsh, form, file_date, cover, rows}``: ``cover`` is the

Build one EDGAR full-text search hit in the live ``_source`` shape.

Populate a tmp memory dir with one entry per type.

Append traceable evidence after stale-goal validation. Args: session_id: Owning session id. goal_id: Goal being mutat

Fresh copy of the worked example's ``run_dcf`` inputs mapping. Args: structure: ``"target"`` supplies ``target_equity_weight``/

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

Resolve API key, base URL, and model from provider/model env vars. Centralizes the ``provider → env_var_name → os.getenv → credential`` chain

Return a media directory for *channel_name* under the VT uploads root. Inbound media must land inside ``~/.vibe-trading/uploads`` — one of the

Load an entity x date x metric panel file into an ``EntityPanel``. The ingest module's generic counterpart to ``load_cashflows``, for data th

Parse one playbook markdown file. Args: path: Path to a ``.md`` playbook file. Returns: The parsed :class:`ResearchPlaybook`

Apply optimizer to position weights. Args: ret: Return matrix (dates x codes). For a decision at ``dt``, only row

Remove a memory entry by name. Returns True if found and removed.

Chain-link the true time-weighted return across a valuation series. Each interval's return removes that interval's external flow before divid

Rolling argmin (0-based index into the window), warmup → NaN. Uses ``bottleneck.move_argmin`` when available (~350x faster). Correction: ``bn

A self-consistent, LTM-ready peer for tests that are not about the big hand-computed fixture (EV bridge signs, exclusion, warnings, ...).

A gamma event wrapping the supplied markets.

Check whether a futures code belongs to a Chinese exchange. Recognises two forms: 1. ``<product><delivery>.<exchange>`` where exchange is o