# coding=utf8
from __future__ import unicode_literals, absolute_import, division, print_function
"""
This is the SpiceBot Events system.
"""
from threading import Thread
from sopel import plugin

from sopel.externals.SpiceBot.SpiceBotCore import sb


@plugin.event(sb.events.BOT_WELCOME, sb.events.BOT_READY, sb.events.BOT_CONNECTED, sb.events.BOT_LOADED)
@plugin.rule('.*')
def bot_events_complete(bot, trigger):
    """This is here simply to log to stderr that this was recieved."""
    sb.logger.info('SpiceBot_Events: %s' % trigger.args[1])


@plugin.event(sb.events.RPL_WELCOME)
@plugin.rule('.*')
def bot_events_connected(bot, trigger):

    # Handling for connection count
    sb.events.dict["RPL_WELCOME_Count"] += 1
    if sb.events.dict["RPL_WELCOME_Count"] > 1:
        sb.events.trigger(bot, sb.events.BOT_RECONNECTED, "Bot ReConnected to IRC")
    else:
        sb.events.trigger(bot, sb.events.BOT_WELCOME, "Welcome to the SpiceBot Events System")

    """For items tossed in a queue, this will trigger them accordingly"""
    Thread(target=events_thread, args=(bot,)).start()


def events_thread(bot):
    while True:
        if len(sb.events.dict["trigger_queue"]):
            pretriggerdict = sb.events.dict["trigger_queue"][0]
            sb.events.dispatch(bot, pretriggerdict)
            try:
                del sb.events.dict["trigger_queue"][0]
            except IndexError:
                pass


@plugin.event(sb.events.BOT_WELCOME)
@plugin.rule('.*')
def bot_events_start(bot, trigger):
    """This stage is redundant, but shows the system is working."""
    sb.events.trigger(bot, sb.events.BOT_READY, "Ready To Process module setup procedures")

    """Here, we wait until we are in at least one channel"""
    while not len(list(bot.channels.keys())) > 0:
        pass
    sb.events.trigger(bot, sb.events.BOT_CONNECTED, "Bot Connected to IRC")


@sb.events.startup_check_ready()
@plugin.event(sb.events.BOT_READY)
@plugin.rule('.*')
def bot_events_startup_complete(bot, trigger):
    """All events registered as required for startup have completed"""
    sb.events.trigger(bot, sb.events.BOT_LOADED, "All registered modules setup procedures have completed")