aboutsummaryrefslogtreecommitdiffstats
path: root/netlib
diff options
context:
space:
mode:
authorAldo Cortesi <aldo@nullcube.com>2012-06-25 14:42:15 +1200
committerAldo Cortesi <aldo@nullcube.com>2012-06-25 14:42:15 +1200
commit353efec7ce032a447efbba60c5ccea441bc573fb (patch)
tree3f443161fc6ac18caa30ddf30d4965cd8643d478 /netlib
parent47f862ae278c61df9bd1b62ec291a954fc0707ea (diff)
downloadmitmproxy-353efec7ce032a447efbba60c5ccea441bc573fb.tar.gz
mitmproxy-353efec7ce032a447efbba60c5ccea441bc573fb.tar.bz2
mitmproxy-353efec7ce032a447efbba60c5ccea441bc573fb.zip
Improve TCPClient interface.
- Don't pass SSL parameters on instantiation. - Add a convert_to_ssl method analogous to that in TCPServer.
Diffstat (limited to 'netlib')
-rw-r--r--netlib/tcp.py31
1 files changed, 16 insertions, 15 deletions
diff --git a/netlib/tcp.py b/netlib/tcp.py
index 91b0c742..3c5c89b7 100644
--- a/netlib/tcp.py
+++ b/netlib/tcp.py
@@ -48,29 +48,30 @@ class FileLike:
class TCPClient:
- def __init__(self, ssl, host, port, clientcert):
- self.ssl, self.host, self.port, self.clientcert = ssl, host, port, clientcert
+ def __init__(self, host, port):
+ self.host, self.port = host, port
self.connection, self.rfile, self.wfile = None, None, None
self.cert = None
+ def convert_to_ssl(self, clientcert=None):
+ context = SSL.Context(SSL.SSLv23_METHOD)
+ if clientcert:
+ context.use_certificate_file(self.clientcert)
+ self.connection = SSL.Connection(context, self.connection)
+ self.connection.set_connect_state()
+ self.cert = self.connection.get_peer_certificate()
+ self.rfile = FileLike(self.connection)
+ self.wfile = FileLike(self.connection)
+
def connect(self):
try:
addr = socket.gethostbyname(self.host)
- server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- if self.ssl:
- context = SSL.Context(SSL.SSLv23_METHOD)
- if self.clientcert:
- context.use_certificate_file(self.clientcert)
- server = SSL.Connection(context, server)
- server.connect((addr, self.port))
- if self.ssl:
- self.cert = server.get_peer_certificate()
- self.rfile, self.wfile = FileLike(server), FileLike(server)
- else:
- self.rfile, self.wfile = server.makefile('rb'), server.makefile('wb')
+ connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ connection.connect((addr, self.port))
+ self.rfile, self.wfile = connection.makefile('rb'), connection.makefile('wb')
except socket.error, err:
raise NetLibError('Error connecting to "%s": %s' % (self.host, err))
- self.connection = server
+ self.connection = connection
class BaseHandler: