aboutsummaryrefslogtreecommitdiffstats
path: root/libmproxy/flow.py
diff options
context:
space:
mode:
authorMaximilian Hils <git@maximilianhils.com>2015-03-15 14:36:06 +0100
committerMaximilian Hils <git@maximilianhils.com>2015-03-15 14:36:06 +0100
commit3650d7366216e4cdde0fa369e58b681c9bc30236 (patch)
treef2b23eb1d2680e90784c129b443d55f6f24bd0c9 /libmproxy/flow.py
parent47091c8db5172b3394b2a8f8d958ba50724f3311 (diff)
parent803d631f04f6af5bb54bbb46b3efec39622ca216 (diff)
downloadmitmproxy-3650d7366216e4cdde0fa369e58b681c9bc30236.tar.gz
mitmproxy-3650d7366216e4cdde0fa369e58b681c9bc30236.tar.bz2
mitmproxy-3650d7366216e4cdde0fa369e58b681c9bc30236.zip
Merge remote-tracking branch 'onlywade/master'
Conflicts: libmproxy/console/__init__.py libmproxy/console/flowlist.py
Diffstat (limited to 'libmproxy/flow.py')
-rw-r--r--libmproxy/flow.py27
1 files changed, 20 insertions, 7 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py
index 43580109..8343c183 100644
--- a/libmproxy/flow.py
+++ b/libmproxy/flow.py
@@ -203,12 +203,19 @@ class ClientPlaybackState:
class ServerPlaybackState:
- def __init__(self, headers, flows, exit, nopop, ignore_params, ignore_content, ignore_payload_params):
+ def __init__(self, headers, flows, exit, nopop, ignore_params, ignore_content,
+ ignore_payload_params, ignore_host):
"""
headers: Case-insensitive list of request headers that should be
included in request-response matching.
"""
- self.headers, self.exit, self.nopop, self.ignore_params, self.ignore_content, self.ignore_payload_params = headers, exit, nopop, ignore_params, ignore_content, ignore_payload_params
+ self.headers = headers
+ self.exit = exit
+ self.nopop = nopop
+ self.ignore_params = ignore_params
+ self.ignore_content = ignore_content
+ self.ignore_payload_params = ignore_payload_params
+ self.ignore_host = ignore_host
self.fmap = {}
for i in flows:
if i.response:
@@ -228,7 +235,6 @@ class ServerPlaybackState:
queriesArray = urlparse.parse_qsl(query)
key = [
- str(r.host),
str(r.port),
str(r.scheme),
str(r.method),
@@ -245,6 +251,9 @@ class ServerPlaybackState:
else:
key.append(str(r.content))
+ if not self.ignore_host:
+ key.append(r.host)
+
filtered = []
ignore_params = self.ignore_params or []
for p in queriesArray:
@@ -616,6 +625,7 @@ class FlowMaster(controller.Master):
self.setheaders = SetHeaders()
self.replay_ignore_params = False
self.replay_ignore_content = None
+ self.replay_ignore_host = False
self.stream = None
self.apps = AppRegistry()
@@ -712,16 +722,19 @@ class FlowMaster(controller.Master):
def stop_client_playback(self):
self.client_playback = None
- def start_server_playback(self, flows, kill, headers, exit, nopop, ignore_params, ignore_content,
- ignore_payload_params):
+ def start_server_playback(self, flows, kill, headers, exit, nopop, ignore_params,
+ ignore_content, ignore_payload_params, ignore_host):
"""
flows: List of flows.
kill: Boolean, should we kill requests not part of the replay?
ignore_params: list of parameters to ignore in server replay
ignore_content: true if request content should be ignored in server replay
+ ignore_payload_params: list of content params to ignore in server replay
+ ignore_host: true if request host should be ignored in server replay
"""
- self.server_playback = ServerPlaybackState(headers, flows, exit, nopop, ignore_params, ignore_content,
- ignore_payload_params)
+ self.server_playback = ServerPlaybackState(headers, flows, exit, nopop,
+ ignore_params, ignore_content,
+ ignore_payload_params, ignore_host)
self.kill_nonreplay = kill
def stop_server_playback(self):