mirror of
https://github.com/SpiceBot/SpiceBot.git
synced 2026-11-10 21:50:59 -05:00
63 lines
2.3 KiB
Python
63 lines
2.3 KiB
Python
# coding=utf8
|
|
from __future__ import unicode_literals, absolute_import, division, print_function
|
|
"""
|
|
This is the SpiceBot Events system.
|
|
"""
|
|
import sopel
|
|
from threading import Thread
|
|
|
|
import sopel_modules.SpiceBot as SpiceBot
|
|
|
|
|
|
@sopel.module.event(SpiceBot.events.BOT_WELCOME, SpiceBot.events.BOT_READY, SpiceBot.events.BOT_CONNECTED, SpiceBot.events.BOT_LOADED)
|
|
@sopel.module.rule('.*')
|
|
def bot_events_complete(bot, trigger):
|
|
"""This is here simply to log to stderr that this was recieved."""
|
|
SpiceBot.logs.log('SpiceBot_Events', trigger.args[1], True)
|
|
|
|
|
|
@sopel.module.event(SpiceBot.events.RPL_WELCOME)
|
|
@sopel.module.rule('.*')
|
|
def bot_events_connected(bot, trigger):
|
|
|
|
# Handling for connection count
|
|
SpiceBot.events.dict["RPL_WELCOME_Count"] += 1
|
|
if SpiceBot.events.dict["RPL_WELCOME_Count"] > 1:
|
|
SpiceBot.events.trigger(bot, SpiceBot.events.BOT_RECONNECTED, "Bot ReConnected to IRC")
|
|
else:
|
|
SpiceBot.events.trigger(bot, SpiceBot.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(SpiceBot.events.dict["trigger_queue"]):
|
|
pretriggerdict = SpiceBot.events.dict["trigger_queue"][0]
|
|
SpiceBot.events.dispatch(bot, pretriggerdict)
|
|
try:
|
|
del SpiceBot.events.dict["trigger_queue"][0]
|
|
except IndexError:
|
|
pass
|
|
|
|
|
|
@sopel.module.event(SpiceBot.events.BOT_WELCOME)
|
|
@sopel.module.rule('.*')
|
|
def bot_events_start(bot, trigger):
|
|
"""This stage is redundant, but shows the system is working."""
|
|
SpiceBot.events.trigger(bot, SpiceBot.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
|
|
SpiceBot.events.trigger(bot, SpiceBot.events.BOT_CONNECTED, "Bot Connected to IRC")
|
|
|
|
|
|
@SpiceBot.events.startup_check_ready()
|
|
@sopel.module.event(SpiceBot.events.BOT_READY)
|
|
@sopel.module.rule('.*')
|
|
def bot_events_startup_complete(bot, trigger):
|
|
"""All events registered as required for startup have completed"""
|
|
SpiceBot.events.trigger(bot, SpiceBot.events.BOT_LOADED, "All registered modules setup procedures have completed")
|