diff options
| author | Chris McDonough <chrism@agendaless.com> | 2009-11-25 17:54:40 +0000 |
|---|---|---|
| committer | Chris McDonough <chrism@agendaless.com> | 2009-11-25 17:54:40 +0000 |
| commit | 103efb5aae885a70590ad1f3c5807af9da8d1ab7 (patch) | |
| tree | 1b335d2d088b84544f8ef5bad713bc8922674153 /repoze/bfg/zcml.py | |
| parent | 2aa86c1a5227a675d32c4ede06e0c031ae3edfad (diff) | |
| download | pyramid-103efb5aae885a70590ad1f3c5807af9da8d1ab7.tar.gz pyramid-103efb5aae885a70590ad1f3c5807af9da8d1ab7.tar.bz2 pyramid-103efb5aae885a70590ad1f3c5807af9da8d1ab7.zip | |
- A dependency on the ``repoze.zcml`` package has been removed (its
functionality is replaced internally).
Diffstat (limited to 'repoze/bfg/zcml.py')
| -rw-r--r-- | repoze/bfg/zcml.py | 230 |
1 files changed, 230 insertions, 0 deletions
diff --git a/repoze/bfg/zcml.py b/repoze/bfg/zcml.py index b97456668..91252ff53 100644 --- a/repoze/bfg/zcml.py +++ b/repoze/bfg/zcml.py @@ -1,9 +1,15 @@ +from zope.component import adaptedBy + from zope.configuration.exceptions import ConfigurationError +from zope.configuration.fields import GlobalInterface from zope.configuration.fields import GlobalObject +from zope.configuration.fields import Tokens from zope.configuration.config import ConfigurationMachine from zope.configuration import xmlconfig from zope.interface import Interface +from zope.interface import implementedBy +from zope.interface import providedBy from zope.schema import Bool from zope.schema import Int @@ -524,3 +530,227 @@ def zcml_configure(name, package): file_configure = zcml_configure # backwards compat (>0.8.1) +def handler(methodName, *args, **kwargs): + registry = get_current_registry() + method = getattr(registry, methodName) + method(*args, **kwargs) + +def adapter(_context, factory, provides=None, for_=None, name=''): + + if for_ is None: + if len(factory) == 1: + for_ = adaptedBy(factory[0]) + + if for_ is None: + raise TypeError("No for attribute was provided and can't " + "determine what the factory adapts.") + + for_ = tuple(for_) + + if provides is None: + if len(factory) == 1: + p = list(implementedBy(factory[0])) + if len(p) == 1: + provides = p[0] + + if provides is None: + raise TypeError("Missing 'provides' attribute") + + # Generate a single factory from multiple factories: + factories = factory + if len(factories) == 1: + factory = factories[0] + elif len(factories) < 1: + raise ValueError("No factory specified") + elif len(factories) > 1 and len(for_) != 1: + raise ValueError("Can't use multiple factories and multiple for") + else: + factory = _rolledUpFactory(factories) + + _context.action( + discriminator = ('adapter', for_, provides, name), + callable = handler, + args = ('registerAdapter', + factory, for_, provides, name, _context.info), + ) + +class IAdapterDirective(Interface): + """ + Register an adapter + """ + + factory = Tokens( + title=u"Adapter factory/factories", + description=(u"A list of factories (usually just one) that create" + " the adapter instance."), + required=True, + value_type=GlobalObject() + ) + + provides = GlobalInterface( + title=u"Interface the component provides", + description=(u"This attribute specifies the interface the adapter" + " instance must provide."), + required=False, + ) + + for_ = Tokens( + title=u"Specifications to be adapted", + description=u"This should be a list of interfaces or classes", + required=False, + value_type=GlobalObject( + missing_value=object(), + ), + ) + + name = TextLine( + title=u"Name", + description=(u"Adapters can have names.\n\n" + "This attribute allows you to specify the name for" + " this adapter."), + required=False, + ) + +_handler = handler +def subscriber(_context, for_=None, factory=None, handler=None, provides=None): + if factory is None: + if handler is None: + raise TypeError("No factory or handler provided") + if provides is not None: + raise TypeError("Cannot use handler with provides") + factory = handler + else: + if handler is not None: + raise TypeError("Cannot use handler with factory") + if provides is None: + raise TypeError( + "You must specify a provided interface when registering " + "a factory") + + if for_ is None: + for_ = adaptedBy(factory) + if for_ is None: + raise TypeError("No for attribute was provided and can't " + "determine what the factory (or handler) adapts.") + + for_ = tuple(for_) + + if handler is not None: + _context.action( + discriminator = None, + callable = _handler, + args = ('registerHandler', + handler, for_, u'', _context.info), + ) + else: + _context.action( + discriminator = None, + callable = _handler, + args = ('registerSubscriptionAdapter', + factory, for_, provides, u'', _context.info), + ) + +class ISubscriberDirective(Interface): + """ + Register a subscriber + """ + + factory = GlobalObject( + title=u"Subscriber factory", + description=u"A factory used to create the subscriber instance.", + required=False, + ) + + handler = GlobalObject( + title=u"Handler", + description=u"A callable object that handles events.", + required=False, + ) + + provides = GlobalInterface( + title=u"Interface the component provides", + description=(u"This attribute specifies the interface the adapter" + " instance must provide."), + required=False, + ) + + for_ = Tokens( + title=u"Interfaces or classes that this subscriber depends on", + description=u"This should be a list of interfaces or classes", + required=False, + value_type=GlobalObject( + missing_value = object(), + ), + ) + +def utility(_context, provides=None, component=None, factory=None, name=''): + if factory and component: + raise TypeError("Can't specify factory and component.") + + if provides is None: + if factory: + provides = list(implementedBy(factory)) + else: + provides = list(providedBy(component)) + if len(provides) == 1: + provides = provides[0] + else: + raise TypeError("Missing 'provides' attribute") + + if factory: + kw = dict(factory=factory) + else: + # older zope.component registries don't accept factory as a kwarg, + # so if we don't need it, we don't pass it + kw = {} + + _context.action( + discriminator = ('utility', provides, name), + callable = handler, + args = ('registerUtility', component, provides, name), + kw = kw, + ) + +class IUtilityDirective(Interface): + """Register a utility.""" + + component = GlobalObject( + title=u"Component to use", + description=(u"Python name of the implementation object. This" + " must identify an object in a module using the" + " full dotted name. If specified, the" + " ``factory`` field must be left blank."), + required=False, + ) + + factory = GlobalObject( + title=u"Factory", + description=(u"Python name of a factory which can create the" + " implementation object. This must identify an" + " object in a module using the full dotted name." + " If specified, the ``component`` field must" + " be left blank."), + required=False, + ) + + provides = GlobalInterface( + title=u"Provided interface", + description=u"Interface provided by the utility.", + required=False, + ) + + name = TextLine( + title=u"Name", + description=(u"Name of the registration. This is used by" + " application code when locating a utility."), + required=False, + ) + +def _rolledUpFactory(factories): + def factory(ob): + for f in factories: + ob = f(ob) + return ob + # Store the original factory for documentation + factory.factory = factories[0] + return factory |
