WebSocket API

import { Luzia } from '@luziadev/sdk'

const luzia = new Luzia({
  apiKey: 'lz_your_api_key',
})

// Create and open a WebSocket connection
const ws = luzia.createWebSocket()

ws.on('connected', (info) => {
  console.log('Connected!', info.tier)
  console.log('Max subscriptions:', info.limits.maxSubscriptions)

  // Subscribe to channels
  ws.subscribe([
    'ticker:binance:BTC/USDT',
    'ticker:coinbase:ETH/USDT',
  ])
})

ws.on('ticker', (data) => {
  console.log(`${data.exchange} ${data.symbol}: $${data.data.last}`)
})

ws.on('error', (err) => {
  console.error(`[${err.code}] ${err.message}`)
})

ws.on('disconnected', ({ code, reason }) => {
  console.log(`Disconnected: ${code} ${reason}`)
})

// Open the connection
ws.connect()

// Without the SDK - server-side (Node.js, Bun, wscat)
// Pass API key via Authorization header
const ws = new WebSocket('wss://api.luzia.dev/v1/ws', {
  headers: { Authorization: 'Bearer lz_your_api_key' },
})

ws.onopen = () => {
  console.log('Connected')
}

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data)

  switch (msg.type) {
    case 'connected':
      // Subscribe to channels after connection is confirmed
      ws.send(JSON.stringify({
        type: 'subscribe',
        channels: ['ticker:binance:BTC/USDT', 'ticker:binance:ETH/USDT'],
      }))
      break

    case 'ticker':
      console.log(`${msg.exchange} ${msg.symbol}: $${msg.data.last}`)
      break

    case 'subscribed':
      console.log('Subscribed to:', msg.channel)
      break

    case 'error':
      console.error(`[${msg.code}] ${msg.message}`)
      break
  }
}

// Keep connection alive with periodic pings
setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(JSON.stringify({ type: 'ping' }))
  }
}, 30000)

// Subscribe to specific symbols
ws.subscribe([
  'ticker:binance:BTC/USDT',    // Single symbol on Binance
  'ticker:coinbase:ETH/USDT',   // Single symbol on Coinbase
])

// Subscribe to ALL tickers from an exchange
ws.subscribe([
  'ticker:binance',              // All Binance tickers
])

// Unsubscribe
ws.unsubscribe(['ticker:binance:BTC/USDT'])

// Configure auto-reconnect behavior
const ws = luzia.createWebSocket({
  autoReconnect: true,           // Enable auto-reconnect (default: true)
  maxReconnectAttempts: 10,      // Max reconnect attempts (default: 10)
  reconnectDelayMs: 1000,        // Initial delay (default: 1000ms)
  maxReconnectDelayMs: 30000,    // Max delay (default: 30000ms)
  heartbeatIntervalMs: 30000,    // Heartbeat interval (default: 30000ms)
})

ws.on('reconnecting', ({ attempt, delayMs }) => {
  console.log(`Reconnecting (attempt ${attempt}) in ${delayMs}ms...`)
})

ws.connect()

// Manually disconnect (disables auto-reconnect)
ws.disconnect()