Pinnacle odds,
ahead of the market.

Python · client.py

# pip install websocketsimport asyncio, json, osimport websocketsURL = "wss://feed.oddspush.com/v1/stream"KEY = os.environ["ODDSPUSH_KEY"]  # opk_…book = {}  # event id -> {market key: market}def merge(rec):    markets = book.setdefault(rec["id"], {})    for m in rec.get("markets") or []:        k = m.get("key")        old = markets.get(k, {}).get("version", -1)        if k is None or m.get("version", 0) <= old:            continue  # stale or reordered: skip        if m.get("status") == "open":            markets[k] = m        else:            markets.pop(k, None)  # closed: remove it    for p in rec.get("periods") or []:        if p.get("status") in ("closed", "settled"):            # a closed period closes all its markets            for k in [k for k, m in markets.items()                      if m.get("period") == p.get("period")]:                del markets[k]async def main():    # compression=None: deflate only adds latency    async with websockets.connect(URL, compression=None,                                  max_size=2**24) as ws:        send = lambda msg: ws.send(json.dumps(msg))        await send({"type": "login", "token": KEY})        welcome = json.loads(await ws.recv())        if welcome["type"] == "error":            raise SystemExit(welcome["code"])        await send({"type": "subscribe", "sports": [1],                    "channels": ["ld", "both"]})        async for raw in ws:            msg = json.loads(raw)            kind = msg["type"]            if kind == "odds":                data = msg["data"]                rec = data.get("rec") or {}                channel = str(data.get("topic")).rsplit("/")[-1]                if data.get("op") == "del":                    book.pop(rec.get("id"), None)                elif "id" in rec and channel in ("ld", "both"):                    merge(rec)  # other channels are not prices            elif kind == "snapshot":                for rec in msg["events"]:                    merge(rec)            elif kind == "missed" or msg.get("status") == "up":                await send({"type": "snapshot"})asyncio.run(main())

Node.js · client.mjs

// npm install wsimport WebSocket from "ws";const KEY = process.env.ODDSPUSH_KEY; // opk_…const book = new Map(); // event id -> Map(market key -> market)const ws = new WebSocket("wss://feed.oddspush.com/v1/stream", {  perMessageDeflate: false, // deflate only adds latency});const send = (msg) => ws.send(JSON.stringify(msg));function merge(rec) {  if (!book.has(rec.id)) book.set(rec.id, new Map());  const markets = book.get(rec.id);  for (const m of rec.markets ?? []) {    const old = markets.get(m.key)?.version ?? -1;    // stale or reordered: skip    if (m.key === undefined || (m.version ?? 0) <= old) continue;    if (m.status === "open") markets.set(m.key, m);    else markets.delete(m.key); // closed: remove it  }  // a closed period closes all its markets  for (const p of rec.periods ?? []) {    if (p.status !== "closed" && p.status !== "settled") continue;    for (const [k, m] of markets) {      if (m.period === p.period) markets.delete(k);    }  }}ws.on("open", () => send({ type: "login", token: KEY }));ws.on("message", (raw) => {  const msg = JSON.parse(raw);  if (msg.type === "welcome") {    send({      type: "subscribe",      sports: [1],      channels: ["ld", "both"],    });  } else if (msg.type === "error") {    console.error(msg.code);  } else if (msg.type === "odds") {    const { op, rec = {}, topic = "" } = msg.data;    if (op === "del") book.delete(rec.id);    // other channels are not prices    else if (rec.id && /\/(ld|both)$/.test(topic)) merge(rec);  } else if (msg.type === "snapshot") {    msg.events.forEach(merge);  } else if (msg.type === "missed" || msg.status === "up") {    send({ type: "snapshot" });  }});

wscat · terminal

# Log in within 15 s, from the machine that runs your bot.$ npm install -g wscat$ wscat -c wss://feed.oddspush.com/v1/streamConnected (press CTRL+C to quit)> {"type":"login","token":"opk_…"}< {"type":"welcome","feed":{"alive":true,"ready":true}, …}> {"type":"subscribe","sports":[1],"channels":["ld","both"]}< {"type":"subscription","filter":{"sports":[1], …}}< {"type":"odds","data":{"type":"live","sport_id":1, …}}< {"type":"snapshot","part":0,"final":false,"events":[ …