commit f5bfad914eeb18dd104aaf44baa58a6502947074 Author: Arturo Filastò arturo@filasto.net Date: Tue Oct 23 10:01:49 2012 +0000
Port Netalyzr test to new API * Make new generation tests work properly --- nettests/third_party/netalyzr.py | 10 +++++----- ooni/nettest.py | 5 +++-- ooni/oonicli.py | 11 ++++++----- ooni/reporter.py | 9 ++++----- ooni/runner.py | 11 +++++------ 5 files changed, 23 insertions(+), 23 deletions(-)
diff --git a/nettests/third_party/netalyzr.py b/nettests/third_party/netalyzr.py index 041c0be..bf94000 100644 --- a/nettests/third_party/netalyzr.py +++ b/nettests/third_party/netalyzr.py @@ -13,15 +13,14 @@ import os
class NetalyzrWrapperTest(nettest.TestCase): name = "NetalyzrWrapper" - type = "wrapper"
def setUp(self): - cwd = os.path.join(os.path.abspath(__file__), '..') + cwd = os.path.abspath(os.path.join(os.path.abspath(__file__), '..'))
# XXX set the output directory to something more uniform outputdir = os.path.join(cwd, '..', '..')
- program_path = os.path.join(cwd, 'NetalyzrCLI') + program_path = os.path.join(cwd, 'NetalyzrCLI.jar') program = "java -jar %s " % program_path
test_token = time.asctime(time.gmtime()).replace(" ", "_").strip() @@ -35,8 +34,9 @@ class NetalyzrWrapperTest(nettest.TestCase): """ This test simply wraps netalyzr and runs it from command line """ - log.msg("running NetalyzrWrapper with command '%s'" % self.run_me) + log.msg("Running NetalyzrWrapper (this will take some time, be patient)") + log.debug("with command '%s'" % self.run_me) os.system(self.run_me) self.report['netalyzr_report'] = self.output_file - log.msg("finished running NetalzrWrapper") + log.debug("finished running NetalzrWrapper")
diff --git a/ooni/nettest.py b/ooni/nettest.py index 768833a..d35bd4d 100644 --- a/ooni/nettest.py +++ b/ooni/nettest.py @@ -1,9 +1,9 @@ import itertools import os
-from twisted.python import log, usage from twisted.trial import unittest, itrial from twisted.internet import defer, utils +from ooni.utils import log
pyunit = __import__('unittest')
@@ -79,9 +79,10 @@ class TestCase(unittest.TestCase):
optParameters = None
- def _run(self, methodName, result): + def _raaun(self, methodName, result): from twisted.internet import reactor method = getattr(self, methodName) + log.debug("Running %s" % methodName) d = defer.maybeDeferred( utils.runWithWarningsSuppressed, self._getSuppress(), method) d.addBoth(lambda x : call.active() and call.cancel() or x) diff --git a/ooni/oonicli.py b/ooni/oonicli.py index ef80c33..5ea92d7 100644 --- a/ooni/oonicli.py +++ b/ooni/oonicli.py @@ -26,7 +26,7 @@ from ooni import nettest, runner, reporter
from twisted.internet import defer from twisted.application import app -from twisted.python import usage, reflect, failure, log +from twisted.python import usage, reflect, failure from twisted.python.filepath import FilePath from twisted import plugin from twisted.python.util import spewer @@ -34,6 +34,8 @@ from twisted.python.compat import set from twisted.trial import itrial from twisted.trial import runner as irunner
+from ooni.utils import log + class Options(usage.Options, app.ReactorSelectionMixin): synopsis = """%s [options] [[file|package|module|TestCase|testmethod]...] """ % (os.path.basename(sys.argv[0]),) @@ -90,6 +92,9 @@ class Options(usage.Options, app.ReactorSelectionMixin):
def run(): + log.start() + log.debug("Started logging") + if len(sys.argv) == 1: sys.argv.append("--help") config = Options() @@ -101,10 +106,6 @@ def run(): if config['debug-stacktraces']: defer.setDebugging(True)
- #logFile = open(config['logfile'], 'w') - #logFileObserver = log.FileLogObserver(logFile) - #log.startLoggingWithObserver(logFileObserver.emit, 0) - classes = runner.findTestClassesFromConfig(config) casesList, options = runner.loadTestsAndOptions(classes, config)
diff --git a/ooni/reporter.py b/ooni/reporter.py index fd64cbe..a7b645b 100644 --- a/ooni/reporter.py +++ b/ooni/reporter.py @@ -132,7 +132,8 @@ class ReporterFactory(OReporter): client_geodata = {} log.msg("Running geo IP lookup via check.torproject.org")
- client_ip = yield geodata.myIP() + #client_ip = yield geodata.myIP() + client_ip = '127.0.0.1' try: import txtorcon client_location = txtorcon.util.NetLocation(client_ip) @@ -209,10 +210,8 @@ class OONIReporter(OReporter): test_input = test.input
self._tests[idx]['input'] = test_input - #self._tests[idx]['idx'] = idx self._tests[idx]['name'] = test.name - #self._tests[idx]['test'] = test - print "Now starting %s" % self._tests[idx] + log.debug("Now starting %s" % self._tests[idx])
def stopTest(self, test): @@ -230,7 +229,7 @@ class OONIReporter(OReporter): # actually end up with the report I want. This could either be a # python bug or a yaml bug. report = dict(test.report) - + log.debug("Adding to report %s" % report) self._tests[idx]['report'] = report
diff --git a/ooni/runner.py b/ooni/runner.py index 1fbc4fe..b5c33a0 100644 --- a/ooni/runner.py +++ b/ooni/runner.py @@ -49,10 +49,7 @@ def isLegacyTest(obj): We do this for backward compatibility of the OONIProbe API. """ try: - if issubclass(obj, oonitests.OONITest) and not obj == oonitests.OONITest: - return True - else: - return False + return issubclass(obj, oonitests.OONITest) and not obj == oonitests.OONITest except TypeError: return False
@@ -116,8 +113,10 @@ def findTestClassesFromConfig(config): module = filenameToModule(filename) for name, val in inspect.getmembers(module): if isTestCase(val): + log.debug("Detected TestCase %s" % val) classes.append(processTest(val, config)) elif isLegacyTest(val): + log.debug("Detected Legacy Test %s" % val) classes.append(adapt_legacy_test(val, config)) return classes
@@ -200,7 +199,8 @@ class ORunner(object): try: first = options.pop(0) except: - first = {} + first = options + if 'inputs' in first: self.inputs = options['inputs'] else: @@ -238,7 +238,6 @@ class ORunner(object): result.done()
def run(self): - log.start() self.reporterFactory.options = self.options for inputUnit in InputUnitFactory(self.inputs): self.runWithInputUnit(inputUnit)