Odel
horus flow mcp

horus flow mcp

Local
@horustechltd2PythonMITUpdated 3 days ago

Institutional crypto & equity orderflow intelligence for AI trading agents.

🦅 HORUS CORTEX & FLOW

The Cognitive Market Brain for Autonomous AI Trading Agents

Glama Verified Glama Score

A-Tier FastMCP Latency 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:

┌─────────────────────────────────────────────────────────────────────────────────────────────┐
│  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

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

📡 Complete API Catalog

Level 1-2: Orderflow Microstructure

EndpointMethodDescriptionTier
/v1/flow/crypto/{symbol}GETReal-time orderbook imbalance, taker flow, and whale intentFree / Trader
/v1/flow/crypto/{symbol}/historyGETFlow history (1-60 min lookback) for backtestingTrader
/v1/flow/equity/{symbol}GETUS Equity institutional tape (SIP)Trader
/v1/flow/equity/macro-blocksGETSPY macro block trades & sentimentTrader

Level 3: Forensic Market Intelligence

EndpointMethodDescriptionTier
/v1/intelligence/climateGETWiseMan macro market regime & health scoreTrader
/v1/intelligence/ignitionsGETVolatility Breakout Engine (VBE) scannerTrader
/v1/intelligence/liquidation-heatmapGETLiquidation cascade zones & gravity vectorPro ($149)
/v1/intelligence/cross-exchange-flowGETSpot vs Futures volume ratio & OI velocityPro ($149)
/v1/intelligence/compositeGET4-layer fused composite score (0-100)Pro ($149)
/v1/intelligence/market-intelligenceGETComplete macro dashboard for all assets in one callPro ($149)

Level 4: The Sovereign Cognitive Cortex

EndpointMethodDescriptionTier
/v1/intelligence/cortexGET🧠 The Master Brain: 7 evidence families, trust score, contradiction engine, execution boundaries & action policyPro ($149) / Institutional
/v1/intelligence/maestroGETBackward-compatible alias for the Cortex endpointPro ($149) / Institutional

🤖 Model Context Protocol (MCP) Setup

Horus provides an official FastMCP server compatible with Claude Desktop, Cursor IDE, and any MCP client:

1. Claude Desktop Configuration

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"
      }
    }
  }
}

2. Available Sovereign Tools for AI Agents

  1. get_horus_cortex(): 🧠 Primary Cognitive Tool — Full consensus, trust score (0-100), boundaries ($), and bot action multipliers.
  2. get_crypto_flow(symbol): Sub-second L2 orderflow and aggressive trade delta.
  3. get_equity_flow(symbol): US Equity block trades and tape prints.
  4. scan_crypto_flow(symbols): Batch scanner for active whale positioning.
  5. get_liquidation_heatmap(symbol): Liquidation cascade zones and gravitational pull.
  6. get_cross_exchange_flow(symbol): Spot vs Futures volume ratio and funding rate risk.
  7. get_composite_intelligence(symbol): 4-layer composite verdict (0-100).
  8. get_full_market_intelligence(): Macro overview of all monitored instruments.

⚡ 60-Second Quant Bot Quickstart (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"])

💎 Institutional Subscription Tiers

FeatureExplorer (Free)Trader ($49/mo)Professional ($149/mo)Institutional ($499/mo)
Daily API Quota100 calls/day1,000 calls/day5,000 calls/dayUnlimited
Microstructure L2 FlowTop 3 SymbolsAll Crypto SymbolsAll Crypto + US EquityAll Instruments
Whale Tape & ImbalancesBasicReal-TimeReal-Time Sub-msPriority Dedicated Socket
Level 3 Intelligence✅ Full Access✅ Full Access
🧠 Level 4 Horus CortexFull Cognitive BrainFull Cognitive Brain
Autonomous Bot Multipliers
AI Agent MCP ServerCommunityCommunity✅ Full FastMCP Access✅ Dedicated Private Server
SLA & SupportCommunityStandardPriority24/7 Dedicated Quant Desk

🌐 Live Real-Time Dashboard

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. 🦅