import this
import socketio


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)
        print(tparams)
        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 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 sio(url=' xxx.net', vparams='', tparams=''):
    if not tparams:
        sio = socketio.Client()
        this.sio.connect('http://localhost:5000')
        print('socketio connect success!!!')
        sio.on('connect', on_connect)
        sio.on('chat_message', revc_message)
        sio.on('disconnect', on_disconnect)
        sio.on('reconnect', on_reconnect)
        return teacher, vsocketIO, tsocketIO

def send_msg(domain_host, featurestype, sendmessage, userid, roomid, timer=1):
    teacher, vsocketIO, tsocketIO = sio(userid, roomid, host=domain_host)
    for i in range(timer):
        teacher.emit('chat_message', f'{sendmessage}', revc_message)
        vsocketIO.wait(seconds=1)
        tsocketIO.wait(seconds=1)
    return VIEWER_DATA, TEACHER_DATA

def send_msg_mutil(domain_host, featurestype, sendmessage, userid, roomid, timer=1, vparams='', tparams=''):
    teacher, vsocketIO, tsocketIO = sio(userid, roomid, host=domain_host, vparams=vparams, tparams=tparams)
    for i in range(timer):
        teacher.emit('chat_message', f'{sendmessage}', revc_message_mutil)
        vsocketIO.wait(seconds=1)
        tsocketIO.wait(seconds=1)
    return VIEWER_DATA, TEACHER_DATA

def clear_data():
    VIEWER_DATA.clear()
    TEACHER_DATA.clear()

class Socketio_client():

    sio = socketio.Client()

    def create_client():
        print('-----------start socketio.clent------------')
        # sio = socketio.Client()
        this.sio.connect('http://localhost:5000')
        print('socketio connect success!!!')

        @this.sio.event
        def connect():
            print('connection established')
            this.sio.emit('client', {'msg': 'connect success'})

        @this.sio.on('serve')
        def on_message(data):
            print('client received a message!',data)
        # @sio.event
        # def message(data):
        #     print('message received with ', data)
        #     sio.emit('client', {'response': 'my response'})

        @this.sio.event
        def connect_error():
            print("The connection failed!")
            this.sio.disconnect()

        @this.sio.event
        def disconnect():
            print('disconnected from server')
            this.sio.disconnect()
        
        # sio.wait()

    def sendmsg(msg): 
        this.sio.emit('client', {'msg': msg})

    def connect(): 
        this.sio.connect('http://localhost:5000')
        print('socketio connect success!!!')


    create_client()