diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-01-20 03:00:41 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-01-20 04:00:42 +0200 |
| commit | ef1db057f27f7dc79c6145543451c3c3a62eba4d (patch) | |
| tree | 1e90e53a35ae05d4ea407ad2d21232e8c3cc6ea5 /src/server | |
| parent | 710cb02025448d6ec5207985ebcde915a9d2e8e0 (diff) | |
refactor rz_socket into top-level class
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/rz_mesh.py | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py index b173e64d..6336cdb2 100644 --- a/src/server/rz_mesh.py +++ b/src/server/rz_mesh.py @@ -69,13 +69,6 @@ def init_ws_interface(cfg, kernel, flask_webapp): flask_webapp.logger.error("Exception while handling socketio connection", exc_info=True) return Response() - # connect socketio route - route_dec = flask_webapp.route('/socket.io/<path:url_path>') - f = route_dec(socketio_route_handler) - flask_webapp.f = f - - # init ws server - ws_srv = RZ_WebSocket_Server(cfg, flask_webapp) # link ws hooks: multicast on topo_diff, attr_diff def decorator__ws_multicast(ws_srv, f, f_multicast): @@ -111,6 +104,14 @@ def init_ws_interface(cfg, kernel, flask_webapp): return wrapped_function + # connect socketio route + route_dec = flask_webapp.route('/socket.io/<path:url_path>') + f = route_dec(socketio_route_handler) + flask_webapp.f = f + + # init ws server + ws_srv = RZ_WebSocket_Server(cfg, flask_webapp) + kernel.diff_commit__topo = decorator__ws_multicast(ws_srv, kernel.diff_commit__topo, f_multicast=WebSocket_Graph_NS.on_diff_commit__topo) |