import socketio

def create_sio():
    sio = socketio.Client()
    return sio

def connect_(url,sio):
    if not url:
        sio.connect(url)
        sio.on('connect', on_connect)
        sio.on('chat_message', revc_message)
        sio.on('disconnect', on_disconnect)
        sio.on('reconnect', on_reconnect)
        print('create sio')
        return sio

def sio(url,tparams):
    if not tparams:
        sio = socketio.Client()
        sio.connect(url)
        sio.on('connect', on_connect)
        sio.on('chat_message', revc_message)
        sio.on('disconnect', on_disconnect)
        sio.on('reconnect', on_reconnect)
        return sio


def get_sessionid(userid, roomid):
    pass

def on_connect(*args):
    # print(*args)
    print('connect')

def on_disconnect():
    print('## disconnect ##')

def on_reconnect():
    print('reconnect')

def send_msg(sendmessage, sio):
    sio.emit('msg', b'{sendmessage}')
    return 

def revc_message(*args):  # 这个函数很重要 是socketio监听信息获取的函数, 这里面socketio会自行调用这个函数
    response_data_format = {}
    response_data = eval(args[0])
    print(response_data)

def revc_message_mutil(*args):  # 这个函数很重要 是socketio监听信息获取的函数, 这里面socketio会自行调用这个函数
    response_data_format = {}
    response_data = eval(args[0])
    print(response_data)

def create_params(userid, roomid):  # 这个方法类似requests库的封装方法 看底层貌似与requests的urllib3方法一样
    vsessionid, tsessionid = get_sessionid(userid, roomid)
    vparams = {
        'sessionid': vsessionid,
    }
    tparams = {
        'sessionid': tsessionid,
    }
    return vparams, tparams

def clear_data():
    print('sessionid')