diff options
author | Maximilian Hils <git@maximilianhils.com> | 2016-02-15 14:58:46 +0100 |
---|---|---|
committer | Maximilian Hils <git@maximilianhils.com> | 2016-02-15 14:58:46 +0100 |
commit | 33fa49277a821b9d38e8c9bf0bcf2adcfa2f6f04 (patch) | |
tree | 31914a601302579ff817504019296fd7e9e46765 /libmproxy/flow_format_compat.py | |
parent | 36f34f701991b5d474c005ec45e3b66e20f326a8 (diff) | |
download | mitmproxy-33fa49277a821b9d38e8c9bf0bcf2adcfa2f6f04.tar.gz mitmproxy-33fa49277a821b9d38e8c9bf0bcf2adcfa2f6f04.tar.bz2 mitmproxy-33fa49277a821b9d38e8c9bf0bcf2adcfa2f6f04.zip |
move mitmproxy
Diffstat (limited to 'libmproxy/flow_format_compat.py')
-rw-r--r-- | libmproxy/flow_format_compat.py | 60 |
1 files changed, 0 insertions, 60 deletions
diff --git a/libmproxy/flow_format_compat.py b/libmproxy/flow_format_compat.py deleted file mode 100644 index a7a95af3..00000000 --- a/libmproxy/flow_format_compat.py +++ /dev/null @@ -1,60 +0,0 @@ -""" -This module handles the import of mitmproxy flows generated by old versions. -""" -from __future__ import absolute_import, print_function, division -from . import version - - -def convert_013_014(data): - data["request"]["first_line_format"] = data["request"].pop("form_in") - data["request"]["http_version"] = "HTTP/" + ".".join(str(x) for x in data["request"].pop("httpversion")) - data["response"]["status_code"] = data["response"].pop("code") - data["response"]["body"] = data["response"].pop("content") - data["server_conn"].pop("state") - data["server_conn"]["via"] = None - data["version"] = (0, 14) - return data - - -def convert_014_015(data): - data["version"] = (0, 15) - return data - - -def convert_015_016(data): - for m in ("request", "response"): - if "body" in data[m]: - data[m]["content"] = data[m].pop("body") - if "httpversion" in data[m]: - data[m]["http_version"] = data[m].pop("httpversion") - if "msg" in data["response"]: - data["response"]["reason"] = data["response"].pop("msg") - data["request"].pop("form_out", None) - data["version"] = (0, 16) - return data - - -def convert_016_017(data): - data["version"] = (0, 17) - return data - - -converters = { - (0, 13): convert_013_014, - (0, 14): convert_014_015, - (0, 15): convert_015_016, - (0, 16): convert_016_017, -} - - -def migrate_flow(flow_data): - while True: - flow_version = tuple(flow_data["version"][:2]) - if flow_version == version.IVERSION[:2]: - break - elif flow_version in converters: - flow_data = converters[flow_version](flow_data) - else: - v = ".".join(str(i) for i in flow_data["version"]) - raise ValueError("Incompatible serialized data version: {}".format(v)) - return flow_data |