mirror of
https://github.com/evennia/evennia.git
synced 2026-03-19 14:26:30 +01:00
108 lines
No EOL
3.1 KiB
Python
108 lines
No EOL
3.1 KiB
Python
import time
|
|
from twisted.internet import task
|
|
import events
|
|
"""
|
|
This file contains the event scheduler system.
|
|
|
|
ADDING AN EVENT:
|
|
* Create an event function to call.
|
|
* Add an entry to the 'schedule' dictionary here.
|
|
* Profit.
|
|
"""
|
|
|
|
# Dictionary of events with a list in the form of:
|
|
# [<function>, <interval>, <lastrantime>, <taskobject>, <description>]
|
|
schedule = {
|
|
'evt_check_sessions': [events.evt_check_sessions, 60, time.time(), None, "Session consistency checks."]
|
|
}
|
|
|
|
def start_events():
|
|
"""
|
|
Start the event system, which is built on Twisted's framework.
|
|
"""
|
|
for event in schedule:
|
|
event_func = get_event_function(event)
|
|
|
|
if callable(event_func):
|
|
# Set the call-back function for the task to trigger_event, but pass
|
|
# a reference to the event function.
|
|
event_task = task.LoopingCall(trigger_event, event_func, event)
|
|
# Start the task up with the specified interval.
|
|
event_task.start(get_event_interval(event), now=False)
|
|
# Set a reference to the event's task object in the dictionary so we
|
|
# can re-schedule, start, and stop events from elsewhere.
|
|
set_event_taskobj(event, event_task)
|
|
|
|
def get_event(event_name):
|
|
"""
|
|
Return the relevant entry in the schedule dictionary for the named event.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return schedule.get(event_name, None)
|
|
|
|
def get_event_function(event_name):
|
|
"""
|
|
Return a reference to the event's function.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return get_event(event_name)[0]
|
|
|
|
def get_event_interval(event_name):
|
|
"""
|
|
Return the event's execution interval.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return get_event(event_name)[1]
|
|
|
|
def get_event_nextfire(event_name):
|
|
"""
|
|
Returns a value in seconds when the event is going to fire off next.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return (get_event(event_name)[2]+get_event_interval(event_name))-time.time()
|
|
|
|
def get_event_taskobj(event_name):
|
|
"""
|
|
Returns an event's task object.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return get_event(event_name)[3]
|
|
|
|
def get_event_description(event_name):
|
|
"""
|
|
Returns an event's description.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
return get_event(event_name)[4]
|
|
|
|
def set_event_taskobj(event_name, taskobj):
|
|
"""
|
|
Sets an event's task object.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
get_event(event_name)[3] = taskobj
|
|
|
|
def set_event_lastfired(event_name):
|
|
"""
|
|
Sets an event's last fired time.
|
|
|
|
event_name: (string) The key of the event in the schedule dictionary.
|
|
"""
|
|
get_event(event_name)[2] = time.time()
|
|
|
|
def trigger_event(event_func, event_name):
|
|
"""
|
|
Update the last ran time and fire off the event.
|
|
|
|
event_func: (func_reference) Reference to the event function to fire.
|
|
eventname: (string) The name of the event (as per schedule dict).
|
|
"""
|
|
event_func()
|
|
set_event_lastfired(event_name) |