aboutsummaryrefslogtreecommitdiffstats
path: root/mitmproxy/proxy/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'mitmproxy/proxy/protocol')
-rw-r--r--mitmproxy/proxy/protocol/http.py10
-rw-r--r--mitmproxy/proxy/protocol/http1.py2
-rw-r--r--mitmproxy/proxy/protocol/http2.py12
-rw-r--r--mitmproxy/proxy/protocol/http_replay.py2
-rw-r--r--mitmproxy/proxy/protocol/rawtcp.py4
-rw-r--r--mitmproxy/proxy/protocol/tls.py2
-rw-r--r--mitmproxy/proxy/protocol/websockets.py4
7 files changed, 18 insertions, 18 deletions
diff --git a/mitmproxy/proxy/protocol/http.py b/mitmproxy/proxy/protocol/http.py
index 6bc06502..a47fb455 100644
--- a/mitmproxy/proxy/protocol/http.py
+++ b/mitmproxy/proxy/protocol/http.py
@@ -6,9 +6,9 @@ from mitmproxy import http
from mitmproxy import flow
from mitmproxy.proxy.protocol import base
from mitmproxy.proxy.protocol import websockets as pwebsockets
-import netlib.http
-from netlib import tcp
-from netlib import websockets
+import mitmproxy.net.http
+from mitmproxy.net import tcp
+from mitmproxy.net import websockets
class _HttpTransmissionLayer(base.Layer):
@@ -422,13 +422,13 @@ class HttpLayer(base.Layer):
self.send_response(http.make_error_response(
401,
"Authentication Required",
- netlib.http.Headers(**self.config.authenticator.auth_challenge_headers())
+ mitmproxy.net.http.Headers(**self.config.authenticator.auth_challenge_headers())
))
else:
self.send_response(http.make_error_response(
407,
"Proxy Authentication Required",
- netlib.http.Headers(**self.config.authenticator.auth_challenge_headers())
+ mitmproxy.net.http.Headers(**self.config.authenticator.auth_challenge_headers())
))
return False
return True
diff --git a/mitmproxy/proxy/protocol/http1.py b/mitmproxy/proxy/protocol/http1.py
index 968d3249..713c48a7 100644
--- a/mitmproxy/proxy/protocol/http1.py
+++ b/mitmproxy/proxy/protocol/http1.py
@@ -1,6 +1,6 @@
from mitmproxy import http
from mitmproxy.proxy.protocol import http as httpbase
-from netlib.http import http1
+from mitmproxy.net.http import http1
class Http1Layer(httpbase._HttpTransmissionLayer):
diff --git a/mitmproxy/proxy/protocol/http2.py b/mitmproxy/proxy/protocol/http2.py
index d0b0720d..f635e710 100644
--- a/mitmproxy/proxy/protocol/http2.py
+++ b/mitmproxy/proxy/protocol/http2.py
@@ -12,10 +12,10 @@ from mitmproxy import exceptions
from mitmproxy import http
from mitmproxy.proxy.protocol import base
from mitmproxy.proxy.protocol import http as httpbase
-import netlib.http
-from netlib import tcp
+import mitmproxy.net.http
+from mitmproxy.net import tcp
from mitmproxy.types import basethread
-from netlib.http import http2
+from mitmproxy.net.http import http2
class SafeH2Connection(connection.H2Connection):
@@ -148,7 +148,7 @@ class Http2Layer(base.Layer):
return True
def _handle_request_received(self, eid, event, h2_connection):
- headers = netlib.http.Headers([[k, v] for k, v in event.headers])
+ headers = mitmproxy.net.http.Headers([[k, v] for k, v in event.headers])
self.streams[eid] = Http2SingleStreamLayer(self, h2_connection, eid, headers)
self.streams[eid].timestamp_start = time.time()
self.streams[eid].no_body = (event.stream_ended is not None)
@@ -162,7 +162,7 @@ class Http2Layer(base.Layer):
return True
def _handle_response_received(self, eid, event):
- headers = netlib.http.Headers([[k, v] for k, v in event.headers])
+ headers = mitmproxy.net.http.Headers([[k, v] for k, v in event.headers])
self.streams[eid].queued_data_length = 0
self.streams[eid].timestamp_start = time.time()
self.streams[eid].response_headers = headers
@@ -239,7 +239,7 @@ class Http2Layer(base.Layer):
self.client_conn.h2.push_stream(parent_eid, event.pushed_stream_id, event.headers)
self.client_conn.send(self.client_conn.h2.data_to_send())
- headers = netlib.http.Headers([[k, v] for k, v in event.headers])
+ headers = mitmproxy.net.http.Headers([[k, v] for k, v in event.headers])
self.streams[event.pushed_stream_id] = Http2SingleStreamLayer(self, h2_connection, event.pushed_stream_id, headers)
self.streams[event.pushed_stream_id].timestamp_start = time.time()
self.streams[event.pushed_stream_id].pushed = True
diff --git a/mitmproxy/proxy/protocol/http_replay.py b/mitmproxy/proxy/protocol/http_replay.py
index 7efb0782..c37badd3 100644
--- a/mitmproxy/proxy/protocol/http_replay.py
+++ b/mitmproxy/proxy/protocol/http_replay.py
@@ -6,7 +6,7 @@ from mitmproxy import exceptions
from mitmproxy import http
from mitmproxy import flow
from mitmproxy import connections
-from netlib.http import http1
+from mitmproxy.net.http import http1
from mitmproxy.types import basethread
diff --git a/mitmproxy/proxy/protocol/rawtcp.py b/mitmproxy/proxy/protocol/rawtcp.py
index 8230c50b..0ec50594 100644
--- a/mitmproxy/proxy/protocol/rawtcp.py
+++ b/mitmproxy/proxy/protocol/rawtcp.py
@@ -2,7 +2,7 @@ import socket
from OpenSSL import SSL
-import netlib.tcp
+import mitmproxy.net.tcp
from mitmproxy import tcp
from mitmproxy import flow
from mitmproxy import exceptions
@@ -31,7 +31,7 @@ class RawTCPLayer(base.Layer):
try:
while not self.channel.should_exit.is_set():
- r = netlib.tcp.ssl_read_select(conns, 10)
+ r = mitmproxy.net.tcp.ssl_read_select(conns, 10)
for conn in r:
dst = server if conn == client else client
diff --git a/mitmproxy/proxy/protocol/tls.py b/mitmproxy/proxy/protocol/tls.py
index b106aa0c..8a344faf 100644
--- a/mitmproxy/proxy/protocol/tls.py
+++ b/mitmproxy/proxy/protocol/tls.py
@@ -6,7 +6,7 @@ import construct
from mitmproxy import exceptions
from mitmproxy.contrib.tls import _constructs
from mitmproxy.proxy.protocol import base
-from netlib import check
+from mitmproxy.net import check
# taken from https://testssl.sh/openssl-rfc.mappping.html
diff --git a/mitmproxy/proxy/protocol/websockets.py b/mitmproxy/proxy/protocol/websockets.py
index f84a1dc5..ca1d05cb 100644
--- a/mitmproxy/proxy/protocol/websockets.py
+++ b/mitmproxy/proxy/protocol/websockets.py
@@ -4,8 +4,8 @@ from OpenSSL import SSL
from mitmproxy import exceptions
from mitmproxy.proxy.protocol import base
from mitmproxy.utils import strutils
-from netlib import tcp
-from netlib import websockets
+from mitmproxy.net import tcp
+from mitmproxy.net import websockets
class WebSocketsLayer(base.Layer):