WebSocket — push actionable arb signals

wss://api.polyquantlab.com/v1/arb/ws

{
  "type": "ready",
  "ticker_filter": ["BTC", "ETH"],
  "tier": "plus",
  "channel": "pql:arb:actionable"
}

{
  "type": "opportunity",
  "as_of": "2026-06-06T04:00:02.118+00:00",
  "market_id": "0x4a8f31...c2",
  "ticker": "BTC",
  "event_type": "5m",
  "question": "Will Bitcoin price be above $109,500 at 04:05 UTC?",
  "tier": "endgame",
  "direction": "BUY_YES",
  "fill_price": 0.82,
  "expected_pnl_per_share": 0.167,
  "...": "(remaining fields identical to /v1/arb/live)"
}

{ "type": "ping" }

import os
import json
import asyncio
import websockets

URL = (
    "wss://api.polyquantlab.com/v1/arb/ws"
    f"?api_key={os.environ['POLYQUANTLAB_API_KEY']}"
)

async def main():
    async with websockets.connect(URL, ping_interval=20, ping_timeout=30) as ws:
        async for raw in ws:
            msg = json.loads(raw)
            t = msg.get("type")

            if t == "ready":
                print(f"subscribed: {msg}")
            elif t == "opportunity":
                handle(msg)
            elif t == "ping":
                pass  # ignore; just liveness
            else:
                print(f"unknown message type: {msg}")

def handle(opp):
    print(
        f"[{opp['tier'].upper():7s}] {opp['ticker']} {opp['event_type']} "
        f"size_at=${opp['fill_price']:.3f} "
        f"edge=${opp['expected_pnl_per_share']:.4f}/sh "
        f"τ={opp['seconds_to_resolution']}s"
    )
    # … submit the order via your Polymarket SDK here …

asyncio.run(main())

import asyncio, websockets

async def run_forever():
    backoff = 1.0
    while True:
        try:
            async with websockets.connect(URL) as ws:
                backoff = 1.0  # success — reset
                async for raw in ws:
                    handle(json.loads(raw))
        except (websockets.ConnectionClosed, OSError) as e:
            print(f"disconnected: {e}; reconnect in {backoff:.1f}s")
            await asyncio.sleep(backoff)
            backoff = min(backoff * 2, 30.0)