WebSockets

A API Liqi CaaS oferece conexões WebSocket para acompanhamento em tempo real de preços, ordens e saldos.

URLs de Conexão

Ambiente	URL
Sandbox	wss://websocket-caas-it-sandbox.liqi.app.br/
Production	wss://ws.liqi-caas.com.br/

Como Conectar

JavaScript

const ws = new WebSocket('wss://websocket-caas-it-sandbox.liqi.app.br/');

ws.onopen = () => {
  console.log('Conectado ao WebSocket');

  // Subscrever a um canal
  ws.send(JSON.stringify({
    action: 'subscribe',
    channel: 'watchTicker',
    data: {
      symbol: 'BTC/BRL'
    }
  }));
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('Dados recebidos:', data);
};

ws.onerror = (error) => {
  console.error('Erro no WebSocket:', error);
};

ws.onclose = () => {
  console.log('Conexão fechada');
};

Python

import asyncio
import websockets
import json

async def connect():
    uri = "wss://websocket-caas-it-sandbox.liqi.app.br/"
    async with websockets.connect(uri) as ws:
        # Subscrever
        await ws.send(json.dumps({
            "action": "subscribe",
            "channel": "watchTicker",
            "data": {"symbol": "BTC/BRL"}
        }))

        # Receber mensagens
        async for message in ws:
            data = json.loads(message)
            print("Recebido:", data)

asyncio.run(connect())

Canais Disponíveis

Canal	Descrição	Dados Necessários
watchOrders	Acompanha status de ordens em tempo real	-
watchTicker	Preço de um par específico	symbol
watchTickers	Preços de todos os pares	onlyPriority (opcional)
watchBalance	Saldos em tempo real	-

Formato das Mensagens

Subscrição

{
  "action": "subscribe",
  "channel": "<nome-do-canal>",
  "data": { ... }
}

Dados Recebidos

{
  "channel": "<nome-do-canal>",
  "message": { ... }
}