1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
"""
The service registry is the place where services can be registered and
retrieved.
Our good old NameServicer.
"""
from zope import interface, component
from logging import getLogger
from gaphor.interfaces import IService
from gaphor.core import inject
class ServiceRegistry(object):
component_registry = inject('component_registry')
logger = getLogger('ServiceRegistry')
def __init__(self):
self._uninitialized_services = {}
def init(self, app=None):
self.logger.info('Starting')
def shutdown(self):
self.logger.info('Shutting down')
def load_services(self, services=None):
"""
Load services from resources.
Services are registered as utilities in zope.component.
Service should provide an interface gaphor.interfaces.IService.
"""
self.logger.info('Loading services')
for ep in pkg_resources.iter_entry_points('gaphor.services'):
cls = ep.load()
if not IService.implementedBy(cls):
raise 'MisConfigurationException', 'Entry point %s doesn''t provide IService' % ep.name
if services is None or ep.name in services:
srv = cls()
self._uninitialized_services[ep.name] = srv
def init_all_services(self):
self.logger.info('Initializing services')
while self._uninitialized_services:
self.init_service(self._uninitialized_services.iterkeys().next())
def init_service(self, name):
"""
Initialize a not yet initialized service.
Raises ComponentLookupError if the service has nor been found
"""
self.logger.info('Initializing service')
self.logger.debug('Service name is %s' % name)
try:
srv = self._uninitialized_services.pop(name)
except KeyError:
raise component.ComponentLookupError(IService, name)
else:
srv.init(self)
self.component_registry.register_utility(srv, IService, name)
self.handle(ServiceInitializedEvent(name, srv))
return srv
def get_service(self, name):
try:
return self.component_registry.get_utility(IService, name)
except component.ComponentLookupError:
return self.init_service(name)
# vim: sw=4:et:ai
|
