WebSocket

const ws = new WebSocket(
  "wss://therundown.io/api/v2/ws/markets?key=YOUR_API_KEY&sport_ids=4&market_ids=1,2,3"
);

ws.onopen = () => {
  console.log("Connected to TheRundown WebSocket");
};

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

  // Skip heartbeats
  if (msg.meta?.type === "heartbeat") return;

  const d = msg.data;
  console.log(
    `Event ${d.event_id} | market=${d.market_id} aff=${d.affiliate_id}`
  );
  console.log(
    `  line=${d.line} price=${d.price} (was ${d.previous_price}, delta=${d.price_delta})`
  );
};

ws.onerror = (error) => {
  console.error("WebSocket error:", error);
};

ws.onclose = (event) => {
  console.log(`Disconnected: code=${event.code} reason=${event.reason}`);
  // Implement reconnection logic here
};

import asyncio
import json
import websockets

API_KEY = "YOUR_API_KEY"
URL = f"wss://therundown.io/api/v2/ws/markets?key={API_KEY}&sport_ids=4"

async def listen():
    async with websockets.connect(URL) as ws:
        print("Connected to TheRundown WebSocket")
        async for message in ws:
            msg = json.loads(message)

            if msg.get("meta", {}).get("type") == "heartbeat":
                continue

            d = msg["data"]
            print(
                f"Event {d['event_id']} | market={d['market_id']} aff={d['affiliate_id']}"
            )
            print(
                f"  line={d['line']} price={d['price']}"
                f" (was {d['previous_price']}, delta={d['price_delta']})"
            )

asyncio.run(listen())

const WebSocket = require("ws");

const API_KEY = "YOUR_API_KEY";
const URL = `wss://therundown.io/api/v2/ws/markets?key=${API_KEY}&sport_ids=4`;

function connect() {
  const ws = new WebSocket(URL);

  ws.on("open", () => console.log("Connected"));

  ws.on("message", (raw) => {
    const msg = JSON.parse(raw);
    if (msg.meta?.type === "heartbeat") return;
    const d = msg.data;
    console.log(`Update: event=${d.event_id} market=${d.market_id} price=${d.price}`);
  });

  ws.on("close", () => {
    console.log("Disconnected, reconnecting in 3s...");
    setTimeout(connect, 3000);
  });

  ws.on("error", (err) => {
    console.error("WebSocket error:", err.message);
    ws.close();
  });
}

connect();