Institutional WebSocket 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
}

import asyncio
import json
import websockets

API_KEY = "YOUR_API_KEY"
# Secure WSS production stream (or direct ws://173.212.247.145:8080/ws/v2/stream)
WS_URL = f"wss://sigma-liq.fun/ws/v2/stream?api_key={API_KEY}"

async def listen_whale_core():
    async with websockets.connect(WS_URL) as ws:
        # 1. Receive initial welcome handshake
        init_msg = await ws.recv()
        print(f"Connected: {init_msg}")

        # 2. Event processing loop
        while True:
            raw = await ws.recv()
            event = json.loads(raw)
            
            # Filter high-impact cascades
            if event.get("type") == "LIQ_CASCADE":
                symbol = event["symbol"]
                impact = event["impact"]
                side = event["side"]
                print(f"🚨 [{symbol}] {side} Liq Cascade: ${impact:,.0f} | CVD: {event.get('cvd_1m')}")

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

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 Whale Core Institutional WebSocket');
    // Keep-alive heartbeat every 30 seconds
    setInterval(() => ws.send('ping'), 30000);
});

ws.on('message', (data) => {
    const event = JSON.parse(data.toString());
    if (event.type === 'LIQ_CASCADE') {
        console.log(`🔥 [${event.symbol}] ${event.side} Liq Cascade: $${event.impact.toLocaleString()}`);
    }
});

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

# Install wscat globally via npm
npm install -g wscat

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