Decide whether to register a live channel given session interactivity. SPEC Transport §4 (headless / no-token-yet): a non-interactive ``serve

Stop and erase the spinner line.

Compute support and resistance levels via peak/valley clustering. Args: close: Closing price series. window: Peak/valley detectio

One-sample t-stat against zero (returns 0.0 if undefined).

Return whether a TCP socket accepts connections.

Bull / base / bear target prices from EPS-growth and target-PE assumptions. Future EPS = ``current_eps × (1 + growth) ** years``; target price =

Serialize to JSON-safe dict.

Return a JSON-serializable dict for SSE payloads.

Compute rolling linear-fit slope. Args: close: Closing price series. window: Fitting window size. Returns: Series of

Update task status and additional fields. Args: task_id: Task ID. status: New status. **kwargs: Optional

Validate the only supported ChatGPT Codex OAuth endpoint. ChatGPT OAuth tokens must not be sent to arbitrary OpenAI-compatible base URLs. The

Verify ``market cap = price × shares`` against a reported value. Args: price: Current share price. shares: Total share count.

Derive valuation ratios from raw per-share inputs (exact decimal). Each optional input, when supplied and non-zero, contributes its metric(s).

Return the wall-clock time when the current turn started, or None.

Write an entry with one potentially large text field. Args: entry: Base trace entry. Mutated before writing. field: T

Add a reaction emoji to a message. Returns the reaction_id on success, None on failure. When called via a tracked background task, th

Return all roots allowed for run_dir-based tools.

Return the FMP API key from the environment, stripped (``""`` if unset).

A datacenter appearance payload with two board rows.

Mirror AgentLoop layer-1 gate (``loop.py`` ~572-573).

Coerce an Eastmoney numeric cell to ``float``, or ``None`` if unusable. Eastmoney emits ``"-"`` for missing numerics; those map to ``None``.

Fail with a clean error when the local OpenD gateway is unreachable.

Atomically write a file: write to .tmp then rename. Args: path: Target file path. content: File content.

Write ``payload`` as JSON to ``path`` atomically with 0600 perms. The parent directory is created 0700 and the file is written via a same-dir

Idempotently subscribe *connection* to *chat_id*.

Attach text inline or as a sidecar path.

Append one redacted live-action record for a sweep broker call. Args: broker: Broker key (stamped as ``server``). remote_tool: Br

Resolve the OAuth authorize handshake deadline in seconds. Reads ``VIBE_LIVE_AUTHORIZE_TIMEOUT_SECONDS`` and falls back to :data:`_LIVE_AUTHO

Layer 3/4/5: structured LLM summary with token-budget tail protection. Upgrades over the original: - Token-budget tail: keeps ~20K

Return the numeric stock code without its exchange suffix.

Strip any exchange suffix to the bare numeric A-share code. Args: code: A symbol such as ``"600519.SH"``, ``"000001.SZ"`` or ``"600519"``

Strip any exchange suffix to the bare code used as a news search term.

Build common metadata for text and media handlers.

Strip the ``.NS`` / ``.BO`` suffix, leaving the broker's bare symbol.

Normalize blank MCP strings to None.

Construct a :class:`BreachEvent` with a computed ``overage``.

Split content into div/markdown + table elements for Feishu card.

Build the public data source settings payload.

Build the public settings payload from dotenv values.

Constructs and returns a dictionary representing the matrix text content with optional HTML formatting and reference to an existing event for

Instantiate one sub-engine per market type detected in codes.

Reconcile + project a run for the MCP response. Used by ``run_swarm`` (polling + start_only). Returns a normal payload on success and a ``{"s

Load and filter recent message history for a session. Returns up to ``_HISTORY_RETAINED_TURNS`` user/assistant messages with non-empty conten

Build plain-text status bar segments. Args: stats: Session statistics. Returns: List of status text segments.

Keep the most recent periods, each truncated to a safe field count. Args: periods: Period records as returned by the provider parser.

Return channel IDs that can satisfy allow_channels for this channel.

Return the first BaseChannel subclass defined in *module*.

检查连续 Swing 点之间是否满足最少 K 线数。 Args: swings: Swing 点列表。 start: 起始索引。 count: 检查的点数。 Returns:

Coerce a caller-supplied ``limit`` into the supported ``1.._MAX_LIMIT`` range. Args: raw: The raw ``limit`` value from the tool arguments

Trim a date cell to its ``YYYY-MM-DD`` form, or ``None`` when absent/blank.

Trim a string cell, or ``None`` when absent/blank/non-string.

Build a ``TigerOpenClientConfig`` from connector settings.

Two ascending bars in eastmoney_client.fetch_kline output shape.

Coerce a raw Eastmoney numeric cell to ``float`` or ``None``. Args: value: Raw value from the payload (number, numeric string, or sentine

Clamp a requested row limit into the supported range. Args: value: Raw ``limit`` argument (may be missing, a string, or a number). R

Return the four banner stat values, computing them at most once. The interactive launch path runs every probe synchronously (the user is alre

Format a date as Eastmoney's ``YYYY-MM-DD`` filter literal.

Run all 4 behavior diagnostics. Args: df: Standardized DataFrame (datetime-sorted). Returns: Dict with disposition_effect /

Causal Wilder-EWM RSI. Mirrors the shape of ``compute_rsi`` in ``agent/src/skills/technical-basic/example_signal_engine.py:13`` — that mo

Install a minimal OpenAI-compatible provider environment for preflight tests.

Re-attach Gemini thought signatures dropped by dict->message conversion. The AgentLoop replays history as OpenAI-format dicts, stamping t

Create the appropriate market engine based on data source and market type. Routing priority: 1. Detect market type from symbol patterns (fu

Create a prompt_toolkit PromptSession with history and live toolbar. Args: stats: Session statistics for the live bottom toolbar. Re

Map the configured ``feed`` string to the Alpaca ``DataFeed`` enum.

Two daily rows in the Eastmoney RZRQ datacenter response shape.

Equity that declines from 1M to 800K (-20%).

Return the configured DeepSeek adapter mode.

检测单个标的的谐波形态。 优先 pyharmonics，失败则回退内置检测器。 Args: df: OHLCV DataFrame。 Returns: 检测到的形态列表。

Infer legacy source name from symbol (back-compat for metrics/engine). Args: code: Ticker / symbol string. Returns: Source n