[event] add logger

Author: rande

ioc/event.py

@@ -35,22 +35,32 @@ def has(self, name):
         return name in self.data
 
 class Dispatcher(object):
-    def __init__(self):
+    def __init__(self, logger=None):
         self.listeners = {}
+        self.logger = logger
 
     def dispatch(self, name, event=None):
         if isinstance(event, dict):
             event = Event(event)
 
         event = event or Event()
 
+        if self.logger:
+            self.logger.debug("event.dispatch: %s" % name)
+
         if name not in self.listeners:
             return event
 
         for listener in self.get_listeners(name):
+            if self.logger:
+                self.logger.debug("event.dispatch: %s to %s" % (name, listener))
+
             listener(event)
 
             if event.stop_propagation():
+                if self.logger:
+                    self.logger.debug("event.dispatch: %s is stopped" % name)
+
                 break
 
         return event

ioc/extra/event/di.py

@@ -18,7 +18,10 @@
 
 class Extension(ioc.component.Extension):
     def load(self, config, container_builder):
-        container_builder.add('ioc.extra.event_dispatcher', ioc.component.Definition('ioc.event.Dispatcher'))
+        definition = ioc.component.Definition('ioc.event.Dispatcher', kwargs={
+            'logger': ioc.component.Reference('logger')
+        })
+        container_builder.add('ioc.extra.event_dispatcher', definition)
 
     def post_build(self, container_builder, container):
         dispatcher = container.get('ioc.extra.event_dispatcher')

ioc/extra/tornado/command.py

@@ -31,7 +31,6 @@ def initialize(self, parser):
         parser.add_argument('--bind', '-b', default="localhost", type=str, help="bind the router to the provided named (default=localhost)")
 
     def execute(self, args, output):
-
         output.write("Configuring tornado (event: ioc.extra.tornado.start)\n")
 
         self.event_dispatcher.dispatch('ioc.extra.tornado.start', {

ioc/extra/tornado/handler.py

@@ -59,6 +59,9 @@ def get_form_data(self):
     def get_chunk_buffer(self):
         return b"".join(self._write_buffer)
 
+    def has_header(self, name):
+        return name in self._headers
+
     def is_xml_http_request(self):
         return 'X-Requested-With' in self.request.headers and 'XMLHttpRequest' == self.request.headers['X-Requested-With']
 
@@ -142,6 +145,9 @@ def dispatch(self):
             self.finish(result=result)
 
     def prepare(self):
+        if self.logger:
+            self.logger.debug("[ioc.extra.tornado.RouterHandler] prepare request %s" % self.request.uri)
+
         self.event_dispatcher.dispatch('handler.request', {
             'request_handler': self,
             'request': self.request
@@ -152,6 +158,9 @@ def finish(self, *args, **kwargs):
         if 'result' in kwargs:
             result = kwargs['result']
 
+        if self.logger:
+            self.logger.debug("[ioc.extra.tornado.RouterHandler] finish request %s" % self.request.uri)
+
         self.event_dispatcher.dispatch('handler.response', {
             'request_handler': self,
             'request': self.request,
@@ -160,6 +169,9 @@ def finish(self, *args, **kwargs):
 
         super(RouterHandler, self).finish()
 
+        if self.logger:
+            self.logger.debug("[ioc.extra.tornado.RouterHandler] terminate request %s" % self.request.uri)
+
         self.event_dispatcher.dispatch('handler.terminate', {
             'request_handler': self,
             'request': self.request,
@@ -171,6 +183,9 @@ def send_file(self, file):
         """
         mime_type, encoding = mimetypes.guess_type(file)
 
+        if self.logger:
+            self.logger.debug("[ioc.extra.tornado.RouterHandler] send file %s" % file)
+
         if mime_type:
             self.set_header('Content-Type', mime_type)