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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
import threading
import zope.component
from zope.component import getGlobalSiteManager
from zope.component import getSiteManager as original_getSiteManager
from zope.component.interfaces import ComponentLookupError
from zope.component.interfaces import IComponentLookup
from zope.component.registry import Components
from zope.deprecation import deprecated
from repoze.bfg.threadlocal import manager
from repoze.bfg.zcml import zcml_configure
from repoze.bfg.settings import Settings # alias for deprecation below
deprecated('Settings',
"('from repoze.bfg.registry import Settings' is now "
"deprecated; instead use 'from repoze.bfg.settings import Settings')",
)
from repoze.bfg.settings import get_options # alias for deprecation below
deprecated('get_options',
"('from repoze.bfg.registry import get_options' is now "
"deprecated; instead use 'from repoze.bfg.settings import get_options')",
)
class Registry(Components):
# for optimization purposes, if no listeners are listening, don't try
# to notify them
has_listeners = False
def registerSubscriptionAdapter(self, *arg, **kw):
result = Components.registerSubscriptionAdapter(self, *arg, **kw)
self.has_listeners = True
return result
def registerHandler(self, *arg, **kw):
result = Components.registerHandler(self, *arg, **kw)
self.has_listeners = True
return result
def notify(self, *events):
if self.has_listeners:
# iterating over subscribers assures they get executed
for ignored in self.subscribers(events, None):
""" """
def get_registry():
return manager.get()['registry']
def populateRegistry(registry, filename, package, lock=threading.Lock()):
""" We push our ZCML-defined configuration into an app-local
component registry in order to allow more than one bfg app to live
in the same process space without one unnecessarily stomping on
the other's component registrations (although I suspect directives
that have side effects are going to fail). The only way to do
that currently is to override zope.component.getGlobalSiteManager
for the duration of the ZCML includes. We acquire a lock in case
another make_app runs in a different thread simultaneously, in a
vain attempt to prevent mixing of registrations. There's not much
we can do about non-makeRegistry code that tries to use the global
site manager API directly in a different thread while we hold the
lock. Those registrations will end up in our application's
registry."""
lock.acquire()
manager.push({'registry':registry, 'request':None})
try:
original_getSiteManager.sethook(getSiteManager)
zope.component.getGlobalSiteManager = get_registry
zcml_configure(filename, package)
finally:
zope.component.getGlobalSiteManager = getGlobalSiteManager
lock.release()
manager.pop()
def getSiteManager(context=None):
if context is None:
return get_registry()
else:
try:
return IComponentLookup(context)
except TypeError, error:
raise ComponentLookupError(*error.args)
class FakeRegistryManager(object):
def push(self, registry):
return manager.push({'registry':registry, 'request':None})
set = push # b/c
def pop(self):
result = manager.pop()
if result:
return result['registry']
def get(self):
return manager.get()['registry']
def clear(self):
manager.clear()
# for use in scripts for backwards compatibility *only*!
registry_manager = FakeRegistryManager()
deprecated('registry_manager',
'As of repoze.bfg 0.9, any import of registry_manager from'
'``repoze.bfg.registry`` is '
'deprecated. Instead, if you are trying to push a BFG '
'application registry into a registry_manager within a "debug" '
'script, call ``app.get_root(environ)``, which has the side '
'effect of pushing the current registry into a thread local '
'stack. ``registry_manager`` will disappear in a later '
'release of repoze.bfg')
|
