commit 53f207416383b7782639d0ee2177580ba23bc5e7 Author: Arun Pandian G arunpandianp@gmail.com Date: Tue Apr 8 04:12:03 2014 +0530
Refactorings --- ooni/templates/httpt.py | 20 +++----------------- 1 file changed, 3 insertions(+), 17 deletions(-)
diff --git a/ooni/templates/httpt.py b/ooni/templates/httpt.py index 44d01be..1263261 100644 --- a/ooni/templates/httpt.py +++ b/ooni/templates/httpt.py @@ -1,10 +1,8 @@ import random
-from zope.interface import implements - from twisted.internet import defer
-from txtorcon.interface import IStreamListener +from txtorcon.interface import StreamListenerMixin
from twisted.internet import reactor from twisted.internet.endpoints import TCP4ClientEndpoint @@ -22,33 +20,21 @@ from ooni.errors import handleAllFailures class InvalidSocksProxyOption(Exception): pass
-class StreamListener(object): - implements(IStreamListener) +class StreamListener(StreamListenerMixin):
def __init__(self, request): self.request = request
- def stream_new(self, stream): - pass - def stream_succeeded(self, stream): host=self.request['url'].split('/')[2] try: if stream.target_host == host and len(self.request['tor']) == 1: self.request['tor']['exit_ip'] = stream.circuit.path[-1].ip self.request['tor']['exit_name'] = stream.circuit.path[-1].name + config.tor_state.stream_listeners.remove(self) except: log.err("Tor Exit ip detection failed")
- def stream_attach(self, stream, circuit): - pass - - def stream_closed(self, stream,**k): - pass - - def stream_failed(self, stream, reason, remote_reason): - pass - class HTTPTest(NetTestCase): """ A utility class for dealing with HTTP based testing. It provides methods to