diff options
author | Maximilian Hils <git@maximilianhils.com> | 2014-12-09 18:55:16 +0100 |
---|---|---|
committer | Maximilian Hils <git@maximilianhils.com> | 2014-12-09 18:55:16 +0100 |
commit | 05bc7e8cd8382aabdd44f7bc569d2fd421c26f21 (patch) | |
tree | 754fc4ad2c21c833fdf06949a30a412161353ccb /libmproxy/web/__init__.py | |
parent | 14a8d2f5b83a1ea28abbb490f6c94c43b4e1f960 (diff) | |
download | mitmproxy-05bc7e8cd8382aabdd44f7bc569d2fd421c26f21.tar.gz mitmproxy-05bc7e8cd8382aabdd44f7bc569d2fd421c26f21.tar.bz2 mitmproxy-05bc7e8cd8382aabdd44f7bc569d2fd421c26f21.zip |
generalize store
Diffstat (limited to 'libmproxy/web/__init__.py')
-rw-r--r-- | libmproxy/web/__init__.py | 26 |
1 files changed, 21 insertions, 5 deletions
diff --git a/libmproxy/web/__init__.py b/libmproxy/web/__init__.py index 50c4b843..8f9fffdd 100644 --- a/libmproxy/web/__init__.py +++ b/libmproxy/web/__init__.py @@ -15,19 +15,34 @@ class WebFlowView(flow.FlowView): def _add(self, f): super(WebFlowView, self)._add(f) - app.ClientConnection.broadcast("add_flow", f.get_state(short=True)) + app.ClientConnection.broadcast( + type="flows", + cmd="add", + data=f.get_state(short=True) + ) def _update(self, f): super(WebFlowView, self)._update(f) - app.ClientConnection.broadcast("update_flow", f.get_state(short=True)) + app.ClientConnection.broadcast( + type="flows", + cmd="update", + data=f.get_state(short=True) + ) def _remove(self, f): super(WebFlowView, self)._remove(f) - app.ClientConnection.broadcast("remove_flow", f.get_state(short=True)) + app.ClientConnection.broadcast( + type="flows", + cmd="remove", + data=f.get_state(short=True) + ) def _recalculate(self, flows): super(WebFlowView, self)._recalculate(flows) - app.ClientConnection.broadcast("reset_flows", None) + app.ClientConnection.broadcast( + type="flows", + cmd="reset" + ) class WebState(flow.State): @@ -120,7 +135,8 @@ class WebMaster(flow.FlowMaster): def handle_log(self, l): self.last_log_id += 1 app.ClientConnection.broadcast( - "add_event", { + type="add_event", + data={ "id": self.last_log_id, "message": l.msg, "level": l.level |