WebSocket Overview

const ws = new WebSocket('wss://mainnet-ws1.bulk.trade');

const WebSocket = require('ws');

const ws = new WebSocket('wss://mainnet-ws1.bulk.trade');

ws.on('open', () => {
  // Subscribe to ticker
  ws.send(JSON.stringify({
    method: 'subscribe',
    subscription: [{
      type: 'ticker',
      symbol: 'BTC-USD'
    }]
  }));
});

ws.on('message', (data) => {
  const message = JSON.parse(data);
  
  // Handle subscription confirmation
  if (message.type === 'subscriptionResponse') {
    console.log('Subscribed to:', message.topics);
    return;
  }
  
  // Handle ticker updates
  if (message.type === 'ticker') {
    console.log('Ticker:', message.data.ticker);
  }
});

import websocket
import json

def on_message(ws, message):
    data = json.loads(message)
    
    # Handle subscription confirmation
    if data.get('type') == 'subscriptionResponse':
        print(f"Subscribed to: {data['topics']}")
        return
    
    # Handle ticker updates
    if data.get('type') == 'ticker':
        print(f"Ticker: {data['data']['ticker']}")

def on_open(ws):
    ws.send(json.dumps({
        'method': 'subscribe',
        'subscription': [{
            'type': 'ticker',
            'symbol': 'BTC-USD'
        }]
    }))

ws = websocket.WebSocketApp(
    'wss://mainnet-ws1.bulk.trade',
    on_message=on_message,
    on_open=on_open
)

ws.run_forever()