forked from openlp/openlp
73 lines
2.4 KiB
Python
73 lines
2.4 KiB
Python
# -*- coding: utf-8 -*-
|
|
# vim: autoindent shiftwidth=4 expandtab textwidth=80
|
|
"""
|
|
OpenLP - Open Source Lyrics Projection
|
|
|
|
Copyright (c) 2008 Raoul Snyman
|
|
|
|
Portions copyright (c) 2008-2009 Martin Thompson, Tim Bentley, Scott Guerreri,
|
|
Carsten Tingaard, Jonathan Corwin
|
|
|
|
This program is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU General Public License as published by the Free Software
|
|
Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful, but WITHOUT ANY
|
|
WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
|
|
PARTICULAR PURPOSE. See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc., 59 Temple
|
|
Place, Suite 330, Boston, MA 02111-1307 USA
|
|
"""
|
|
import os
|
|
import logging
|
|
|
|
class EventManager(object):
|
|
"""
|
|
A mechanism to send events to all registered endpoints. The
|
|
endpoints are registered and listen with a handle_event method.
|
|
The endpoint will decide whether to do somthing with the event or
|
|
ignore it.
|
|
"""
|
|
global log
|
|
log = logging.getLogger(u'EventManager')
|
|
|
|
def __init__(self):
|
|
"""
|
|
Defines the class and a list of endpoints
|
|
"""
|
|
self.endpoints = []
|
|
log.info(u'Initialising')
|
|
self.processing = False
|
|
self.events = []
|
|
|
|
def register(self, plugin):
|
|
"""
|
|
Called by plugings who wish to receive event notifications
|
|
"""
|
|
log.debug(u'Class %s registered with EventManager', plugin)
|
|
self.endpoints.append(plugin)
|
|
|
|
def post_event(self, event):
|
|
"""
|
|
Called by any part of the system which wants send events to the plugins
|
|
|
|
``event``
|
|
The event type to be triggered
|
|
|
|
"""
|
|
log.debug(u'post event called for event %s (%s)', event.event_type, event.sender)
|
|
self.events.append(event)
|
|
if not self.processing:
|
|
self.processing = True
|
|
while len(self.events) > 0:
|
|
pEvent = self.events[0]
|
|
for point in self.endpoints:
|
|
status = point.handle_event(pEvent)
|
|
#if call returns true message is finished with
|
|
if status is not None and status :
|
|
break
|
|
self.events.remove(pEvent)
|
|
self.processing = False
|