test

SpiceBot/__init__.py

@@ -6,6 +6,7 @@ from __future__ import unicode_literals, absolute_import, division, print_functi
 
 import os
 import pathlib
+from threading import Thread
 
 from sopel import plugin
 
@@ -35,9 +36,60 @@ def welcome_setup_start(bot, trigger):
     sb.comms.ircbackend_initialize(bot)
 
 
-# @plugin.event(sb.events.BOT_CONNECTED)
+@plugin.event(sb.events.BOT_CONNECTED)
-@plugin.event("1003")
+@plugin.rule('.*')
+def bot_events_start_set_hostmask(bot, trigger):
+    sb.comms.hostmask_set(bot)
+
+
+@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('SpiceBot_Events', trigger.args[1], True)
+
+
+@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):
-    sb.comms.hostmask_set(bot)
+    """This stage is redundant, but shows the system is working."""
-    print("here b")
+    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")