Add the event dispatcher as an extension

Author: rande

docs/extra.rst

@@ -111,4 +111,13 @@ Services available:
 .. _Flask: http://flask.pocoo.org/
 .. _Redis-Py: https://github.com/andymccurdy/redis-py
 .. _Redis: http://redis.io/
-.. _Twisted: http://twistedmatrix.com/
+.. _Twisted: http://twistedmatrix.com/
+
+Event Dispatcher
+----------------
+
+The IoC package includes a small event dispatcher, you can include it by adding this yaml.
+
+.. code-block:: yaml
+
+    ioc.extra.event:

ioc/component.py

@@ -16,7 +16,7 @@ def post_load(self, container_builder, container):
     def pre_build(self, container_builder, container):
         pass
 
-    def post_build(self, container):
+    def post_build(self, container_builder, container):
         pass
 
     def start(self, container):
@@ -196,7 +196,7 @@ def build_container(self, container):
             self.get_service(id, definition, container)
 
         for extension in extensions:
-            extension.post_build(container)
+            extension.post_build(self, container)
 
         if self.logger:
             self.logger.debug("Building container is over!")

ioc/extra/event/__init__.py

@@ -0,0 +1,20 @@
+import ioc.loader, ioc.component, ioc.exceptions
+import os, datetime
+
+class Extension(ioc.component.Extension):
+    def load(self, config, container_builder):
+        container_builder.add('ioc.extra.event_dispatcher', ioc.component.Definition('ioc.event.Dispatcher'))
+
+    def post_build(self, container_builder, container):
+        dispatcher = container.get('ioc.extra.event_dispatcher')
+
+        for id in container_builder.get_ids_by_tag('event.listener'):
+            definition = container_builder.get(id)
+            for option in definition.get_tag('event.listener'):
+                if 'name' not in option:
+                    break
+
+                if 'method' not in option:
+                    break                
+
+                dispatcher.add_listener(option['name'], getattr(container.get(id), option['method']))

ioc/extra/event/di.py

@@ -67,11 +67,35 @@ def configure_blueprint(self, config, container_builder):
         for id, kwargs in config.get_dict('blueprints', {}).all().iteritems():
             definition.add_call('register_blueprint', [ioc.component.Reference(id)], kwargs.all())
 
-    def post_build(self, container):
+    def post_build(self, container_builder, container):
+
         if container.has('jinja.env'):
             raise ioc.exceptions.DuplicateServiceDefinition()
 
-        container.set('jinja.env', container.get('ioc.extra.flask.app').jinja_env)
-        container.set('jinja.loader', container.get('ioc.extra.flask.app').jinja_loader)
+        container.add('jinja.env', container.get('ioc.extra.flask.app').jinja_env)
+        container.add('jinja.loader', container.get('ioc.extra.flask.app').jinja_loader)
+
+        # Attach jinja helper to the dedicated instance
+        # TODO: create a proper jinja extra and overwrite the default Flask App to use this
+        #       a clean jinja instance
+        for id in container_builder.get_ids_by_tag('jinja.filter'):
+            definition = container_builder.get(id)
+            for option in definition.get_tag('jinja.filter'):
+                if 'name' not in option:
+                    break
+
+                if 'method' not in option:
+                    break                
+
+                container.get('jinja.env').filters[option['name']] = getattr(container.get(id), option['method'])
+
+        for id in container_builder.get_ids_by_tag('jinja.global'):
+            definition = container_builder.get(id)
+            for option in definition.get_tag('jinja.global'):
+                if 'name' not in option:
+                    break
 
+                if 'method' not in option:
+                    break                
 
+                container.get('jinja.env').globals[option['name']] = getattr(container.get(id), option['method'])

ioc/extra/flask/di.py

@@ -7,7 +7,7 @@ def load(self, config, container_builder):
             'default': 'ioc.extra.redis.client.default' 
         }).all())
 
-    def post_build(self, container):
+    def post_build(self, container_builder, container):
         import redis_wrap
 
         for name, id in container.parameters.get('ioc.extra.redis_wrap.clients').iteritems():

ioc/extra/redis_wrap/di.py

@@ -65,8 +65,7 @@ def build(files, logger=None, parameters=None):
         }
 
     container_builder = ioc.component.ContainerBuilder(logger=logger)
-    container_builder.add('event_dispatcher', ioc.component.Definition('ioc.event.Dispatcher'))
-    
+        
     loaders = [
         ioc.loader.YamlLoader()
     ]

ioc/helper.py

@@ -13,7 +13,7 @@ def test_build(self):
             "%s/../fixtures/services.yml" % current_dir
         ], parameters={'inline': 'parameter'})
 
-        self.assertEquals(5, len(container.services))
+        self.assertEquals(4, len(container.services))
         self.assertEquals(container.get('foo').fake, container.get('fake'))
         self.assertEquals('argument 1', container.get('fake').mandatory)