Grasscutters/mitmproxy
3
0
Fork 0
mirror of https://github.com/Grasscutters/mitmproxy.git synced 2024-11-27 02:24:18 +00:00
Code Issues Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
Thomas Kriechbaumer 2016-08-18 17:23:47 +02:00
parent b476966a45
commit 0badb3ec91
2 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
mitmproxy/protocol/http2.py
View File

@ -96,15 +96,17 @@ class Http2Layer(base.Layer):
self.server_to_client_stream_ids = dict([(0, 0)]) self.server_to_client_stream_ids = dict([(0, 0)])
self.client_conn.h2 = SafeH2Connection(self.client_conn, client_side=False, header_encoding=False) self.client_conn.h2 = SafeH2Connection(self.client_conn, client_side=False, header_encoding=False)
# make sure that we only pass actual SSL.Connection objects in here,
# because otherwise ssl_read_select fails!
self.active_conns = [self.client_conn.connection]
def _initiate_server_conn(self): def _initiate_server_conn(self):
self.server_conn.h2 = SafeH2Connection(self.server_conn, client_side=True, header_encoding=False) if self.server_conn:
self.server_conn.h2.initiate_connection() self.server_conn.h2 = SafeH2Connection(self.server_conn, client_side=True, header_encoding=False)
self.server_conn.send(self.server_conn.h2.data_to_send()) self.server_conn.h2.initiate_connection()
self.active_conns.append(self.server_conn.connection) self.server_conn.send(self.server_conn.h2.data_to_send())
def _complete_handshake(self):
preamble = self.client_conn.rfile.read(24)
self.client_conn.h2.initiate_connection()
self.client_conn.h2.receive_data(preamble)
self.client_conn.send(self.client_conn.h2.data_to_send())
def next_layer(self): # pragma: no cover def next_layer(self): # pragma: no cover
# WebSockets over HTTP/2? # WebSockets over HTTP/2?
@ -301,20 +303,19 @@ class Http2Layer(base.Layer):
stream.data_finished.set() stream.data_finished.set()
def __call__(self): def __call__(self):
if self.server_conn: self._initiate_server_conn()
self._initiate_server_conn() self._complete_handshake()
preamble = self.client_conn.rfile.read(24) client = self.client_conn.connection
self.client_conn.h2.initiate_connection() server = self.server_conn.connection
self.client_conn.h2.receive_data(preamble) conns = [client, server]
self.client_conn.send(self.client_conn.h2.data_to_send())
try: try:
while True: while True:
r = tcp.ssl_read_select(self.active_conns, 1) r = tcp.ssl_read_select(conns, 1)
for conn in r: for conn in r:
source_conn = self.client_conn if conn == self.client_conn.connection else self.server_conn source_conn = self.client_conn if conn == client else self.server_conn
other_conn = self.server_conn if conn == self.client_conn.connection else self.client_conn other_conn = self.server_conn if conn == client else self.client_conn
is_server = (conn == self.server_conn.connection) is_server = (conn == self.server_conn.connection)
with source_conn.h2.lock: with source_conn.h2.lock:

1
test/mitmproxy/protocol/test_http2.py
View File

@ -130,6 +130,7 @@ class _Http2TestBase(object):
b"\r\n" % (self.server.server.address.port, self.server.server.address.port) b"\r\n" % (self.server.server.address.port, self.server.server.address.port)
) )
client.wfile.flush() client.wfile.flush()
# TODO: rewrite as http.Request object with http.assemble_request
# read CONNECT response # read CONNECT response
while client.rfile.readline() != b"\r\n": while client.rfile.readline() != b"\r\n":