diff options
author | Aldo Cortesi <aldo@nullcube.com> | 2017-03-16 15:40:43 +1300 |
---|---|---|
committer | Aldo Cortesi <aldo@nullcube.com> | 2017-03-16 18:33:24 +1300 |
commit | c5e0dc64b9b367eae8f4af66a4917c738dd87569 (patch) | |
tree | 8577458ea0e643e0f48d48e39dcb4f80a4317094 /mitmproxy/master.py | |
parent | 3de982900381b9d3743e65defbfa413453cd3836 (diff) | |
download | mitmproxy-c5e0dc64b9b367eae8f4af66a4917c738dd87569.tar.gz mitmproxy-c5e0dc64b9b367eae8f4af66a4917c738dd87569.tar.bz2 mitmproxy-c5e0dc64b9b367eae8f4af66a4917c738dd87569.zip |
Rip out master handler mechanism
All events are now handled by addons, and we no longer support any events on
master.
Diffstat (limited to 'mitmproxy/master.py')
-rw-r--r-- | mitmproxy/master.py | 99 |
1 files changed, 2 insertions, 97 deletions
diff --git a/mitmproxy/master.py b/mitmproxy/master.py index 887a9240..946b25a4 100644 --- a/mitmproxy/master.py +++ b/mitmproxy/master.py @@ -93,18 +93,7 @@ class Master: raise exceptions.ControlException( "Unknown event %s" % repr(mtype) ) - handle_func = getattr(self, mtype) - if not callable(handle_func): - raise exceptions.ControlException( - "Handler %s not callable" % mtype - ) - if not handle_func.__dict__.get("__handler"): - raise exceptions.ControlException( - "Handler function %s is not decorated with controller.handler" % ( - handle_func - ) - ) - handle_func(obj) + self.addons.handle_lifecycle(mtype, obj) self.event_queue.task_done() changed = True except queue.Empty: @@ -143,7 +132,7 @@ class Master: f.request.scheme = self.server.config.upstream_server.scheme f.reply = controller.DummyReply() for e, o in eventsequence.iterate(f): - getattr(self, e)(o) + self.addons.handle_lifecycle(e, o) def replay_request( self, @@ -199,87 +188,3 @@ class Master: if block: rt.join() return rt - - @controller.handler - def log(self, l): - pass - - @controller.handler - def clientconnect(self, root_layer): - pass - - @controller.handler - def clientdisconnect(self, root_layer): - pass - - @controller.handler - def serverconnect(self, server_conn): - pass - - @controller.handler - def serverdisconnect(self, server_conn): - pass - - @controller.handler - def next_layer(self, top_layer): - pass - - @controller.handler - def http_connect(self, f): - pass - - @controller.handler - def error(self, f): - pass - - @controller.handler - def requestheaders(self, f): - pass - - @controller.handler - def request(self, f): - pass - - @controller.handler - def responseheaders(self, f): - pass - - @controller.handler - def response(self, f): - pass - - @controller.handler - def websocket_handshake(self, f): - pass - - @controller.handler - def websocket_start(self, flow): - pass - - @controller.handler - def websocket_message(self, flow): - pass - - @controller.handler - def websocket_error(self, flow): - pass - - @controller.handler - def websocket_end(self, flow): - pass - - @controller.handler - def tcp_start(self, flow): - pass - - @controller.handler - def tcp_message(self, flow): - pass - - @controller.handler - def tcp_error(self, flow): - pass - - @controller.handler - def tcp_end(self, flow): - pass |