urlbot-native-trex/events.py

# -*- coding: utf-8 -*-
import time
import sched
import threading

EVENTLOOP_DELAY = 0.100  # seconds

event_list = sched.scheduler(time.time, time.sleep)


def register_active_event(t, callback, args, action_runner, plugin, msg_obj):
    """
    Execute a callback at a given time and react on the output

    :param t: when to execute the job
    :param callback: the function to execute
    :param args: parameters for said function
    :param action_runner: bots action dict parser
    :param plugin: pass-through object for action parser
    :param msg_obj: pass-through object for action parser
    :return:
    """
    def func(func_args):
        action = callback(*func_args)
        if action:
            action_runner(action=action, plugin=plugin, msg_obj=msg_obj)
    event_list.enterabs(t, 0, func, args)


def register_event(t, callback, args):
    event_list.enterabs(t, 0, callback, args)


class EventLoop(threading.Thread):
    def run(self):
        while 1:
            event_list.run(False)
            time.sleep(EVENTLOOP_DELAY)

event_loop = EventLoop()