5.2. Bảng giá cơ sở (WebSocket)

import base64

token = "igwfUq9M2IqWVhrFrYybEYKWxAxDbYzxz1RzOkp0L0S95lrMtrJDbMgFwy86r8Ir"
encoded = base64.b64encode(token.encode()).decode()
auth_message = f"d|a|||{encoded}"

await ws.send(auth_message)

# Wait for response: d|0|{"success":true,"error":null}
response = await ws.recv()

"""Minimal WebSocket cash price-board client for TCBS — Python 3.10+"""

import asyncio
import base64
import json

# pip install websockets>=12.0
from websockets.asyncio.client import connect


WS_URL = "wss://openapi.tcbs.com.vn/ws/thesis/v1/stream/normal"
TOKEN = "YOUR_OPENAPI_TOKEN_HERE"
SYMBOLS = "FPT,VNM,HPG"


async def main():
    # 1. Connect — MUST disable auto-ping
    async with connect(WS_URL, ping_interval=None, ping_timeout=None) as ws:

        # 2. Auth — base64 encode token
        encoded_token = base64.b64encode(TOKEN.encode()).decode()
        await ws.send(f"d|a|||{encoded_token}")

        # 3. Wait for auth response: d|0|{"success":true,...}
        auth_response = await asyncio.wait_for(ws.recv(), timeout=5.0)
        print(f"Auth response: {auth_response}")
        if '"success":true' not in auth_response:
            print("Auth failed!")
            return

        # 4. Subscribe by symbol
        await ws.send(f"d|s|tk|bp+bi+tm+mp+op+fe|{SYMBOLS}")
        print(f"Subscribed to {SYMBOLS}")

        # 5. Start heartbeat background task
        async def heartbeat():
            while True:
                await ws.send("d|p|||")
                await asyncio.sleep(2)

        asyncio.create_task(heartbeat())

        # 6. Receive & parse messages
        while True:
            raw = await ws.recv()

            # Skip control messages
            if raw.startswith("d|"):
                continue

            # Parse data: s|[channel]|[json]
            if raw.startswith("s|"):
                parts = raw.split("|", 2)
                if len(parts) == 3:
                    channel = parts[1]
                    payload = json.loads(parts[2])

                    if channel == "6":
                        print(f"[TRADE] {payload['symbol']} "
                              f"Price={payload['matchPrice']} "
                              f"Qty={payload['matchQtty']}")
                    elif channel == "1":
                        print(f"[BID] {payload['symbol']} "
                              f"Best={payload['bidPrice01']} "
                              f"Qty={payload['bidQtty01']}")
                    elif channel == "2":
                        print(f"[OFFER] {payload['symbol']} "
                              f"Best={payload['offerPrice01']}")
                    elif channel == "4":
                        print(f"[BASE] {payload['symbol']} "
                              f"Ref={payload['refPrice']}")


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