Use < and > in stream logger for send/recv resp.

diff --git a/kamaki/cli/__init__.py b/kamaki/cli/__init__.py
index 4576ee7..fbac2d7 100644 (file)
--- a/kamaki/cli/__init__.py
+++ b/kamaki/cli/__init__.py
@@ -173,17 +173,18 @@ def _setup_logging(silent=False, debug=False, verbose=False, include=False):
         add_stream_logger(__name__, logging.CRITICAL)
         return
 
+    sfmt, rfmt = '> %(message)s', '< %(message)s'
     if debug:
-        add_stream_logger('kamaki.clients.send', logging.DEBUG)
-        add_stream_logger('kamaki.clients.recv', logging.DEBUG)
+        add_stream_logger('kamaki.clients.send', logging.DEBUG, sfmt)
+        add_stream_logger('kamaki.clients.recv', logging.DEBUG, rfmt)
         add_stream_logger(__name__, logging.DEBUG)
     elif verbose:
-        add_stream_logger('kamaki.clients.send', logging.INFO)
-        add_stream_logger('kamaki.clients.recv', logging.INFO)
+        add_stream_logger('kamaki.clients.send', logging.INFO, sfmt)
+        add_stream_logger('kamaki.clients.recv', logging.INFO, rfmt)
         add_stream_logger(__name__, logging.INFO)
     if include:
-        add_stream_logger('kamaki.clients.send', logging.INFO)
-        add_stream_logger('kamaki.clients.recv', logging.INFO)
+        add_stream_logger('kamaki.clients.send', logging.INFO, sfmt)
+        add_stream_logger('kamaki.clients.recv', logging.INFO, rfmt)
     add_stream_logger(__name__, logging.WARNING)
     global kloger
     kloger = get_logger(__name__)

diff --git a/kamaki/logger.py b/kamaki/logger.py
index 9648a58..53bc8ee 100644 (file)
--- a/kamaki/logger.py
+++ b/kamaki/logger.py
@@ -76,9 +76,9 @@ def add_file_logger(name, level=None, filename=None):
         return get_logger(name)
 
 
-def add_stream_logger(name, level=None):
+def add_stream_logger(name, level=None, fmt=None):
     try:
-        return _add_logger(name, level)
+        return _add_logger(name, level, fmt=fmt)
     except Exception:
         return get_logger(name)