from PyQt5.QtCore import QUrl, QThread, pyqtSignal, QObject, pyqtSlot, Qt
import irc.client

import IrcHandler

class ircConnectThread(QThread):
    sig = pyqtSignal(str, str, str)
    nick_sig = pyqtSignal(str, str)
    join_sig = pyqtSignal(str)
    namreply_sig = pyqtSignal(str, str)
    def __init__(self):
        QThread.__init__(self)
        self.reactor = irc.client.Reactor()
        self.server = self.reactor.server()
        self.handler = IrcHandler.IrcHandler

    def __del__(self):
        self.wait()

    def run(self):
        try:
            self.c = self.server.connect("irc.blatech.net", 6667, "wtest")
        except irc.client.ServerConnectionError:
            print(sys.exc_info()[1])
            raise SystemExit(1)

        # self.sig.connect(IrcWindow.updateTextArea)
        print("start")
        self.c.add_global_handler("welcome", self.on_connect)
        self.c.add_global_handler("pubmsg", self.on_pubmsg)
        self.c.add_global_handler("privmsg", self.on_privmsg)
        self.c.add_global_handler("join", self.on_join)
        self.c.add_global_handler("namreply", self.on_names)
        self.reactor.process_forever()

    def on_connect(self, connection, event):
        if irc.client.is_channel("#wtest"):
            self.join_sig.emit("#wtest")
            return
    def on_pubmsg(self, connection, event):
        print(event)
        self.sig.emit(event.target, event.source, event.arguments[0])

    def on_privmsg(self, connection, event):
        self.sig.emit(event.source, "", event.arguments[0])

    def on_join(self, connection, event):
        print(event)
        nick = event.source.split("!")[0]
        self.nick_sig.emit(event.target, event.source.split("!")[0])
        self.sig.emit(event.target, "", event.source + " joined " + event.target)

    def on_names(self, connection, event):
        print(event)
        self.namreply_sig.emit(event.arguments[1], event.arguments[2])

    @pyqtSlot(str, str)
    def send_msg(self, channel, message):
        if (message.startswith("/join")):
            self.handle_join(message)
        else:
            self.server.privmsg(channel, message)
            print(message)

    @pyqtSlot(str)
    def join_channel(self, channel):
        print(channel)
        self.c.join(channel)
        #TODO: handle errors such as invalid/passworded channel
        return True