WebSocket Streaming

const API_KEY = "rm_your_key_here";
const ws = new WebSocket("wss://api.resolvedmarkets.com/ws/orderbook");

ws.onopen = () => {
  // First message must be auth — server closes with 4001 after 5s otherwise.
  ws.send(JSON.stringify({ type: "auth", apiKey: API_KEY }));
};

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

  if (msg.type === "auth" && msg.status === "ok") {
    // Authenticated — subscribe to BTC orderbooks.
    ws.send(JSON.stringify({ type: "subscribe", crypto: "BTC" }));
    return;
  }

  if (msg.type === "markets") {
    console.log("Available markets:", msg.data);
  }

  if (msg.type === "orderbook") {
    for (const market of msg.markets) {
      console.log(market.crypto, market.timeframe);
      console.log("  UP best bid:", market.up?.bestBid);
      console.log("  DOWN best ask:", market.down?.bestAsk);
    }
  }
};

ws.onclose = (e) => {
  console.log("Disconnected:", e.code, e.reason);
  setTimeout(() => { /* reconnect logic */ }, 3000);
};

import asyncio, json, websockets

async def stream():
    API_KEY = "rm_your_key_here"
    async with websockets.connect("wss://api.resolvedmarkets.com/ws/orderbook") as ws:
        # First message must be auth.
        await ws.send(json.dumps({"type": "auth", "apiKey": API_KEY}))
        ack = json.loads(await ws.recv())
        assert ack.get("status") == "ok", ack

        await ws.send(json.dumps({"type": "subscribe", "crypto": "ETH"}))

        async for message in ws:
            data = json.loads(message)
            if data["type"] == "orderbook":
                for m in data["markets"]:
                    print(f"{m['crypto']} {m['timeframe']}: "
                          f"UP bid={m['up']['bestBid']}")

asyncio.run(stream())