# π¦
Horus Flow MCP Server
[](https://smithery.ai/mcp/horustechltd/horus-flow-mcp)
[](https://glama.ai/mcp/servers/horustechltd/horus-flow-mcp)
[](https://github.com/horustechltd/horus-flow-mcp)
[](https://github.com/horustechltd/horus-flow-mcp)
[](https://opensource.org/licenses/MIT)
---
## π§ Why Horus? The AI Agent's "Nervous System"
In the world of autonomous trading, an AI Agent without real-time orderflow is like a pilot flying blind. Technical indicators (RSI, MACD) are **lagging echoes** of the past. **Horus** is the **Nervous System** that provides:
* **Proprioception:** Real-time awareness of market "muscle" (Orderbook Depth).
* **Reflexes:** Sub-second detection of institutional "pain" (Liquidity Collapses).
* **Intelligence:** A context-aware decision matrix that translates raw physics into actionable signals.
> "If you want your AI Agent to trade like a whale, you must give it the whale's eyes. Horus is that vision."
---
## π§ͺ Manus AI Audit: Live Performance Proof
Horus Flow MCP has been rigorously audited by **Manus AI** (an autonomous execution agent). The results confirm that Horus isn't just codeβit's a high-performance reality.
### **Audit Highlights (Live Test on BTCUSDT):**
* **Signal Accuracy:** Successfully detected **STRONG_SELL_PRESSURE** with a **0.85 Confidence Score**.
* **Physics Engine Validation:** Confirmed `bid_ask_ratio` of **0.156**, proving the engine's ability to read thin limit books and aggressive selling.
* **Zero-Hallucination Logic:** The MCP server correctly identified symbols in "Data Gathering" mode (e.g., SOLUSDT), preventing the AI from making false assumptions.
| Metric | Audit Result | Status |
| :--- | :--- | :--- |
| **Response Time** | Sub-millisecond (Local) | β
Verified |
| **Data Integrity** | L2 Binance Orderbook Sync | β
Verified |
| **AI Confidence** | 0.85+ on High-Vol Events | β
Verified |
---
## π° The $29 Arbitrage: Institutional Intelligence for the Price of a Lunch
Why pay thousands for institutional terminals when you can get the same **Microstructure Intelligence** for a fraction of the cost?
| Feature | **Horus Flow MCP** | Traditional Terminals |
| :--- | :--- | :--- |
| **Monthly Cost** | **$29 (Pro Plan)** | $150 - $2,000+ |
| **AI Integration** | **Native MCP (Plug & Play)** | Complex API / Manual |
| **Data Source** | Institutional L2 Feeds | Proprietary / Closed |
| **Decision Logic** | Physics-Based (Gravity) | Lagging Indicators |
---
## π Stop Predicting Candles. Start Measuring Gravity.
Retail traders use trailing indicators 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:
```json
{
"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:
1. **`bid_ask_ratio: 7.934` & `wall_side: BID`**: Massive spoofed bid walls are placed by whales below the market to create fake support.
2. **`buy_sell_ratio: 0.393`**: Horus sees through the spoofing (`SPOOFING_DETECTED` flag). It measures real *taker* flow and discovers aggressive selling is devastating the orderbook.
3. **`delta_accel: 3.8` & `whale_activity: true`**: Selling momentum accelerated by 3.8x natively tracking 4 major whale dumps within milliseconds.
4. **`wiseman_climate: FRAGILE`**: Integrates perfectly with the overarching Horus SaaS macro brain, verifying that Bitcoin's holistic environment is fragile before attacking.
5. **The Verdict**: With a `0.99` Confidence factor, the AI engine triggers `LIQUIDITY_EVENT`. It front-runs the ensuing 1-minute crash. **This is Institutional Grade.**
---
## ποΈ 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 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
L1/L2 Book]:::crypto_stream
A[Alpaca WSS
SIP Equities]:::equity_stream
end
%% Engine
subgraph Core_Engine [The Physics Engine]
IC[Imbalance Calculator
Bid/Ask Spread]:::compute
FC[Flow Calculator
Tape Deltas]:::compute
Tkr[Prediction Tracker
In-Memory Evaluator]:::compute
BC[Behavioral Court
Spoofing & Liquidity Rules]:::compute
end
%% Output
subgraph Output_Layer [Data Shield & Delivery]
MCP[AI Agent MCP Context
Context-Aware Prompts]:::mcp
API[FastAPI Client
Safe Shielded Outputs]:::client
Dash[Real-time Dashboard
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](./horus_postman_collection.json) to ping the API directly from your browser.
### **1. Fire up the Core Engine**
```bash
# Install Dependencies
pip install mcp httpx
# Set your RapidAPI Key (Required for the server to fetch live data)
export RAPIDAPI_KEY="your_actual_rapidapi_key"
# Run the SSE Server
python horus_mcp_public.py --transport sse --port 8011
```
In your local Bot / Agent, simply pull the live flow for any Crypto or US Equity using your RapidAPI key or Direct API key:
```python
import requests
response = requests.get(
"https://flow.horustek.pro/v1/flow/crypto/BTCUSDT",
headers={"X-API-Key": "your_secure_api_key"}
)
flow_data = response.json()
# The Zero-Human Decision Loop:
if flow_data.get('signal') in ['EMERGENCY_DUMP', 'BAILOUT', 'LIQUIDITY_EVENT']:
print(f"β οΈ {flow_data['symbol']} Market gravity collapsing. Executing Bailout.")
# execute_market_sell()
```
---
## π Live Real-Time Dashboard & Dev Portal
Horus comes with a stunning glass-morphism WebSocket dashboard and an interactive API documentation console out-of-the-box.
**ποΈ View the Developer Portal:** [https://flow.horustek.pro](https://flow.horustek.pro)
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** ποΈ
---
*mcp-name: pro.horustek/horus-flow-mcp*