Detect A-share index symbols (000xxx.SH, 000300.SH, 399xxx.SZ).

Return whether *interval* is finer than one day (minute/hour bars). Daily-and-coarser intervals (``1D``/``1W``/``1M``) carry no meaningful in

Return whether the request originates from a loopback client.

Return whether *code* is a symbol this loader handles (US/HK/India).

Detect US equity symbols (e.g. AAPL.US).

Login to Shoonya API with TOTP authentication. Sessions are cached per ``user_id`` so distinct accounts never share an authenticated client.

Write a minimal agent.json config pointing at the fake stdio server. Args: tmp_path: Temporary directory to place the config file in.

Build a DataFrame with trade_date as the index name (like real loaders).

Build a SwarmRuntime backed by a tmp-path SwarmStore.

Resolve the per-call minimum spacing, honoring the env override.

Normalize symbol strings for a source. Args: codes: Raw code list. source: Data source. Returns: Normalized codes.

Return 'buy'/'sell', falling back to 'buy'.

Normalize Signal identifiers (phone/uuid/service-id) for matching.

Build a TIME_SERIES_DAILY-shaped payload from (date, o, h, l, c, v) tuples.

Wrap report rows in the datacenter ``result.data`` envelope.

Size of 1 pip for the pair. Args: symbol: Forex pair (e.g. 'EUR/USD', 'USD/JPY'). Returns: 1 pip in price terms (0.0001 or 0

Compute price-context features as-of *buy_dt* from a price frame. Every value is read from bars dated ``<= buy_dt`` only; bars in the ``(buy_

Process incoming message and forward to bus.

K线振幅（最高 - 最低）。 Args: h: 最高价序列。 l: 最低价序列。 Returns: 每根K线的振幅。

Read a supported config file format into a dictionary. Args: path: Config file path to decode. Returns: The decoded config o

Render a compact goal card.

Resolve and guard the account id by its ``trd_env``. Calls ``get_acc_list()``, keeps rows whose ``trd_env`` matches the profile, and either c

Return report.md content if it exists, otherwise fall back to text.

Pick the operator config the swarm runtime should boot against. Resolution order (first hit wins): 1. ``VIBE_TRADING_SWARM_AGENT_CONFIG`` en

Build AgentLoop and execute, return result dict. Args: proposal_sink: Optional callable invoked with the payload of every ``m

Call ``obj.name(*args, **kwargs)`` if it exists, retrying without kwargs. Tiger SDK signatures vary across versions (some read methods take an

Sanitize a user query for FTS5 MATCH syntax. - Splits on non-alphanumeric/CJK to extract tokens - Joins with OR so any-word-matches (

Best-effort write to ``.env.partial`` (crash-resilience nicety).

Scan all .md files (except MEMORY.md) and parse frontmatter. Returns: List of parsed memory entries.

Vertically-scrollable selector. Returns chosen value, BACK, or CANCEL. Keybindings: ↑/↓ navigate, Enter confirm, Esc/← back, Ctrl+C cancel. F

Best-effort sendtyping wrapper.

Build sender_id with username for allowlist matching.

Return the active CLI session id, optionally creating one.

Cross-sectionally permute finite values within each row. This preserves the per-date cross-sectional distribution of the factor while destroy

Stop typing indicator for a channel.

Extract the JSON array embedded in Sina's JSONP wrapper. Args: raw: Raw response body, e.g. ``var x=([{"d":"2024-01-02",...}]);``. R

Return up to three "did you mean" suggestions for ``unknown``. Uses :func:`difflib.get_close_matches` (edit-distance based) as the primary si

Map provider-specific env vars to OPENAI_* for ChatOpenAI. Each entry: provider_name -> (api_key_env, base_url_env). All base URLs must be se

Map project interval string to a futu KLType enum value. Lazy-imports futu so the module can be imported without futu installed. Unknown inte

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

Open an ``OpenSecTradeContext`` against the local OpenD gateway.

Return the ``TrdEnv`` enum value for this profile's environment.

Clip `content` to `limit` chars total, leaving room for the marker. The marker is reserved inside the limit (not appended on top) so the on-

Detect candlestick patterns: doji, hammer, and engulfing. Args: open_: Open price series. high: High price series. low: L

Check if this tool's dependencies are met. Override in subclasses to check for API keys, packages, etc. Tools that return False are e

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

Trip the halt switch for a live remote MCP connector profile.

Trip the kill switch — write the HALT sentinel (privileged). With no broker, trips the global switch (halts all brokers); with a broker, trip

Compute how long the loop should sleep before its next check. Args: jobs: The current job set. now_ms: The reference time in epoc

Per-run silence budget before a ``running`` run looks abandoned. With ``HeartbeatTimer`` wrapping ``registry.execute`` in the swarm w

Return True if the most recent Ctrl+C press was a "second press". A "second press" means the user pressed Ctrl+C twice within ``window_sec``

Return all built-in channel module names by scanning the package (zero imports).

Start a research goal. Args: **kwargs: Tool arguments from the model. Returns: JSON envelope with the goal s

Fetch margin-trading rows and return a JSON envelope string. Args: **kwargs: ``code`` (required, str) and ``days`` (optional int)

Parse Robinhood ``place_equity_order`` kwargs into a normalized :class:`OrderIntent`. Returns ``None`` (→ DENY) whenever the tool is not a recogn

Fetch normalized OHLCV data through the repository loader layer.

Fetch market data and return strict JSON.

Return the active config file path. Prefers the first existing candidate. If an explicit path is provided, returns that path directly. If no

Return the current goal for a session.

Read an env var with a backward-compatible alias fallback. Several env vars were renamed during the centralization effort (e.g. ``VIBE_TRADIN

Read all messages for a session. Args: session_id: Session ID. limit: Maximum number of messages to return.

Build an interval trigger firing every ``interval_ms`` ms. Args: interval_ms: Cadence in milliseconds; must be strictly positive.

Preserve Telegram's legacy id|username allowlist matching.

Load all tasks for the current run. Returns: List of SwarmTask sorted by ID.

Return a cached DataFrame for one payload, or ``None`` on any miss. Misses include: cache disabled, range not yet settled, entry absent, or a

Write one non-empty DataFrame to the cache; a no-op when not cacheable. Skips a disabled cache, an unsettled range, and empty/non-DataFrame resul

CLI entrypoint returning a process exit code.

Normalize remote MCP input schemas into OpenAI-compatible objects. Args: schema: Raw MCP input schema. Returns: A JSON Schem

Fetch and normalise feed items, dropping anything not yet knowable. Args: codes: Instrument codes to query. as_of: Po

Query a fundamental table and filter out rows unpublished by ``as_of``.

Read any supported document; dispatch by extension. Args: file_path: Absolute path to the file. pages: Only used for PDF — e.g. "

Sweep all run directories and reconcile each one. Returns IDs of runs whose status flipped from ``running`` to a terminal status — us

Record the current press, return True iff inside the window. Args: window_sec: Two-press window in seconds. Returns:

Return a Rich :class:`Text` row describing a single tool call. Args: name: Raw tool name (``get_financials``); pretty-printed in output.