Add decoding to the events

Signed-off-by: Christophe Labouisse <[email protected]>

Author: ggtools

docker/client.py

@@ -292,7 +292,7 @@ def _get_raw_response_socket(self, response):
 
         return sock
 
-    def _stream_helper(self, response):
+    def _stream_helper(self, response, decode=False):
         """Generator for data coming from a chunked-encoded HTTP response."""
         if response.raw._fp.chunked:
             reader = response.raw
@@ -303,6 +303,8 @@ def _stream_helper(self, response):
                     break
                 if reader._fp.chunk_left:
                     data += reader.read(reader._fp.chunk_left)
+                if decode:
+                    data = json.loads(data)
                 yield data
         else:
             # Response isn't chunked, meaning we probably
@@ -584,7 +586,8 @@ def events(self, since=None, until=None, filters=None):
         }
 
         return self._stream_helper(self.get(self._url('/events'),
-                                            params=params, stream=True))
+                                            params=params, stream=True),
+                                   decode=True)
 
     def execute(self, container, cmd, detach=False, stdout=True, stderr=True,
                 stream=False, tty=False):

docs/api.md

@@ -245,10 +245,10 @@ function return a blocking generator you can iterate over to retrieve events as
 **Returns** (generator):
 
 ```python
-{"status":"die",
-"id":"container-id",
-"from":"image/with:tag",
-"time":unix-timestamp}
+{u'status': u'start',
+ u'from': u'image/with:tag',
+ u'id': u'container-id',
+ u'time': 1423339459}
 ```
 
 ## execute