diff options
| author | Aldo Cortesi <aldo@nullcube.com> | 2011-08-03 13:33:18 +1200 |
|---|---|---|
| committer | Aldo Cortesi <aldo@nullcube.com> | 2011-08-03 13:33:18 +1200 |
| commit | f7e4e89b124e0bc20cf8192227add04bd92846ae (patch) | |
| tree | c03067688d76c1e36bb4c4e9702d529a85bb6695 /libmproxy/flow.py | |
| parent | 12d2b1f926bedfb334ce625aad2e85c53e65f481 (diff) | |
| download | mitmproxy-f7e4e89b124e0bc20cf8192227add04bd92846ae.tar.gz mitmproxy-f7e4e89b124e0bc20cf8192227add04bd92846ae.tar.bz2 mitmproxy-f7e4e89b124e0bc20cf8192227add04bd92846ae.zip | |
Move the event notification mechanism into flow.py
Diffstat (limited to 'libmproxy/flow.py')
| -rw-r--r-- | libmproxy/flow.py | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/libmproxy/flow.py b/libmproxy/flow.py index 92a4e812..49cf0796 100644 --- a/libmproxy/flow.py +++ b/libmproxy/flow.py @@ -481,6 +481,12 @@ class FlowMaster(controller.Master): raise NotImplementedError #end nocover + def add_event(self, e, level="info"): + """ + level: info, error + """ + pass + def set_plugin(self, p): self.plugin = p @@ -615,9 +621,19 @@ class FlowMaster(controller.Master): #end nocover def handle_clientconnect(self, r): + self.add_event("Connect from: %s:%s"%r.address) r.ack() def handle_clientdisconnect(self, r): + s = "Disconnect from: %s:%s"%r.client_conn.address + self.add_event(s) + if r.client_conn.requestcount: + s = " -> handled %s requests"%r.client_conn.requestcount + self.add_event(s) + if r.client_conn.connection_error: + self.add_event( + " -> error: %s"%r.client_conn.connection_error, "error" + ) r.ack() def handle_error(self, r): |