Fixed so that all logging are presented as one time line. Also for sp_test.
This commit is contained in:
@@ -50,20 +50,11 @@ cf.start()
|
|||||||
streamhandler = logging.StreamHandler(sys.stderr)
|
streamhandler = logging.StreamHandler(sys.stderr)
|
||||||
streamhandler.setFormatter(formatter_2)
|
streamhandler.setFormatter(formatter_2)
|
||||||
|
|
||||||
# pys_memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
||||||
# pys_memoryhandler.setFormatter(formatter_2)
|
memoryhandler.addFilter(cf)
|
||||||
# pys_memoryhandler.addFilter(cf)
|
|
||||||
# root_logger.addHandler(pys_memoryhandler)
|
|
||||||
# root_logger.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
t_memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
|
||||||
t_memoryhandler.addFilter(cf)
|
|
||||||
logger.addHandler(t_memoryhandler)
|
|
||||||
logger.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
saml2testlog = logging.getLogger("saml2test")
|
saml2testlog = logging.getLogger("saml2test")
|
||||||
saml2testlog.addHandler(t_memoryhandler)
|
saml2testlog.addHandler(memoryhandler)
|
||||||
saml2testlog.setLevel(logging.DEBUG)
|
saml2testlog.setLevel(logging.DEBUG)
|
||||||
|
|
||||||
|
|
||||||
@@ -260,7 +251,7 @@ class SAML2client(object):
|
|||||||
self.args = self._parser.parse_args()
|
self.args = self._parser.parse_args()
|
||||||
|
|
||||||
if self.args.pysamllog:
|
if self.args.pysamllog:
|
||||||
root_logger.addHandler(t_memoryhandler)
|
root_logger.addHandler(memoryhandler)
|
||||||
root_logger.setLevel(logging.DEBUG)
|
root_logger.setLevel(logging.DEBUG)
|
||||||
|
|
||||||
if self.args.operations:
|
if self.args.operations:
|
||||||
@@ -343,7 +334,7 @@ class SAML2client(object):
|
|||||||
print >> sys.stdout, json.dumps(tsum)
|
print >> sys.stdout, json.dumps(tsum)
|
||||||
|
|
||||||
if tsum["status"] > 1 or self.args.debug or err:
|
if tsum["status"] > 1 or self.args.debug or err:
|
||||||
self.output_log(t_memoryhandler, streamhandler)
|
self.output_log(memoryhandler, streamhandler)
|
||||||
|
|
||||||
def list_operations(self):
|
def list_operations(self):
|
||||||
lista = []
|
lista = []
|
||||||
|
@@ -1,4 +1,5 @@
|
|||||||
import json
|
import json
|
||||||
|
import pprint
|
||||||
import argparse
|
import argparse
|
||||||
import sys
|
import sys
|
||||||
from importlib import import_module
|
from importlib import import_module
|
||||||
@@ -21,33 +22,22 @@ from saml2test import exception_trace
|
|||||||
|
|
||||||
__author__ = 'rolandh'
|
__author__ = 'rolandh'
|
||||||
|
|
||||||
formatter_2 = logging.Formatter(
|
#formatter = logging.Formatter("%(asctime)s %(name)s:%(levelname)s %(message)s")
|
||||||
"%(delta).6f - %(levelname)s - [%(name)s] %(message)s")
|
formatter_2 = logging.Formatter("%(delta).6f - %(levelname)s - [%(name)s] %(message)s")
|
||||||
|
|
||||||
cf = ContextFilter()
|
cf = ContextFilter()
|
||||||
cf.start()
|
cf.start()
|
||||||
|
|
||||||
|
streamhandler = logging.StreamHandler(sys.stderr)
|
||||||
|
streamhandler.setFormatter(formatter_2)
|
||||||
|
|
||||||
memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
||||||
|
memoryhandler.addFilter(cf)
|
||||||
|
|
||||||
pys_streamhandler = logging.StreamHandler(sys.stderr)
|
logger = logging.getLogger(__name__)
|
||||||
pys_streamhandler.setFormatter(formatter_2)
|
logger.setLevel(logging.DEBUG)
|
||||||
|
logger.addHandler(memoryhandler)
|
||||||
pys_memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
logger.setLevel(logging.DEBUG)
|
||||||
pys_memoryhandler.setFormatter(formatter_2)
|
|
||||||
pys_memoryhandler.addFilter(cf)
|
|
||||||
root_logger.addHandler(pys_memoryhandler)
|
|
||||||
root_logger.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
tracelog = logging.getLogger(__name__)
|
|
||||||
t_memoryhandler = logging.handlers.MemoryHandler(1024*10, logging.DEBUG)
|
|
||||||
t_memoryhandler.addFilter(cf)
|
|
||||||
tracelog.addHandler(t_memoryhandler)
|
|
||||||
tracelog.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
saml2testlog = logging.getLogger("saml2test")
|
|
||||||
saml2testlog.addHandler(t_memoryhandler)
|
|
||||||
saml2testlog.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
|
|
||||||
class Client(object):
|
class Client(object):
|
||||||
|
|
||||||
@@ -82,6 +72,7 @@ class Client(object):
|
|||||||
help="Module describing tests")
|
help="Module describing tests")
|
||||||
self._parser.add_argument("-Y", dest="pysamllog", action='store_true',
|
self._parser.add_argument("-Y", dest="pysamllog", action='store_true',
|
||||||
help="Print PySAML2 logs")
|
help="Print PySAML2 logs")
|
||||||
|
self._parser.add_argument("-H", dest="pretty", action='store_true')
|
||||||
self._parser.add_argument("oper", nargs="?", help="Which test to run")
|
self._parser.add_argument("oper", nargs="?", help="Which test to run")
|
||||||
|
|
||||||
self.interactions = None
|
self.interactions = None
|
||||||
@@ -137,6 +128,10 @@ class Client(object):
|
|||||||
def run(self):
|
def run(self):
|
||||||
self.args = self._parser.parse_args()
|
self.args = self._parser.parse_args()
|
||||||
|
|
||||||
|
if self.args.pysamllog:
|
||||||
|
root_logger.addHandler(memoryhandler)
|
||||||
|
root_logger.setLevel(logging.DEBUG)
|
||||||
|
|
||||||
if self.args.metadata:
|
if self.args.metadata:
|
||||||
return self.make_meta()
|
return self.make_meta()
|
||||||
elif self.args.list:
|
elif self.args.list:
|
||||||
@@ -166,6 +161,12 @@ class Client(object):
|
|||||||
|
|
||||||
opers = oper["sequence"]
|
opers = oper["sequence"]
|
||||||
|
|
||||||
|
if self.args.pretty:
|
||||||
|
pp = pprint.PrettyPrinter(indent=4)
|
||||||
|
else:
|
||||||
|
pp = None
|
||||||
|
|
||||||
|
logger.info("Starting conversation")
|
||||||
conv = Conversation(self.idp, self.idp_config,
|
conv = Conversation(self.idp, self.idp_config,
|
||||||
self.interactions, self.json_config,
|
self.interactions, self.json_config,
|
||||||
check_factory=self.check_factory,
|
check_factory=self.check_factory,
|
||||||
@@ -175,12 +176,10 @@ class Client(object):
|
|||||||
conv.do_sequence(opers, oper["tests"])
|
conv.do_sequence(opers, oper["tests"])
|
||||||
self.test_log = conv.test_output
|
self.test_log = conv.test_output
|
||||||
tsum = self.test_summation(self.args.oper)
|
tsum = self.test_summation(self.args.oper)
|
||||||
print >>sys.stdout, json.dumps(tsum)
|
|
||||||
err = None
|
err = None
|
||||||
except CheckError, err:
|
except CheckError, err:
|
||||||
self.test_log = conv.test_output
|
self.test_log = conv.test_output
|
||||||
tsum = self.test_summation(self.args.oper)
|
tsum = self.test_summation(self.args.oper)
|
||||||
print >>sys.stdout, json.dumps(tsum)
|
|
||||||
except FatalError, err:
|
except FatalError, err:
|
||||||
if conv:
|
if conv:
|
||||||
self.test_log = conv.test_output
|
self.test_log = conv.test_output
|
||||||
@@ -188,7 +187,6 @@ class Client(object):
|
|||||||
else:
|
else:
|
||||||
self.test_log = exception_trace("RUN", err)
|
self.test_log = exception_trace("RUN", err)
|
||||||
tsum = self.test_summation(self.args.oper)
|
tsum = self.test_summation(self.args.oper)
|
||||||
print >>sys.stdout, json.dumps(tsum)
|
|
||||||
except Exception, err:
|
except Exception, err:
|
||||||
if conv:
|
if conv:
|
||||||
self.test_log = conv.test_output
|
self.test_log = conv.test_output
|
||||||
@@ -196,13 +194,14 @@ class Client(object):
|
|||||||
else:
|
else:
|
||||||
self.test_log = exception_trace("RUN", err)
|
self.test_log = exception_trace("RUN", err)
|
||||||
tsum = self.test_summation(self.args.oper)
|
tsum = self.test_summation(self.args.oper)
|
||||||
print >>sys.stdout, json.dumps(tsum)
|
|
||||||
|
|
||||||
if self.args.pysamllog:
|
if pp:
|
||||||
self.output_log(pys_memoryhandler, pys_streamhandler)
|
pp.pprint(tsum)
|
||||||
|
else:
|
||||||
|
print >> sys.stdout, json.dumps(tsum)
|
||||||
|
|
||||||
if tsum["status"] > 1 or self.args.debug or err:
|
if tsum["status"] > 1 or self.args.debug or err:
|
||||||
self.output_log(t_memoryhandler, pys_streamhandler)
|
self.output_log(memoryhandler, streamhandler)
|
||||||
|
|
||||||
def setup(self):
|
def setup(self):
|
||||||
self.json_config = self.json_config_file()
|
self.json_config = self.json_config_file()
|
||||||
|
Reference in New Issue
Block a user