- | libmproxy.flow.ClientConnection |
- Describes a client connection. |
+ libmproxy.proxy.server.ConnectionHandler |
+ Describes a proxy client connection session. Always has a client_conn attribute, might have a server_conn attribute. |
- | libmproxy.flow.ClientDisconnection |
- Describes a client disconnection. |
+ libmproxy.proxy.connection.ClientConnection |
+ Describes a client connection. |
+
+
+ | libmproxy.proxy.connection.ServerConnection |
+ Describes a server connection. |
- | libmproxy.flow.Error |
+ libmproxy.protocol.primitives.Error |
A communications error. |
- | libmproxy.flow.Flow |
+ libmproxy.protocol.http.HTTPFlow |
A collection of objects representing a single HTTP transaction. |
-
- | libmproxy.flow.Headers |
- HTTP headers for a request or response. |
-
| libmproxy.flow.ODict |
@@ -103,15 +103,15 @@
calls (used mainly for headers).
- | libmproxy.flow.Response |
+ libmproxy.protocol.http.HTTPResponse |
An HTTP response. |
- | libmproxy.flow.Request |
+ libmproxy.protocol.http.HTTPRequest |
An HTTP request. |
- | libmproxy.flow.ScriptContext |
+ libmproxy.script.ScriptContext |
A handle for interacting with mitmproxy's from within scripts. |
@@ -124,7 +124,7 @@
using pydoc (which is installed with Python by default), like this:
-> pydoc libmproxy.flow.Request
+> pydoc libmproxy.protocol.http.HTTPRequest
diff --git a/libmproxy/cmdline.py b/libmproxy/cmdline.py
index 6c0cae9f33..bee4aa6083 100644
--- a/libmproxy/cmdline.py
+++ b/libmproxy/cmdline.py
@@ -209,7 +209,7 @@ def common_options(parser):
action="store", type = int, dest="port", default=8080,
help = "Proxy service port."
)
- # We could make a mutually exclusive group out of -R, -F, -T, but we don't do because
+ # We could make a mutually exclusive group out of -R, -F, -T, but we don't do that because
# - --upstream-server should be in that group as well, but it's already in a different group.
# - our own error messages are more helpful
parser.add_argument(
diff --git a/libmproxy/console/flowview.py b/libmproxy/console/flowview.py
index f5b5f83f48..9b63684058 100644
--- a/libmproxy/console/flowview.py
+++ b/libmproxy/console/flowview.py
@@ -2,7 +2,7 @@
import urwid
import common, grideditor, contentview
from .. import utils, flow, controller
-from ..protocol.http import CONTENT_MISSING
+from ..protocol.http import HTTPResponse, CONTENT_MISSING
class SearchError(Exception): pass
@@ -571,7 +571,7 @@ def edit(self, part):
conn = self.flow.request
else:
if not self.flow.response:
- self.flow.response = flow.Response(
+ self.flow.response = HTTPResponse(
self.flow.request,
self.flow.request.httpversion,
200, "OK", flow.ODictCaseless(), "", None
diff --git a/libmproxy/protocol/__init__.py b/libmproxy/protocol/__init__.py
index 6200757f82..b253fbd5cc 100644
--- a/libmproxy/protocol/__init__.py
+++ b/libmproxy/protocol/__init__.py
@@ -1,4 +1,4 @@
-from libmproxy.proxy.primitives import AddressPriority
+from ..proxy.primitives import AddressPriority
KILL = 0 # const for killed requests
diff --git a/libmproxy/proxy/server.py b/libmproxy/proxy/server.py
index 554ee551b4..c77ab2a811 100644
--- a/libmproxy/proxy/server.py
+++ b/libmproxy/proxy/server.py
@@ -1,10 +1,9 @@
import socket
-from .. import version, protocol
-from libmproxy.proxy.primitives import Log
-from .primitives import ProxyServerError
-from .connection import ClientConnection, ServerConnection
-from .primitives import ProxyError, ConnectionTypeChange, AddressPriority
+from OpenSSL import SSL
from netlib import tcp
+from .primitives import ProxyServerError, Log, ProxyError, ConnectionTypeChange, AddressPriority
+from .connection import ClientConnection, ServerConnection
+from .. import version, protocol
class DummyServer:
@@ -23,6 +22,7 @@ def shutdown(self):
class ProxyServer(tcp.TCPServer):
allow_reuse_address = True
bound = True
+
def __init__(self, config, port, host='', server_version=version.NAMEVERSION):
"""
Raises ProxyServerError if there's a startup problem.
@@ -51,8 +51,11 @@ def handle_client_connection(self, conn, client_address):
class ConnectionHandler:
def __init__(self, config, client_connection, client_address, server, channel, server_version):
self.config = config
+ """@type: libmproxy.proxy.config.ProxyConfig"""
self.client_conn = ClientConnection(client_connection, client_address, server)
+ """@type: libmproxy.proxy.connection.ClientConnection"""
self.server_conn = None
+ """@type: libmproxy.proxy.connection.ServerConnection"""
self.channel, self.server_version = channel, server_version
self.close = False
@@ -98,7 +101,7 @@ def handle(self):
def del_server_connection(self):
"""
- Deletes an existing server connection.
+ Deletes (and closes) an existing server connection.
"""
if self.server_conn and self.server_conn.connection:
self.server_conn.finish()
@@ -150,8 +153,7 @@ def establish_ssl(self, client=False, server=False):
"""
Establishes SSL on the existing connection(s) to the server or the client,
as specified by the parameters. If the target server is on the pass-through list,
- the conntype attribute will be changed and the SSL connection won't be wrapped.
- A protocol handler must raise a ConnTypeChanged exception if it detects that this is happening
+ the conntype attribute will be changed and a ConnTypeChanged exception will be raised.
"""
# TODO: Implement SSL pass-through handling and change conntype
passthrough = [
@@ -160,7 +162,7 @@ def establish_ssl(self, client=False, server=False):
]
if self.server_conn.address.host in passthrough or self.sni in passthrough:
self.conntype = "tcp"
- return
+ raise ConnectionTypeChange
# Logging
if client or server: