MCP Server / horus flow
horus flow
Official Model Context Protocol (MCP) Server for Institutional Orderbook Intelligence. Empowers Claude & Cursor AI to read real-time Binance/Alpaca Microstructure data.
Transport
Dokumentation
🛑 Stop Predicting Candles. Start Measuring Gravity.
Retail traders use trailing indicators (RSI/MACD) to guess what the market will do based on the past. Horus uses Level 2 Orderbook physics, Tick imbalances, and 5-Second Flow Deltas to measure exactly what institutional whales are doing right now.
Horus doesn't ask "Are we overbought?". It measures gravitational pull and tells you: "Whales are spoofing the bid and aggressive takers are tearing through the ask. Liquidity is collapsing. Bailout now."
⚡ Why AI Agents (Claude, Cursor) Love Horus
If you hook up an AI Agent to a basic technical indicator feed, it gets confused by noise. If you feed an AI Agent Horus, it gets an institutional grade decision matrix.
Look at what Horus catches in real-time during a Liquidity Withdrawal / Flash Crash attempt:
{
"symbol": "BTCUSDT",
"signal": "LIQUIDITY_EVENT",
"confidence": 0.99,
"market_state": "DISTRIBUTION",
"risk": "EXTREME",
"description": "Liquidity withdrawn under price. Aggressive taking.",
"metrics": {
"bid_ask_ratio": 7.934,
"buy_sell_ratio": 0.393,
"delta_5s": -83040.05,
"whale_activity": true,
"large_sell_count": 4,
"delta_accel": 3.8,
"wall_side": "BID",
"wiseman_climate": {
"market_mode": "CHOP",
"health": "FRAGILE",
"confidence": 0.85
},
"flags": [
"GLOBAL_LIQUIDITY_EVENT",
"SPOOFING_DETECTED(wall=BID)"
]
},
"timestamp": 1776107738.975
}
The Institutional Alpha:
bid_ask_ratio: 7.934&wall_side: BID: Massive spoofed bid walls are placed by whales below the market to create fake support.buy_sell_ratio: 0.393: Horus sees through the spoofing (SPOOFING_DETECTEDflag). It measures real taker flow and discovers aggressive selling is devastating the orderbook.delta_accel: 3.8&whale_activity: true: Selling momentum accelerated by 3.8x natively tracking 4 major whale dumps within milliseconds.wiseman_climate: FRAGILE: Integrates perfectly with the overarching Horus SaaS macro brain, verifying that Bitcoin's holistic environment is fragile before attacking.- The Verdict: With a
0.99Confidence factor, the AI engine triggersLIQUIDITY_EVENT. It front-runs the ensuing 1-minute crash. This is Institutional Grade.
🏗️ Architecture
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 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
end
%% Engine
subgraph Core_Engine [The Physics Engine]
IC[Imbalance Calculator <br/> Bid/Ask Spread]:::compute
FC[Flow Calculator <br/> Tape Deltas]:::compute
Tkr[Prediction Tracker <br/> In-Memory Evaluator]:::compute
BC[Behavioral Court <br/> Spoofing & Liquidity Rules]:::compute
end
%% Output
subgraph Output_Layer [Data Shield & Delivery]
MCP[AI Agent MCP Context <br/> Context-Aware Prompts]:::mcp
API[FastAPI Client <br/> Safe Shielded Outputs]:::client
Dash[Real-time Dashboard <br/> Live Edge Proof]:::client
end
B --> IC
A --> IC
B --> FC
A --> FC
IC --> BC
FC --> BC
BC --> Tkr
Tkr -- "Validates 1M accuracy" --> BC
BC --> MCP
BC --> API
BC --> Dash
🚀 Quickstart for Trading Bots
Getting started with Horus takes less than 60 seconds. ⚡ Test Instantly: Download our Postman Collection to ping the API directly from your browser.
# 1. Install Dependencies
pip install -r requirements.txt
# 2. Fire up the Core Engine
uvicorn app.main:app --host 0.0.0.0 --port 8011
In your local Bot / Agent, simply pull the live flow for any Crypto or US Equity:
import requests
response = requests.get(
"http://127.0.0.1:8011/v1/flow/crypto/BTCUSDT",
headers={"X-API-Key": "your_secure_api_key"}
)
flow_data = response.json()
# The Zero-Human Decision Loop:
if flow_data['signal'] in ['EMERGENCY_DUMP', 'BAILOUT', 'LIQUIDITY_EVENT']:
print("Market gravity collapsing. Market selling all positions.")
# execute_market_sell()
🌐 Live Real-Time Dashboard
Horus comes with a stunning glass-morphism WebSocket dashboard out-of-the-box.
👁️ View the Matrix Live: https://api.horustek.pro/dash/
It features a Local Edge Proof Tracker that strictly measures 1-Minute Candle directional predictions generated by the Physics Engine with an openly transparent win rate. Let developers see the logic before they plug it into their agents.
Built with absolute precision for those who need to see the Matrix. — HORUS INTELLIGENCE 👁️
🏢 About Horus Tech Ltd
Horus Tech Ltd is an institutional-grade AI financial infrastructure provider headquartered in London. We specialize in building high-performance quantitative orderflow engines and Market Microstructure APIs tailored specifically for autonomous trading agents and hedge funds.
By bridging the gap between deep market physics (Level 2 depth, spoofing mechanics) and AI reasoning protocols (MCP), we empower algorithmic agents to make decisions based on institutional reality, not retail indicators.
🌐 Website: horustek.pro
📧 Contact: [email protected]