from pymexc import spot, futures
from dotenv import load_dotenv

import os

load_dotenv()

api_key = os.getenv("API_KEY")
api_secret = os.getenv("API_SECRET")

def handle_message(message): 
    print(message)



# initialize WebSocket client
ws_spot_client = spot.WebSocket(api_key = api_key, api_secret = api_secret)

# make http request to api

# create websocket connection to public channel (spot@public.deals.v3.api@BTCUSDT)
# all messages will be handled by function `handle_message`
ws_spot_client.kline_stream(handle_message, "BTCUSDT", "Min1")
ws_spot_client.kline_stream(handle_message, "XRPUSDT", "Min1")
while True: 
    ...