summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-04-09 01:41:06 +0300
committerLV-426 <lv-426@taproot.org.il>2015-04-09 02:03:45 +0300
commit265491cde730218399ec07535f7c35437c43c4cb (patch)
tree6d7580c41bc53987869920cf86d56e42b7cfd9fb /src/server
parent9931f2d3f9d761c69f7438f3193c15716c317e51 (diff)
rz_mesh: rzdoc_from_f_args_extractor() util
Diffstat (limited to 'src/server')
-rw-r--r--src/server/rz_mesh.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py
index fc554bce..6fd78851 100644
--- a/src/server/rz_mesh.py
+++ b/src/server/rz_mesh.py
@@ -124,6 +124,7 @@ def init_ws_interface(cfg, kernel, flask_webapp):
except Exception as e:
log.exception('decorator__ws_multicast: failed to detect REST/Websocket call via stack inspection') # exception derived from stack
+ rzdoc = rzdoc_from_f_args_extractor(args)
assert type(f_ret) in [list, tuple]
pkt_data = map(_prep_for_serialization, f_ret)
@@ -142,6 +143,12 @@ def init_ws_interface(cfg, kernel, flask_webapp):
return wrapped_function
+ def rzdoc_from_f_args_extractor(f_args): # extract rzdoc from req ctx
+ if len(f_args) < 2 or not isinstance(f_args[1], Req_Context):
+ return
+ req_ctx = f_args[1]
+ return req_ctx.rzdoc
+
# connect socketio route
route_dec = flask_webapp.route('/socket.io/<path:url_path>')
f = route_dec(socketio_route_handler)