# AllTick realtime financial data API
# forex crypto stock commodities indices
import asyncio, json, uuid
import websockets

subscribe = {
    "cmd_id": 22004,
    "seq_id": 1,
    "trace": str(uuid.uuid4()),
    "data": {"symbol_list": [{"code": "EURUSD"}]},
}
heartbeat = {"cmd_id": 22000, "seq_id": 1, "trace": "heartbeat", "data": {}}

async def stream():
    uri = "wss://quote.alltick.co/quote-b-ws-api?token=YOUR_API_KEY"
    async with websockets.connect(uri) as socket:
        await socket.send(json.dumps(subscribe))

        async def keep_alive():
            while True:
                await asyncio.sleep(10)
                await socket.send(json.dumps(heartbeat))

        asyncio.create_task(keep_alive())
        async for message in socket:
            print(json.loads(message))

asyncio.run(stream())