WebSocket Streaming

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

ws.onopen = () => {
  console.log("Connected");
  // Subscribe to BTC orderbooks
  ws.send(JSON.stringify({ type: "subscribe", crypto: "BTC" }));
};

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

  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 = () => {
  console.log("Disconnected — reconnect after 3s");
  setTimeout(() => { /* reconnect logic */ }, 3000);
};

import asyncio, json, websockets

async def stream():
    API_KEY = "rm_your_key_here"
    async with websockets.connect(f"wss://api.resolvedmarkets.com/ws/orderbook?apiKey={API_KEY}") as ws:
        # Subscribe to ETH
        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())