Horus Flow Mcp

io.github.horustechltdPublished by GitHub account horustechltdv1.0.2Updated Oct 24, 2026

Institutional crypto & equity orderflow intelligence for AI trading agents.

The publisher's own server: Horus Flow Mcp

VerifiedSTDIODesktop onlyFinanceData & Analytics

Overview

AI-generated overview

Gives AI trading agents institutional crypto and equity orderflow intelligence, including a cognitive market verdict with trust scores and execution boundaries.

What you can do
Horus Flow MCP exposes tools that return market microstructure and intelligence data for crypto and US equities. Tools include get_horus_cortex for a consensus verdict with trust score, contradiction flags, execution boundaries and bot action multipliers, plus get_crypto_flow, get_equity_flow, scan_crypto_flow, get_liquidation_heatmap, get_cross_exchange_flow, get_composite_intelligence and get_full_market_intelligence. Outputs are intended to feed autonomous trading agents with regime state, orderflow metrics and risk directives.
When to use it
Use it when building or running AI trading agents that need orderflow, liquidation, cross-exchange and macro regime signals rather than lagging indicators. It suits quantitative workflows where an agent must decide position sizing or whether to stand aside.
Requirements
Runs locally as a Python stdio process (PyPI package horus-flow-mcp). Requires a RapidAPI key supplied via the RAPIDAPI_KEY environment variable, and network access to the Horus Flow service. Paid subscription tiers gate Level 3 and Level 4 intelligence and higher API quotas.
Before you install
Requires the RAPIDAPI_KEY secret; keep it out of shared configs. The service is a paid subscription with quotas, and higher tiers unlock the Cortex and intelligence endpoints. Outputs are trading signals and directives, not guarantees; agents acting on them can place real trades and lose money. Data is sent to a third-party market data service.

Installation

In SourceWeft

  1. Open Horus Flow Mcp in the dashboard and add it to a workspace.
  2. Enable the server for the chats that should use its tools.

Desktop only via STDIO. STDIO servers start a local process, so they need the SourceWeft desktop host.

Other MCP clients

Follow the launch instructions in the repository.

README

🦅 HORUS CORTEX & FLOW

The Cognitive Market Brain for Autonomous AI Trading Agents

[Glama Verified] [Glama Score] [AI Agents Listing Verified]

[FastMCP] [Status] [Python] [License]

Don't let your AI trading agents trade on lagging candlestick echoes. Give them the whale's eyes and an institutional cognitive mind.

🤖 The Zero-Human Decision Loop in Action

When you connect Claude Desktop, Cursor, or an autonomous LangChain / AutoGen agent to Horus Cortex, your agent stops hallucinating and begins executing with Wall Street risk rigor:

text
┌─────────────────────────────────────────────────────────────────────────────────────────────┐│  Autonomous Quant Agent (Claude 3.5 Sonnet / Cursor IDE) 🤖                                ││                                                                                             ││  Prompt: "BTC is pumping. Should we execute a 3x breakout long entry?"                      ││                                                                                             ││  AI Calls Tool: `get_horus_cortex()`                                                        ││  ◀  Horus Cortex Returns:                                                                   ││     {                                                                                       ││       "regime_state": "TRANSITION",                                                         ││       "trust_score": 26.5,                                                                  ││       "action_policy": {                                                                    ││         "directive": "Deteriorating Transition: Capital Preservation Lock (0.0x)",          ││         "trend_allowed": false,                                                             ││         "ignition_allowed": false                                                           ││       },                                                                                    ││       "market_vitals": { "taker_ratio": 0.24, "global_ignition": 0.08 },                    ││       "active_contradictions": [                                                            ││         { "id": "BULLISH_PRICE_vs_HOLLOW_BREADTH", "severity": "MEDIUM" }                   ││       ],                                                                                    ││       "execution_boundaries": {                                                             ││         "invalidation_support": 77052.0,                                                    ││         "breakout_resistance": 78608.0                                                      ││       }                                                                                     ││     }                                                                                       ││                                                                                             ││  AI Final Output:                                                                           ││  "⛔ TRADE ABORTED — CAPITAL PRESERVATION ENFORCED.                                        ││   Although spot price is making local highs, Horus Cortex flags a severe divergence:        ││   1. Taker Buy/Sell ratio collapsed to 0.24 (Aggressive seller absorption).                 ││   2. Global market breadth is dormant (0.08) indicating an isolated, hollow squeeze.        ││   3. Cortex Trust Score is 26.5/100 with active trend locks enabled.                        ││   Action: Standing aside. Re-evaluating only if price confirms above $78,608 with volume."  │└─────────────────────────────────────────────────────────────────────────────────────────────┘

🛑 Stop Predicting Candles. Start Measuring Gravity.

Retail traders rely on lagging indicators (RSI, MACD, Moving Averages) which calculate what has already happened.

Horus is predictive, not reactive:

  1. Level 1-2 Physics (The Eye): Measures sub-second limit orderbook depth, spoofed liquidity walls, and aggressive taker execution delta before candlesticks print.
  2. Level 3 Forensics (The Radar): Tracks Liquidation Cascades (Gravity Direction) and Spot vs. Futures Speculation Ratios.
  3. Level 4 Cortex (The Mind): Synthesizes 7 independent evidence families with a real-time Contradiction Engine to output machine-executable position sizing multipliers and USD invalidation boundaries.

🏗️ Architecture

mermaid
graph TD    %% Styling    classDef crypto_stream fill:#F3BA2F,stroke:#000,color:#000,stroke-width:2px;    classDef equity_stream fill:#000,stroke:#09b533,color:#09b533,stroke-width:2px;    classDef compute fill:#1A1F36,stroke:#00D6FF,color:#fff,stroke-width:2px;    classDef level3 fill:#1A1F36,stroke:#FF6B00,color:#fff,stroke-width:2px;    classDef cortex fill:#4A154B,stroke:#FFD700,color:#fff,stroke-width:3px;    classDef mcp fill:#632CA6,stroke:#fff,color:#fff,stroke-width:2px;    classDef client fill:#FF3366,stroke:#fff,color:#fff,stroke-width:2px;
    %% Ingestion    subgraph Data_Pipelines [Websocket Ingestion]        B[Binance WSS <br/> L1/L2 Book]:::crypto_stream        A[Alpaca WSS <br/> IEX Equities - sample]:::equity_stream        BF[Binance Futures <br/> OI / Funding / Liquidations]:::crypto_stream    end
    %% Level 1-2 Engine    subgraph Core_Engine [Level 1-2: Microstructure Physics]        IC[Imbalance Calculator <br/> Bid/Ask Walls]:::compute        FC[Flow Calculator <br/> Tape Deltas]:::compute        BC[Behavioral Court <br/> Spoofing & Absorption Rules]:::compute    end
    %% Level 3 Intelligence    subgraph L3_Engine [Level 3: Institutional Intelligence]        LH[Liquidation Heatmap <br/> Gravity Zones]:::level3        XF[Cross-Exchange Flow <br/> Spot ↔ Futures]:::level3        CI[Composite Intelligence <br/> 4-Layer Verdict]:::level3    end
    %% Level 4 Cognitive Cortex    subgraph L4_Cortex [Level 4: The Sovereign Cognitive Cortex]        HC[Horus Cortex Symphony 3.0 <br/> 7 Forensic Families + Contradiction Engine]:::cortex        TS[Penalized Trust Score 0-100]:::compute        EB[Execution Boundaries USD]:::compute        AP[Action Policy Multipliers for Bots]:::compute    end
    %% Output    subgraph Output_Layer [Data Delivery & Agent Integration]        MCP[AI Agent FastMCP Server <br/> 8 Sovereign Tools]:::mcp        API[FastAPI REST Gateway <br/> 13 Endpoints]:::client        Dash[Real-Time Portal <br/> Live Microstructure]:::client    end
    B --> IC    A --> IC    B --> FC    A --> FC    BF --> LH    BF --> XF
    IC --> BC    FC --> BC    LH --> CI    XF --> CI    BC --> CI
    CI --> HC    HC --> TS    HC --> EB    HC --> AP
    HC --> MCP    HC --> API    BC --> Dash

📡 Complete API Catalog

Level 1-2: Orderflow Microstructure

EndpointMethodDescriptionTier
/v1/flow/crypto/{symbol}GETOrder book imbalance (top 20 levels) and taker flow from Binance's public stream. Any TRADING spot pairFree: all pairs
/v1/flow/crypto/{symbol}/historyGETSnapshots every 15s with price, deltas and ratiosBuilder: 60 min · Pro: 24 h
/v1/flow/equity/{symbol}GETUS equity flow from the IEX feed (about 3% of US volume, a sample)Builder
/v1/flow/equity/macro-blocksGETSPY buy/sell skew and IEX prints of $200k or moreFree
/v1/statusGETFreshness and uptime of every data source (no key)Public

Level 3: Forensic Market Intelligence

EndpointMethodDescriptionTier
/v1/intelligence/climateGETWiseMan BTC regime and healthBuilder
/v1/intelligence/ignitionsGETVolatility breakout scanner across ~750 assets, refreshed every minuteBuilder
/v1/intelligence/liquidation-heatmapGETCrowd positioning vs its 24h median and estimated liquidation levels (10 majors)Pro
/v1/intelligence/cross-exchange-flowGETFutures/spot volume vs its 7-day median, premium, funding and OI across Binance, Bybit and OKXPro
/v1/intelligence/compositeGET0-100 score from climate, ignition, positioning and futures/spot flowPro
/v1/intelligence/market-intelligenceGETAll of the above for 10 majors in one callPro

Every Level 3 document carries a method field with its exact formula. Endpoints return 503 data_stale instead of serving data older than their freshness limit.

Level 4: The Sovereign Cognitive Cortex

EndpointMethodDescriptionTier
/v1/intelligence/cortexGETRegime state, trust score, contradictions, execution boundaries and action policyPro
/v1/intelligence/maestroGETBackward-compatible alias for the Cortex endpointPro

Agent Layer

EndpointMethodDescriptionPlan
/v1/book/pressureGETThe spot order book of 30 Binance pairs in one call (top-five bid share, bid/ask ratio, 30 s taker flow), with its measured link to the next minuteFree: 3 rows · Trader: 30
/v1/scanGETRank about 250 Binance perpetuals in one call: buyers or sellers in control, volume surge, breakout candidates, crowded funding, or custom filtersFree: 3 rows · Builder: 100
/v1/track-recordGETLive hit rate of every signal at 1/5/15/30 min, by signal, symbol and confidencePublic
/v1/track-record/signalsGETPoint-in-time ledger: what Horus said, at what price, and what happened next (since Aug 2026)Builder
/v1/eventsGETChanges since your last check: liquidation cascades, regime changes, new US halts, and moreBuilder
/v1/events/streamGETThe same events as Server-Sent EventsBuilder
/v1/webhooksPOST GET DELETESigned webhooks for any event typePro
/v1/equity/sessionGETUS session phase, holidays, early closes, next open/close, active haltsPublic
/v1/equity/haltsGETAll US trading halts published today, with plain-language reasonsPublic
/v1/cross-assetGETBTC order flow next to SPY, QQQ, COIN, MSTR and IBIT flowBuilder
/v1/statusGETFreshness and uptime of every data sourcePublic

Every directional flow reading carries a reliability block with its measured hit rate. Add ?view=compact to /v1/flow/crypto/{symbol} for a token-light answer.

🤖 Connect Your AI Agent

Remote MCP server (recommended)

https://flow.horustek.pro/mcp (Streamable HTTP).

  • RapidAPI subscribers: send your RapidAPI key as X-RapidAPI-Key: <key>. Calls go through RapidAPI, so your RapidAPI plan and quota apply. Subscribe on RapidAPI.
  • Horus keys: X-API-Key: <key> or Authorization: Bearer <key>.
  • No key: free tier: order flow for any pair, the public track record, US session context, the first 3 scanner results and service status.

Claude Code:

bash
claude mcp add --transport http horus-flow https://flow.horustek.pro/mcp --header "X-RapidAPI-Key: YOUR_RAPIDAPI_KEY"

Any MCP client that supports remote servers:

json
{  "mcpServers": {    "horus-flow": {      "type": "http",      "url": "https://flow.horustek.pro/mcp",      "headers": { "X-RapidAPI-Key": "YOUR_RAPIDAPI_KEY" }    }  }}

Tools (all read-only, compact JSON with an output schema)

ToolWhat it answersPlan
get_book_pressureWhat does the order book say right now across 30 majors, and how much has that told about the next minuteFree (3 rows) / Trader
scan_marketWhere are buyers, sellers or volume surging across about 250 markets right nowFree (3 rows) / Builder
get_crypto_flowLive order flow for one pair, with the signal's measured hit rateFree
get_flow_historyIs pressure building or fading over the last hourBuilder
get_market_overviewClimate, Cortex and 10 majors in one callPro
get_derivativesFunding, OI across Binance/Bybit/OKX, crowd positioning, liquidation levelsPro
get_cortexRegime, trust score, contradictions, invalidation and breakout levelsPro
get_ignitionsBreakout scanner across ~750 assetsBuilder
get_track_recordHow often each signal was rightFree
get_signal_ledgerHistorical signals with outcomes, for backtestingBuilder
get_recent_eventsWhat changed since your last checkBuilder
get_us_market_sessionCan US stocks be traded right now, and which are haltedFree
get_cross_assetAre crypto and US equities risk-on together or divergingBuilder
get_equity_flowUS stock flow from the IEX sampleBuilder
get_service_statusFreshness of every data sourceFree

Readings are context with a measured track record, not trade instructions. Many signals score close to a coin flip; the reliability field says so.

Local stdio server (PyPI)

pip install horus-flow-mcp and set RAPIDAPI_KEY to use the RapidAPI listing from a local MCP client.

Webhook signatures

python
import hmac, hashlibdef verify(secret: str, timestamp: str, body: bytes, signature: str) -> bool:    expected = "sha256=" + hmac.new(secret.encode(), timestamp.encode() + b"." + body, hashlib.sha256).hexdigest()    return hmac.compare_digest(expected, signature)# timestamp = request.headers["X-Horus-Timestamp"], signature = request.headers["X-Horus-Signature"]

⚡ 60-Second Quant Bot Quickstart (Python)

python
import requests
HEADERS = {"X-API-Key": "your_horus_api_key"}BASE_URL = "https://flow.horustek.pro"
# 1. Query Horus Cortex for the Sovereign Market Stateres = requests.get(f"{BASE_URL}/v1/intelligence/cortex", headers=HEADERS).json()
trust_score = res["trust_score"]policy = res["action_policy"]boundaries = res["execution_boundaries"]
print(f"🧠 Market State: {res['regime_state']} | Trust: {trust_score}/100")print(f"🛡️ Action Directive: {policy['directive']}")print(f"🎯 Support Invalidation: ${boundaries['invalidation_support']:,.0f} | Breakout Target: ${boundaries['breakout_resistance']:,.0f}")
# 2. Enforce Autonomous Risk Rulesif not policy["trend_allowed"]:    print("⛔ Trade Rejected: Cortex forbids trend breakouts during transitions.")else:    position_multiplier = policy["trend_multiplier"]    # execute_trade(multiplier=position_multiplier, stop_loss=boundaries["invalidation_support"])

💎 Plans

FeatureFreeBuilder / Trader ($29/mo)Pro ($149/mo)Institutional ($499/mo)
Crypto order flowAny Binance spot pairAny Binance spot pairAny Binance spot pairAny Binance spot pair
Flow history–60 minutes24 hours24 hours
Track record and US session context✅✅✅✅
Climate, ignitions, cross-asset, US equities (IEX sample)–✅✅✅
Events (polling and SSE), signal ledger–✅✅✅
Derivatives (10 majors, Binance + Bybit + OKX), composite, Cortex––✅✅
Signed webhooks––✅✅
Rate limit30/min120/min300/min600/min
Remote MCP server✅✅✅✅

Live status and uptime: flow.horustek.pro/status.html

🌐 Live Real-Time Dashboard

Explore the live institutional orderflow visualizer at flow.horustek.pro/dash/.

Engineered with mathematical rigor for Autonomous AI Agents and Quantitative Traders.
© 2026 Horus Tech Ltd. 🦅

mcp-name: pro.horustek/horus-flow-mcp

Source: README.md at commit 12ac376

Tools

0
SourceWeft has not started this package in its sandbox yet, so its tools are not known.

Version history

1
  1. v1.0.2LatestSep 16, 2026

Score

50% of the applicable checks met

How complete this listing is, computed from the registry entry, the endpoint and public sources. Not a rating of the server and not a statement that it is safe or working today: reachability is a dated check, and no installs or reviews go into the score.

  • Reached in the last 30 days25 pts

    Keep the endpoint answering the MCP handshake; SourceWeft probes it every 30 days.

  • Auth declared10 pts

    Declare the credential headers in the registry entry, or keep the endpoint answering the probe so its auth can be classified.

  • Tools listed15 pts

    Answer tools/list without a credential, or ship a package that starts in a sandbox without one.

  • DescriptionRequired15 pts
  • Logo10 pts
  • Documentation15 pts
  • License10 pts

Other Horustek integrations

Horus Flow Mcp

pro.horustekOfficial publisher

Remote MCP server giving assistants live crypto order flow, derivatives positioning, US equity flow and market-regime readings with measured hit rates.

Streamable HTTPWeb executable
Finance14 toolsOct 25, 2026