Back to Directory/Developer Tools

io.github.horustechltd/horus-flow-mcp

Institutional crypto & equity orderflow intelligence for AI trading agents.

Developer ToolsPythonv1.0.2

πŸ¦… HORUS CORTEX & FLOW

The Cognitive Market Brain for Autonomous 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.


πŸ€– 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 CortexβŒβŒβœ… Full Cognitive Brainβœ… Full 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. πŸ¦…

Installation

Source-derived launch command. Check the maintainer’s required arguments and credentials before running:

bash
uvx horus-flow-mcp

Set up in your AI client

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

json
{
  "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 reference

Package

horus-flow-mcppypi

Compatible MCP Clients

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

  • Claude Desktop~/Library/Application Support/Claude/claude_desktop_config.jsonRestart Claude Desktop completely for changes to take effect.
  • Cursor~/.cursor/mcp.jsonRestart Cursor for changes to take effect.
  • VS Code.vscode/mcp.jsonReload VS Code window for changes to take effect.
  • Windsurf~/.codeium/windsurf/mcp_config.jsonRestart Windsurf for changes to take effect.
  • Claude Code.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.

Learn More