commit f4fda9b7e24da3dbe4a93a2406b9cdda5ca36e23 Author: Arturo Filastò arturo@filasto.net Date: Fri Feb 5 20:06:48 2016 +0100
Move the creation of the agent for HTTPS and HTTP urls into constructor.
This is needed by our unittests --- ooni/reporter.py | 27 ++++++++++++++------------- 1 file changed, 14 insertions(+), 13 deletions(-)
diff --git a/ooni/reporter.py b/ooni/reporter.py index c62fa90..42787fb 100644 --- a/ooni/reporter.py +++ b/ooni/reporter.py @@ -10,12 +10,16 @@ from yaml.representer import SafeRepresenter from yaml.emitter import Emitter from yaml.serializer import Serializer from yaml.resolver import Resolver + from twisted.python.util import untilConcludes -from twisted.internet import defer +from twisted.internet import defer, reactor +from twisted.web.client import Agent from twisted.internet.error import ConnectionRefusedError from twisted.python.failure import Failure from twisted.internet.endpoints import TCP4ClientEndpoint
+from txsocksx.http import SOCKS5Agent + from ooni.utils import log from ooni.tasks import Measurement try: @@ -233,6 +237,15 @@ class OONIBReporter(OReporter):
self.reportID = None
+ if self.collectorAddress.startswith('https://'): + # not sure if there's something else it needs. Seems to work. + # Very difficult to get it to work with self-signed certs. + self.agent = Agent(reactor) + + elif self.collectorAddress.startswith('http://'): + log.msg("Warning using unencrypted collector") + self.agent = Agent(reactor) + OReporter.__init__(self, test_details)
def validateCollectorAddress(self): @@ -287,9 +300,6 @@ class OONIBReporter(OReporter): # do this with some deferred kung foo or instantiate the reporter after # tor is started.
- from twisted.web.client import Agent - from txsocksx.http import SOCKS5Agent - from twisted.internet import reactor
if self.collectorAddress.startswith('httpo://'): self.collectorAddress = \ @@ -298,15 +308,6 @@ class OONIBReporter(OReporter): config.tor.socks_port) self.agent = SOCKS5Agent(reactor, proxyEndpoint=proxyEndpoint)
- elif self.collectorAddress.startswith('https://'): - # not sure if there's something else it needs. Seems to work. - # Very difficult to get it to work with self-signed certs. - self.agent = Agent(reactor) - - elif self.collectorAddress.startswith('http://'): - log.msg("Warning using unencrypted collector") - self.agent = Agent(reactor) - url = self.collectorAddress + '/report'
content = '---\n'