import websocket
import json
import threading
import time

##########    infos    ##########
channel = input('channel:\n>>')
trip = input('passwd:\n>>')
nick = input('nick:\n>>')

if trip == '':
    pass
else:
    nick = nick + '#' + trip

on_message = []  # msgs from ur join to now
online_users = []  # online since u joined
on_join = []
on_leave = []
on_whisper = []


##########        ##########

##########    DEFS    ##########
def _send_msg(msg):
    _send({"cmd": "chat", "text": msg})

def _info():
    while True:
        result = json.loads(ws.recv())  # get stuff
        if result["cmd"] == "chat" and not result["nick"] == nick:  # if otheres send shit
            for handler in list(on_message):
                handler(result["text"], result["nick"])
            if result['text']=='#yelp':
                send_msg('yelp me im not done yet\nrn only lol can use me so fuck you')
            if result['text']=='#game':
                _send_msg('we dont have any... yet')
                    #if result['text']=='#game -l':
                        #print(list_game())
            print(result)
#def _game_r_p_s():
        elif result["cmd"] == "onlineAdd":
            online_users.append(result["nick"])
            for handler in list(on_join):
                handler(result["nick"])
            print(result)

        elif result["cmd"] == "onlineRemove":
            online_users.remove(result["nick"])
            for handler in list(on_leave):
                handler(result["nick"])
            print(result)

        elif result["cmd"] == "onlineSet":
            for nick in result["nicks"]:
                online_users.append(nick)
            print(result)

        elif result["cmd"] == "info" and result["type"] == "whisper":
            for handler in list(on_whisper):
                handler(result["text"], result["from"], result)
            print(result)


# def send_to(target, msg):
#        _send({"cmd": "whisper", "nick": target, "text": msg})


def _send(pkg):
    encoded = json.dumps(pkg)
    ws.send(encoded)


def _stay_in_chat():
    while ws.connected:
        _send({"cmd": "ping"})
        time.sleep(60)


def _send_msg_in_chat():
    while True:
        msg=input()
        _send({"cmd": "chat", "text": msg})


##########        ##########

##########     CONNECT    ##########
ws = websocket.create_connection('wss://hack.chat/chat-ws')

_send({"cmd": "join", "channel": channel, "nick": nick})
threading.Thread(target=_stay_in_chat).start()


# def _daemon():
#    daemon_thread=threading.Thread(target=info)
#    daemon_thread.start()

daemon_thread = threading.Thread(target=_info)
daemon_thread.start()
msg=threading.Thread(target=_send_msg_in_chat).start()