Institutional crypto & equity orderflow intelligence for AI trading agents.
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. π¦
Source-derived launch command. Check the maintainerβs required arguments and credentials before running:
uvx horus-flow-mcpMerge this template into ~/Library/Application Support/Claude/claude_desktop_config.json. Keep existing servers. Add any arguments, credentials, and permissions required by the maintainer; this template has not been install-tested.
{
"mcpServers": {
"io-github-horustechltd-horus-flow-mcp": {
"command": "uvx",
"args": [
"horus-flow-mcp"
]
}
}
}Restart Claude Desktop completely for changes to take effect. Confirm the server appears connected in the clientβs tool list, then try a read-only example from its documentation.
Claude Desktop setup referencehorus-flow-mcppypiio.github.horustechltd/horus-flow-mcp works with any MCP-compatible client. Copy the config snippet from the Configuration section above and add it to the file shown for your client, then restart the application.
~/Library/Application Support/Claude/claude_desktop_config.jsonRestart Claude Desktop completely for changes to take effect.~/.cursor/mcp.jsonRestart Cursor for changes to take effect..vscode/mcp.jsonReload VS Code window for changes to take effect.~/.codeium/windsurf/mcp_config.jsonRestart Windsurf for changes to take effect..mcp.jsonSave at the project root, then start Claude Code in that project and review the MCP server approval prompt. Keep real credentials out of shared files.