import asyncio
import websockets
import json

async def run_client():
    uri = "wss://spro.agency/api?key=YOUR_TOKEN"
    while True:
        try:
            async with websockets.connect(uri) as websocket:

                ack_message = await websocket.recv()

                # Send subscription message
                subscribe_message = {
                    "action": "subscribe",
                    "filters": {
                        "sports": ["NBA", "MLB", "Wimbledon (M)"],
                        "sportsbooks": ["draftkings", "betmgm"]
                    }
                }

                await websocket.send(json.dumps(subscribe_message))
                

                # Listen for incoming messages
                while True:

                    message = await websocket.recv()
                    
                    data = json.loads(message)

                    #work with data
                    print("Received message:", data)

        except websockets.ConnectionClosed:
            print("Connection closed — reconnecting")
            await asyncio.sleep(5)
            continue


if __name__ == "__main__":
    asyncio.run(run_client())