diff options
| author | Aldo Cortesi <aldo@nullcube.com> | 2014-09-17 13:58:56 +1200 |
|---|---|---|
| committer | Aldo Cortesi <aldo@nullcube.com> | 2014-09-17 13:58:56 +1200 |
| commit | b4ecd96beb77a8bae02d82eac174dded198797a3 (patch) | |
| tree | 1868202264b5e201338698b76dbed5104448ec28 /libmproxy/web/__init__.py | |
| parent | 51db9a5612f0899ed61751dbee3f4e4b19a74ea4 (diff) | |
| download | mitmproxy-b4ecd96beb77a8bae02d82eac174dded198797a3.tar.gz mitmproxy-b4ecd96beb77a8bae02d82eac174dded198797a3.tar.bz2 mitmproxy-b4ecd96beb77a8bae02d82eac174dded198797a3.zip | |
Introduce short form object state, and connect the ends to send data to web app
Diffstat (limited to 'libmproxy/web/__init__.py')
| -rw-r--r-- | libmproxy/web/__init__.py | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/libmproxy/web/__init__.py b/libmproxy/web/__init__.py index c2597861..50b41b80 100644 --- a/libmproxy/web/__init__.py +++ b/libmproxy/web/__init__.py @@ -81,18 +81,31 @@ class WebMaster(flow.FlowMaster): self.shutdown() def handle_request(self, f): - pprint.pprint(f.get_state()) + app.ClientConnection.broadcast("flow", f.get_state(True)) flow.FlowMaster.handle_request(self, f) if f: f.reply() return f def handle_response(self, f): + app.ClientConnection.broadcast("flow", f.get_state(True)) flow.FlowMaster.handle_response(self, f) if f: f.reply() return f def handle_error(self, f): + app.ClientConnection.broadcast("flow", f.get_state(True)) flow.FlowMaster.handle_error(self, f) return f + + def handle_log(self, l): + app.ClientConnection.broadcast( + "event", { + "message": l.msg, + "level": l.level + } + ) + self.add_event(l.msg, l.level) + l.reply() + |