pro.horustekPublished by horustek.proOfficial publisherv3.1.0Updated Oct 25, 2026
Crypto order flow, cross-venue derivatives and US market context for AI agents, with a track record.
Remote MCP server giving assistants live crypto order flow, derivatives positioning, US equity flow and market-regime readings with measured hit rates.
Web executable via Streamable HTTP. Remote servers run from the web runtime once configured in a workspace.
Paste this prompt into Claude Code, Codex, Cursor or another agent — or into SourceWeft chat. The agent reads this server's install guide, shows you its publisher, endpoint and sign-in, and adds it to your client once you agree. Keys never go into a command.
Read https://sourceweft.com/mcp/pro.horustek%2Fhorus-flow-mcp/install.md and connect the MCP server it describes to my client. Before changing any config, show me its publisher, endpoint and sign-in method and wait for my OK. Never put an API key in a command or in a file I would commit; ask me where it should come from.Add this to your client's mcpServers config.
{
"mcpServers": {
"horus-flow": {
"type": "http",
"url": "https://flow.horustek.pro/mcp"
}
}
}[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.
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:
Retail traders rely on lagging indicators (RSI, MACD, Moving Averages) which calculate what has already happened.
Horus is predictive, not reactive:
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.
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.
https://flow.horustek.pro/mcp (Streamable HTTP).
X-RapidAPI-Key: <key>. Calls go through RapidAPI, so your RapidAPI plan and quota apply. Subscribe on RapidAPI.X-API-Key: <key> or Authorization: Bearer <key>.Claude Code:
Any MCP client that supports remote servers:
Readings are context with a measured track record, not trade instructions. Many signals score close to a coin flip; the reliability field says so.
pip install horus-flow-mcp and set RAPIDAPI_KEY to use the RapidAPI listing from a local MCP client.
Live status and uptime: flow.horustek.pro/status.html
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. 🦅
mcp-name: pro.horustek/horus-flow-mcp
Source: README.md at commit 12ac376
Live order flow for one Binance spot pair: signal, direction, 30-second buy/sell delta in USD, order book depth ratio, large sells in the last 5 minutes, and the signal's measured hit rate. Use for "what is the market doing right now in X". Symbols like BTCUSDT, ETHUSDT, SOLUSDT.
symbolRecent order-flow snapshots (every 15s) for a crypto pair with a summary: signal counts, price change, cumulative 30s delta. Use to see whether pressure is building or fading. minutes up to 60 (BUILDER / RapidAPI PRO) or 1440 (PRO / RapidAPI ULTRA); free plans get the last 15 minutes.
symbolminutesOne call for the crypto market: BTC climate, ignition regime, Cortex regime, and for 10 majors the composite score, derivatives positioning (crowd vs its 24h median, liquidation gravity), futures/spot activity and open interest across Binance, Bybit and OKX. Full: PRO / RapidAPI ULTRA; lower plans get a BTCUSDT preview.
Takes no parameters.
Derivatives positioning for one of 10 majors: funding (per venue and OI-weighted), open interest and its 10/30-minute change, futures/spot volume vs its 7-day median, crowd long/short vs its 24h median, top-trader divergence, estimated liquidation levels, liquidations seen in the last 5 minutes. Full: PRO / RapidAPI ULTRA; lower plans get a BTCUSDT preview.
symbolHorus Cortex: the BTC market regime, trust score (0-100), active contradictions between evidence families, invalidation and breakout levels, and position-size multipliers by strategy type. Full: PRO / RapidAPI ULTRA; lower plans get regime, trust score and headline.
Takes no parameters.
Volatility-breakout scanner across ~750 crypto assets, refreshed every minute: global regime and the assets with the highest ignition score (0-1). A ranking of breakout conditions, not a probability. Full: BUILDER / RapidAPI PRO; free plans get the top 3.
limitScan about 190 Binance perpetual markets in one call and get a ranked list. preset is one of: buyers_in_control, sellers_in_control, volume_surge, breakout_candidates, crowded_funding, top_movers. Each row: price, 15m and 1h change, aggressive buy share, net taker flow in USD, volume surge, funding, ignition score, and Horus live flow with its measured hit rate where Horus tracks the pair. Use it to find where to look before calling get_crypto_flow or get_derivatives on a specific market. Rankings of current conditions, not predictions. Free plans: 3 rows; BUILDER / RapidAPI PRO and above: up to 100.
limitpresetmin_volume_24h_usdMeasured hit rates of Horus signals at 1, 5, 15 and 30 minutes (window 30d or all), from every signal recorded live since August 2026. Pass a signal name (e.g. STRONG_BUY_PRESSURE) for just that signal. Use this to decide how much weight to give a reading. Free.
signalwindowPoint-in-time ledger: every signal Horus emitted for BTCUSDT, ETHUSDT or SOLUSDT between start and end (ISO dates, max 31 days), with the price and what the market did 1/5/15/30 minutes later. For backtesting. Full: BUILDER / RapidAPI PRO; free plans get 20 signals from the last 24 hours.
endlimitstartsymbolWhat changed since your last check: liquidation cascades, strong flow signals, composite changes, Cortex regime changes, climate changes, ignition alerts, US session changes, new US trading halts. Pass the last event id you saw as since_id. types is a comma-separated filter. Full: BUILDER / RapidAPI PRO; free plans get the last 3 events, 15 minutes late.
limittypessince_idUS equity market right now: session phase (pre-market, regular, after-hours, closed), holidays and early closes, next open and close in New York time, minutes to close, and currently active trading halts. Call this before reasoning about US stock trades. Free.
Takes no parameters.
BTC order flow side by side with US equities flow (SPY, QQQ) and crypto-linked stocks and ETFs (COIN, MSTR, IBIT): are crypto and stocks risk-on together, risk-off together, or diverging? When US markets are closed, says so and keeps BTC as the live gauge. Equity flow is an IEX sample. Full: BUILDER / RapidAPI PRO; free plans get SPY and QQQ only.
Takes no parameters.
Order flow for one US stock or ETF from the IEX feed (about 3% of US volume, a sample): signal, buy/sell ratio, delta, large IEX prints. Extreme verdicts are capped because of the sample size. Full: BUILDER / RapidAPI PRO; free plans get SPY and QQQ.
symbolFreshness and uptime of every Horus data source. Check this if a tool returns data_stale. Free.
Takes no parameters.
100% of the applicable checks met
How complete this listing is, computed from the registry entry, the endpoint and public sources. Not a rating of the server and not a statement that it is safe or working today: reachability is a dated check, and no installs or reviews go into the score.
┌─────────────────────────────────────────────────────────────────────────────────────────────┐│ 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." │└─────────────────────────────────────────────────────────────────────────────────────────────┘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 <br/> L1/L2 Book]:::crypto_stream A[Alpaca WSS <br/> IEX Equities - sample]:::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 --> Dashclaude mcp add --transport http horus-flow https://flow.horustek.pro/mcp --header "X-RapidAPI-Key: YOUR_RAPIDAPI_KEY"{ "mcpServers": { "horus-flow": { "type": "http", "url": "https://flow.horustek.pro/mcp", "headers": { "X-RapidAPI-Key": "YOUR_RAPIDAPI_KEY" } } }}import hmac, hashlibdef 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"]import requests
HEADERS = {"X-API-Key": "your_horus_api_key"}BASE_URL = "https://flow.horustek.pro"
# 1. Query Horus Cortex for the Sovereign Market Stateres = 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 Rulesif 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"])