๐Ÿฆ… 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
L1/L2 Book]:::crypto_stream A[Alpaca WSS
IEX Equities - sample]:::equity_stream BF[Binance Futures
OI / Funding / Liquidations]:::crypto_stream end %% Level 1-2 Engine subgraph Core_Engine [Level 1-2: Microstructure Physics] IC[Imbalance Calculator
Bid/Ask Walls]:::compute FC[Flow Calculator
Tape Deltas]:::compute BC[Behavioral Court
Spoofing & Absorption Rules]:::compute end %% Level 3 Intelligence subgraph L3_Engine [Level 3: Institutional Intelligence] LH[Liquidation Heatmap
Gravity Zones]:::level3 XF[Cross-Exchange Flow
Spot โ†” Futures]:::level3 CI[Composite Intelligence
4-Layer Verdict]:::level3 end %% Level 4 Cognitive Cortex subgraph L4_Cortex [Level 4: The Sovereign Cognitive Cortex] HC[Horus Cortex Symphony 3.0
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
8 Sovereign Tools]:::mcp API[FastAPI REST Gateway
13 Endpoints]:::client Dash[Real-Time Portal
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 | Endpoint | Method | Description | Tier | |:---|:---|:---|:---| | `/v1/flow/crypto/{symbol}` | `GET` | Order book imbalance (top 20 levels) and taker flow from Binance's public stream. Any TRADING spot pair | Free: all pairs | | `/v1/flow/crypto/{symbol}/history` | `GET` | Snapshots every 15s with price, deltas and ratios | Builder: 60 min ยท Pro: 24 h | | `/v1/flow/equity/{symbol}` | `GET` | US equity flow from the IEX feed (about 3% of US volume, a sample) | Builder | | `/v1/flow/equity/macro-blocks` | `GET` | SPY buy/sell skew and IEX prints of $200k or more | Free | | `/v1/status` | `GET` | Freshness and uptime of every data source (no key) | Public | ### Level 3: Forensic Market Intelligence | Endpoint | Method | Description | Tier | |:---|:---|:---|:---| | `/v1/intelligence/climate` | `GET` | WiseMan BTC regime and health | Builder | | `/v1/intelligence/ignitions` | `GET` | Volatility breakout scanner across ~750 assets, refreshed every minute | Builder | | `/v1/intelligence/liquidation-heatmap` | `GET` | Crowd positioning vs its 24h median and estimated liquidation levels (10 majors) | Pro | | `/v1/intelligence/cross-exchange-flow` | `GET` | Futures/spot volume vs its 7-day median, premium, funding and OI across Binance, Bybit and OKX | Pro | | `/v1/intelligence/composite` | `GET` | 0-100 score from climate, ignition, positioning and futures/spot flow | Pro | | `/v1/intelligence/market-intelligence` | `GET` | All of the above for 10 majors in one call | Pro | 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 | Endpoint | Method | Description | Tier | |:---|:---|:---|:---| | `/v1/intelligence/cortex` | `GET` | Regime state, trust score, contradictions, execution boundaries and action policy | Pro | | `/v1/intelligence/maestro` | `GET` | Backward-compatible alias for the Cortex endpoint | Pro | --- ### Agent Layer | Endpoint | Method | Description | Plan | |:---|:---|:---|:---| | `/v1/scan` | `GET` | Rank about 250 Binance perpetuals in one call: buyers or sellers in control, volume surge, breakout candidates, crowded funding, or custom filters | Free: 3 rows ยท Builder: 100 | | `/v1/track-record` | `GET` | Live hit rate of every signal at 1/5/15/30 min, by signal, symbol and confidence | Public | | `/v1/track-record/signals` | `GET` | Point-in-time ledger: what Horus said, at what price, and what happened next (since Aug 2026) | Builder | | `/v1/events` | `GET` | Changes since your last check: liquidation cascades, regime changes, new US halts, and more | Builder | | `/v1/events/stream` | `GET` | The same events as Server-Sent Events | Builder | | `/v1/webhooks` | `POST` `GET` `DELETE` | Signed webhooks for any event type | Pro | | `/v1/equity/session` | `GET` | US session phase, holidays, early closes, next open/close, active halts | Public | | `/v1/equity/halts` | `GET` | All US trading halts published today, with plain-language reasons | Public | | `/v1/cross-asset` | `GET` | BTC order flow next to SPY, QQQ, COIN, MSTR and IBIT flow | Builder | | `/v1/status` | `GET` | Freshness and uptime of every data source | Public | 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: `. Calls go through RapidAPI, so your RapidAPI plan and quota apply. [Subscribe on RapidAPI](https://rapidapi.com/horus-tech-ltd-horus-tech-ltd-default/api/horus-flow-intelligence). - **Horus keys:** `X-API-Key: ` or `Authorization: Bearer `. - **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) | Tool | What it answers | Plan | |:---|:---|:---| | `scan_market` | Where are buyers, sellers or volume surging across about 250 markets right now | Free (3 rows) / Builder | | `get_crypto_flow` | Live order flow for one pair, with the signal's measured hit rate | Free | | `get_flow_history` | Is pressure building or fading over the last hour | Builder | | `get_market_overview` | Climate, Cortex and 10 majors in one call | Pro | | `get_derivatives` | Funding, OI across Binance/Bybit/OKX, crowd positioning, liquidation levels | Pro | | `get_cortex` | Regime, trust score, contradictions, invalidation and breakout levels | Pro | | `get_ignitions` | Breakout scanner across ~750 assets | Builder | | `get_track_record` | How often each signal was right | Free | | `get_signal_ledger` | Historical signals with outcomes, for backtesting | Builder | | `get_recent_events` | What changed since your last check | Builder | | `get_us_market_session` | Can US stocks be traded right now, and which are halted | Free | | `get_cross_asset` | Are crypto and US equities risk-on together or diverging | Builder | | `get_equity_flow` | US stock flow from the IEX sample | Builder | | `get_service_status` | Freshness of every data source | Free | 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, hashlib def 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 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"]) ``` --- ## ๐Ÿ’Ž Plans | Feature | Free | Builder / Trader ($29/mo) | Pro ($149/mo) | Institutional ($499/mo) | |:---|:---:|:---:|:---:|:---:| | Crypto order flow | Any Binance spot pair | Any Binance spot pair | Any Binance spot pair | Any Binance spot pair | | Flow history | โ€“ | 60 minutes | 24 hours | 24 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 limit | 30/min | 120/min | 300/min | 600/min | | Remote MCP server | โœ… | โœ… | โœ… | โœ… | Live status and uptime: [flow.horustek.pro/status.html](https://flow.horustek.pro/status.html) --- ## ๐ŸŒ Live Real-Time Dashboard Explore the live institutional orderflow visualizer at [flow.horustek.pro/dash/](https://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*