Orderbook Stream

const ws = new WebSocket("wss://ob.polynode.dev/ws?key=pn_live_YOUR_KEY");

ws.onopen = () => {
  // Subscribe by condition ID — resolves to both Yes + No tokens
  ws.send(JSON.stringify({
    action: "subscribe",
    markets: ["0x7cb525e831729325d651017f81cbcb6f1adde5011c7b2283babea00b4ae93ae7"]
  }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "snapshot_batch") {
    for (const snap of msg.snapshots) {
      console.log(`${snap.question} [${snap.outcome}]: ${snap.bids.length} bids, ${snap.asks.length} asks`);
    }
  } else if (msg.type === "batch") {
    for (const update of msg.updates) {
      if (update.type === "price_change") {
        for (const asset of update.assets) {
          // size="0" means the level was removed; otherwise it's the new absolute size at that level.
          console.log(`${update.slug} [${asset.outcome}] ${asset.side} @ ${asset.price} -> size ${asset.size}  (bbo: ${asset.best_bid}/${asset.best_ask})`);
        }
      }
    }
  }
};

import asyncio, json, websockets

async def stream_orderbook():
    async with websockets.connect("wss://ob.polynode.dev/ws?key=pn_live_YOUR_KEY") as ws:
        await ws.send(json.dumps({
            "action": "subscribe",
            "markets": ["0x7cb525e831729325d651017f81cbcb6f1adde5011c7b2283babea00b4ae93ae7"]
        }))
        async for message in ws:
            data = json.loads(message)
            if data["type"] == "snapshot_batch":
                for snap in data["snapshots"]:
                    print(f"{snap['question']} [{snap['outcome']}]: {len(snap['bids'])} bids, {len(snap['asks'])} asks")
            elif data["type"] == "batch":
                for update in data["updates"]:
                    if update["type"] == "price_change":
                        for asset in update["assets"]:
                            # size="0" removes the level; otherwise it's the new absolute size.
                            print(f"{update['slug']} [{asset['outcome']}] {asset['side']} @ {asset['price']} -> size {asset['size']}  (bbo: {asset['best_bid']}/{asset['best_ask']})")

asyncio.run(stream_orderbook())

npx wscat -c "wss://ob.polynode.dev/ws?key=pn_live_YOUR_KEY"
# once connected, send:
{"action":"subscribe","markets":["0x7cb525e831729325d651017f81cbcb6f1adde5011c7b2283babea00b4ae93ae7"]}