From 39207ffdd280af854d521f810f6082d42943eefa Mon Sep 17 00:00:00 2001 From: Aldo Cortesi Date: Wed, 23 Feb 2011 10:54:51 +1300 Subject: Add a way for users to specify header significance in server replay. Also add the --rheader command-line option to mitmdump to let the user specify an arbitrary number of significant headers. The default is to treat no headers as significant. --- libmproxy/dump.py | 3 ++- libmproxy/flow.py | 20 +++++++++++++++++--- mitmdump | 35 +++++++++++++++++++++++------------ test/test_flow.py | 23 +++++++++++++++++++---- 4 files changed, 61 insertions(+), 20 deletions(-) diff --git a/libmproxy/dump.py b/libmproxy/dump.py index 66bb5206..396dc31d 100644 --- a/libmproxy/dump.py +++ b/libmproxy/dump.py @@ -12,6 +12,7 @@ class Options(object): "replay", "verbosity", "wfile", + "rheaders", ] def __init__(self, **kwargs): for k, v in kwargs.items(): @@ -52,7 +53,7 @@ class DumpMaster(flow.FlowMaster): flows = list(flow.FlowReader(f).stream()) except IOError, v: raise DumpError(v.strerror) - self.start_playback(flows, options.kill) + self.start_playback(flows, options.kill, options.rheaders) def _runscript(self, f, script): try: diff --git a/libmproxy/flow.py b/libmproxy/flow.py index 80a88708..42870f17 100644 --- a/libmproxy/flow.py +++ b/libmproxy/flow.py @@ -32,7 +32,12 @@ class RequestReplayThread(threading.Thread): class ServerPlaybackState: - def __init__(self): + def __init__(self, headers): + """ + headers: A case-insensitive list of request headers that should be + included in request-response matching. + """ + self.headers = headers self.fmap = {} def count(self): @@ -62,6 +67,15 @@ class ServerPlaybackState: str(r.path), str(r.content), ] + if self.headers: + hdrs = [] + for i in self.headers: + v = r.headers.get(i, []) + # Slightly subtle: we need to convert everything to strings + # to prevent a mismatch between unicode/non-unicode. + v = [str(x) for x in v] + hdrs.append((i, v)) + key.append(repr(hdrs)) return hashlib.sha256(repr(key)).digest() def next_flow(self, request): @@ -342,12 +356,12 @@ class FlowMaster(controller.Master): def set_request_script(self, s): self.scripts["request"] = s - def start_playback(self, flows, kill): + def start_playback(self, flows, kill, headers): """ flows: A list of flows. kill: Boolean, should we kill requests not part of the replay? """ - self.playback = ServerPlaybackState() + self.playback = ServerPlaybackState(headers) self.playback.load(flows) self.kill_nonreplay = kill diff --git a/mitmdump b/mitmdump index a1b8aef1..66cb5ade 100755 --- a/mitmdump +++ b/mitmdump @@ -28,31 +28,40 @@ if __name__ == '__main__': ) proxy.certificate_option_group(parser) parser.add_option( - "-p", "--port", action="store", + "-p", action="store", type = "int", dest="port", default=8080, help = "Port." ) - parser.add_option("-q", "--quiet", + parser.add_option("-q", action="store_true", dest="quiet", help="Quiet.") - parser.add_option("-v", "--verbose", - action="count", dest="verbose", default=1, - help="Increase verbosity. Can be passed multiple times.") - parser.add_option("-w", "--writefile", - action="store", dest="wfile", default=None, - help="Write flows to file.") parser.add_option("", "--reqscript", action="store", dest="request_script", default=None, help="Script to run when a request is recieved.") parser.add_option("", "--respscript", action="store", dest="response_script", default=None, help="Script to run when a response is recieved.") - parser.add_option("-r", "--replay", - action="store", dest="replay", default=None, + parser.add_option("-v", + action="count", dest="verbose", default=1, + help="Increase verbosity. Can be passed multiple times.") + parser.add_option("-w", + action="store", dest="wfile", default=None, + help="Write flows to file.") + + + group = OptionGroup(parser, "Server Replay") + group.add_option("-r", action="store", dest="replay", default=None, metavar="PATH", help="Replay server responses from a saved file.") - parser.add_option("-k", "--kill", + group.add_option("-k", "--kill", action="store_true", dest="kill", default=False, help="Kill extra requests during replay.") + group.add_option("--rheader", + action="append", dest="rheaders", type="str", + help="Request headers to be considered during replay. " + "Can be passed multiple times.") + parser.add_option_group(group) + + options, args = parser.parse_args() @@ -60,6 +69,7 @@ if __name__ == '__main__': if options.quiet: options.verbose = 0 + config = proxy.process_certificate_option_group(parser, options) server = proxy.ProxyServer(config, options.port) dumpopts = dump.Options( @@ -68,7 +78,8 @@ if __name__ == '__main__': request_script = options.request_script, response_script = options.response_script, replay = options.replay, - kill = options.kill + kill = options.kill, + rheaders = options.rheaders ) if args: filt = " ".join(args) diff --git a/test/test_flow.py b/test/test_flow.py index 9963ad18..e574f545 100644 --- a/test/test_flow.py +++ b/test/test_flow.py @@ -6,7 +6,7 @@ import libpry class uServerPlaybackState(libpry.AutoTree): def test_hash(self): - s = flow.ServerPlaybackState() + s = flow.ServerPlaybackState(None) r = utils.tflow() r2 = utils.tflow() @@ -17,8 +17,23 @@ class uServerPlaybackState(libpry.AutoTree): r.request.path = "voing" assert s._hash(r) != s._hash(r2) + def test_headers(self): + s = flow.ServerPlaybackState(["foo"]) + r = utils.tflow_full() + r.request.headers["foo"] = ["bar"] + r2 = utils.tflow_full() + assert not s._hash(r) == s._hash(r2) + r2.request.headers["foo"] = ["bar"] + assert s._hash(r) == s._hash(r2) + r2.request.headers["oink"] = ["bar"] + assert s._hash(r) == s._hash(r2) + + r = utils.tflow_full() + r2 = utils.tflow_full() + assert s._hash(r) == s._hash(r2) + def test_load(self): - s = flow.ServerPlaybackState() + s = flow.ServerPlaybackState(None) r = utils.tflow_full() r.request.headers["key"] = ["one"] @@ -319,10 +334,10 @@ class uFlowMaster(libpry.AutoTree): fm = flow.FlowMaster(None, s) assert not fm.do_playback(utils.tflow()) - fm.start_playback(pb, False) + fm.start_playback(pb, False, []) assert fm.do_playback(utils.tflow()) - fm.start_playback(pb, False) + fm.start_playback(pb, False, []) r = utils.tflow() r.request.content = "gibble" assert not fm.do_playback(r) -- cgit v1.2.3