WebSockets

wss://api.conyr.ai/ws

const ws = new WebSocket("wss://api.conyr.ai/ws");
 
ws.onopen = () => {
  ws.send(JSON.stringify({
    op: "subscribe",
    channels: ["token:EPjFWd...:trades"]
  }));
};
 
ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.channel) {
    console.log(`[${msg.channel}]`, msg.data);
  }
};

import asyncio
import json
import websockets
 
async def stream():
    async with websockets.connect("wss://api.conyr.ai/ws") as ws:
        await ws.send(json.dumps({
            "op": "subscribe",
            "channels": [
                "token:EPjFWd...:trades",
                "token:EPjFWd...:ohlcv:full:1m",
            ]
        }))
 
        async for message in ws:
            data = json.loads(message)
            if "channel" in data:
                print(f"[{data['channel']}] {data['data']}")
 
asyncio.run(stream())

{"op": "subscribe", "channels": ["token:EPjFWd...:trades", "wallet:7xKXtg...:pnl"]}

{"op": "unsubscribe", "channels": ["token:EPjFWd...:trades"]}

{"op": "ping"}

{"op": "subscribed", "channels": ["token:EPjFWd...:trades"]}

{"channel": "token:EPjFWd...:trades", "data": { ... }}

{"op": "pong"}

{"op": "error", "message": "Subscription limit reached (max 50)"}