
Connects Claude to institutional-grade orderflow data from Binance and Alpaca, exposing real-time whale detection, spoofing alerts, and liquidation heatmaps through a physics-based engine. The MCP surfaces Level 2 orderbook imbalances, 5-second tape deltas, and bid/ask ratios with sub-second latency, returning structured signals with confidence scores and market state classifications. Requires a RapidAPI key for the Horus Flow Intelligence API. Reach for this when you need your AI to make trading decisions based on actual institutional flow rather than lagging technical indicators. The Python server runs over stdio and delivers the same microstructure data that HFT firms pay thousands for, packaged for autonomous agent consumption at $29/month.
Don't let your AI trading agents trade on lagging candlestick echoes. Give them the whale's eyes and an institutional cognitive mind.
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:
┌─────────────────────────────────────────────────────────────────────────────────────────────┐
│ 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." │
└─────────────────────────────────────────────────────────────────────────────────────────────┘
Retail traders rely on lagging indicators (RSI, MACD, Moving Averages) which calculate what has already happened.
Horus is predictive, not reactive:
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 [Sub-Millisecond Websocket Ingestion]
B[Binance WSS <br/> L1/L2 Book]:::crypto_stream
A[Alpaca WSS <br/> SIP Equities]:::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
| Endpoint | Method | Description | Tier |
|---|---|---|---|
/v1/flow/crypto/{symbol} | GET | Real-time orderbook imbalance, taker flow, and whale intent | Free / Trader |
/v1/flow/crypto/{symbol}/history | GET | Flow history (1-60 min lookback) for backtesting | Trader |
/v1/flow/equity/{symbol} | GET | US Equity institutional tape (SIP) | Trader |
/v1/flow/equity/macro-blocks | GET | SPY macro block trades & sentiment | Trader |
| Endpoint | Method | Description | Tier |
|---|---|---|---|
/v1/intelligence/climate | GET | WiseMan macro market regime & health score | Trader |
/v1/intelligence/ignitions | GET | Volatility Breakout Engine (VBE) scanner | Trader |
/v1/intelligence/liquidation-heatmap | GET | Liquidation cascade zones & gravity vector | Pro ($149) |
/v1/intelligence/cross-exchange-flow | GET | Spot vs Futures volume ratio & OI velocity | Pro ($149) |
/v1/intelligence/composite | GET | 4-layer fused composite score (0-100) | Pro ($149) |
/v1/intelligence/market-intelligence | GET | Complete macro dashboard for all assets in one call | Pro ($149) |
| Endpoint | Method | Description | Tier |
|---|---|---|---|
/v1/intelligence/cortex | GET | 🧠 The Master Brain: 7 evidence families, trust score, contradiction engine, execution boundaries & action policy | Pro ($149) / Institutional |
/v1/intelligence/maestro | GET | Backward-compatible alias for the Cortex endpoint | Pro ($149) / Institutional |
Horus provides an official FastMCP server compatible with Claude Desktop, Cursor IDE, and any MCP client:
Add this to your claude_desktop_config.json:
{
"mcpServers": {
"horus-cortex": {
"command": "python3",
"args": ["/absolute/path/to/horus_flow_api/horus_mcp.py", "--transport", "stdio"],
"env": {
"FLOW_API_KEY": "YOUR_HORUS_API_KEY"
}
}
}
}
get_horus_cortex(): 🧠 Primary Cognitive Tool — Full consensus, trust score (0-100), boundaries ($), and bot action multipliers.get_crypto_flow(symbol): Sub-second L2 orderflow and aggressive trade delta.get_equity_flow(symbol): US Equity block trades and tape prints.scan_crypto_flow(symbols): Batch scanner for active whale positioning.get_liquidation_heatmap(symbol): Liquidation cascade zones and gravitational pull.get_cross_exchange_flow(symbol): Spot vs Futures volume ratio and funding rate risk.get_composite_intelligence(symbol): 4-layer composite verdict (0-100).get_full_market_intelligence(): Macro overview of all monitored instruments.import requests
HEADERS = {"X-API-Key": "your_horus_api_key"}
BASE_URL = "https://flow.horustek.pro"
# 1. Query Horus Cortex for the Sovereign Market State
res = 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 Rules
if 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"])
| Feature | Explorer (Free) | Trader ($49/mo) | Professional ($149/mo) | Institutional ($499/mo) |
|---|---|---|---|---|
| Daily API Quota | 100 calls/day | 1,000 calls/day | 5,000 calls/day | Unlimited |
| Microstructure L2 Flow | Top 3 Symbols | All Crypto Symbols | All Crypto + US Equity | All Instruments |
| Whale Tape & Imbalances | Basic | Real-Time | Real-Time Sub-ms | Priority Dedicated Socket |
| Level 3 Intelligence | ❌ | ❌ | ✅ Full Access | ✅ Full Access |
| 🧠 Level 4 Horus Cortex | ❌ | ❌ | ✅ Full Cognitive Brain | ✅ Full Cognitive Brain |
| Autonomous Bot Multipliers | ❌ | ❌ | ✅ | ✅ |
| AI Agent MCP Server | Community | Community | ✅ Full FastMCP Access | ✅ Dedicated Private Server |
| SLA & Support | Community | Standard | Priority | 24/7 Dedicated Quant Desk |
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. 🦅
RAPIDAPI_KEY*secretYour RapidAPI key for Horus Flow Intelligence