Institutional WebSocket & REST API

{
  "type": "LIQ_CASCADE",
  "symbol": "BTCUSDT",
  "side": "Sell",
  "price": 78500.0,
  "impact": 1250000.0,
  "timestamp": 1741684800.12,
  "verdict_state": "Deleveraging",
  "impact_pct": 0.2,
  "cvd_1m": -127010000.0,
  "cvd_5m": -123420000.0,
  "cvd_15m": -125980000.0,
  "oi_delta_pct": 0.06,
  "funding_rate": 0.000087,
  "liq_count": 5
}

{
  "type": "WHALE_LIQ_DANGER",
  "source": "HYPERLIQUID_ONCHAIN",
  "symbol": "SOLUSDT",
  "coin": "SOL",
  "side": "Long",
  "price": 148.25,
  "liq_price": 143.10,
  "dist_pct": 3.47,
  "position_usd": 3420000.0,
  "impact": 3420000.0,
  "wallet": "0x505417b127521dfb68945657fa48b4887df4f483",
  "hypurr_url": "https://hypurrscan.io/address/0x505417b127521dfb68945657fa48b4887df4f483",
  "entry_price": 152.40,
  "hl_skew": {
    "long_pct": 68.5,
    "short_pct": 31.5
  },
  "timestamp": 1790172810.25
}

{
  "type": "WHALE_POSITION_INFLOW",
  "source": "HYPERLIQUID_ONCHAIN",
  "symbol": "ETHUSDT",
  "coin": "ETH",
  "side": "Short",
  "price": 2640.50,
  "delta_usd": 1850000.0,
  "position_usd": 4950000.0,
  "impact": 1850000.0,
  "wallet": "0xa14f60da7008b40413d1221b1548578497ac9311",
  "hypurr_url": "https://hypurrscan.io/address/0xa14f60da7008b40413d1221b1548578497ac9311",
  "entry_price": 2642.10,
  "liq_price": 2980.00,
  "dist_pct": 12.86,
  "hl_skew": {
    "long_pct": 42.1,
    "short_pct": 57.9
  },
  "timestamp": 1790172825.80
}

import asyncio
import json
import websockets

API_KEY = "YOUR_API_KEY"
WS_URL = f"wss://sigma-liq.fun/ws/v2/stream?api_key={API_KEY}"

async def listen_institutional_stream():
    async with websockets.connect(WS_URL) as ws:
        # 1. Receive handshake with engine specifications
        handshake = await ws.recv()
        print(f"⚡ Authenticated: {handshake}")

        # 2. Real-time dual-engine anomaly event loop
        while True:
            raw = await ws.recv()
            event = json.loads(raw)
            ev_type = event.get("type")

            # Branch A: Hyperliquid L1 Whale Sonar Danger Alert
            if ev_type == "WHALE_LIQ_DANGER":
                symbol = event["symbol"]
                dist = event["dist_pct"]
                pos = event["position_usd"]
                print(f"🐋 [WHALE SONAR] {symbol} {event['side']} Whale ${pos:,.0f} | ONLY {dist:.1f}% to LIQ @ ${event['liq_price']}")

            # Branch B: Binance Futures Liquidation Cascade
            elif ev_type == "LIQ_CASCADE":
                print(f"🔥 [BINANCE CASCADE] {event['symbol']} {event['side']} Liq Vol: ${event['impact']:,.0f}")

if __name__ == "__main__":
    asyncio.run(listen_institutional_stream())

const WebSocket = require('ws');

const API_KEY = 'YOUR_API_KEY';
const ws = new WebSocket(`wss://sigma-liq.fun/ws/v2/stream?api_key=${API_KEY}`);

ws.on('open', () => {
    console.log('⚡ Connected to Dual-Engine Institutional WebSocket');
    // 30-second keep-alive ping
    setInterval(() => ws.send('ping'), 30000);
});

ws.on('message', (data) => {
    const event = JSON.parse(data.toString());
    
    if (event.type === 'WHALE_LIQ_DANGER') {
        console.log(`🐋 [SONAR DANGER] ${event.symbol} ${event.side} $${event.position_usd.toLocaleString()} within ${event.dist_pct}% to Liq!`);
    } else if (event.type === 'LIQ_CASCADE') {
        console.log(`🔥 [CASCADE] ${event.symbol} ${event.side} Liq Cascade: $${event.impact.toLocaleString()}`);
    }
});

ws.on('error', console.error);

# 1. Fetch live service health & telemetry:
curl -s http://173.212.247.145:8080/health

# 2. Get snapshot of recent market events across both engines:
curl -s "http://173.212.247.145:8080/api/v2/events/recent?limit=20"

# 3. Pull recent Hyperliquid L1 on-chain mega-whale anomalies:
curl -s "http://173.212.247.145:8080/api/v2/events/sonar?limit=10"

# Install wscat globally via npm
npm install -g wscat

# Connect instantly to the live production feed:
wscat -c "wss://sigma-liq.fun/ws/v2/stream?api_key=YOUR_API_KEY"