An unsettled binary market as gamma serializes it.

Build a minimal stand-in for a ``requests.Response``. Args: text: Body used by the XML path. payload: Object returned by ``.json(

Read evidence rows, optionally filtered, ordered by (strategy_id, regime).

Load an irregular dated cash-flow file into a ``CashFlowSeries``. The file needs a date column and an amount column. Currency and kind may co

Load the committed mandate for ``broker`` from the protected store. Reads ``<runtime_root>/live/<broker>/mandate.json`` (written 0600 by the

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

Handle an incoming message: check permissions, issue pairing codes in DMs, or forward to bus.

Convert a LangChain AIMessage (or AIMessageChunk) to ``LLMResponse``. Single source for reasoning: ``additional_kwargs["reasoning_content"]``

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

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

Monkeypatch ``_fetch_raw_book`` to return ``book`` and record call args.

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.

Close the file handle.

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

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

Register a new artifact. Returns the artifact_id.

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

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 a return frame generated by a known market model.

Keyword search across all entries, weighted by importance.

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

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

Return a TestClient that simulates a loopback caller.

Add connector profile metadata to an operation payload.

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

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

Return a JSON-safe goal snapshot.

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

Insert or replace evidence rows. Returns the number of rows written. Raises: ValueError: When any row carries a NaN/Inf numeric f

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

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

Return all persisted memory entries, filename-sorted.

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

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.

Patch the loader's config accessors directly (no config-cache dependency).

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

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

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

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

A row that passes every Phase 1 gate (non-borderline by construction): 20 trades, adequate quality, comfortable breakeven, long coverage — so

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.

Return a ledger that screened broadly, then locked one candidate.

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

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

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

Return criteria for a goal.

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

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

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

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

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