1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
"""
Rhizi websocket web API
"""
import json
import logging
from socketio.mixins import BroadcastMixin
from socketio.namespace import BaseNamespace
import traceback
from model.graph import Attr_Diff, Topo_Diff
log = logging.getLogger('rhizi')
class WebSocket_Graph_NS(BaseNamespace, BroadcastMixin):
"""
Rhizi '/graph' websocket namespace
"""
def __init__(self, *args, **kw):
super(WebSocket_Graph_NS, self).__init__(*args, **kw)
def multicast_msg(self, msg_name, *args):
self.socket.server.log_multicast(msg_name)
try:
super(WebSocket_Graph_NS, self).broadcast_event_not_me(msg_name, *args)
except Exception as e:
log.error(e.message)
log.error(traceback.print_exc())
def _log_conn(self, prefix_msg):
rmt_addr = self.environ['REMOTE_ADDR']
rmt_port = self.environ['REMOTE_PORT']
sid = self.environ['socketio'].sessid
log.info('ws: %s: sid: %s, remote-socket: %s:%s' % (prefix_msg, sid, rmt_addr, rmt_port))
def recv_connect(self):
self._log_conn('conn open')
def recv_disconnect(self):
self._log_conn('conn close')
def on_diff_commit__topo(self, json_data):
json_dict = json.loads(json_data)
topo_diff = Topo_Diff.from_json_dict(json_dict)
log.info('ws: rx: topo diff: ' + str(topo_diff))
kernel = self.request.kernel
gen = kernel.diff_commit__topo(topo_diff, ctx={'__caller': 'ws'})
topo_diff, _, commit_ret = gen.next()
# handle serialization
topo_diff_dict = topo_diff.to_json_dict()
# assert Topo_Diff.Commit_Result_Type == type(commit_ret)
return self.multicast_msg('diff_commit__topo', topo_diff_dict, commit_ret)
def on_diff_commit__attr(self, json_data):
json_dict = json.loads(json_data)
attr_diff = Attr_Diff.from_json_dict(json_dict)
log.info('ws: rx: attr diff: ' + str(attr_diff))
kernel = self.request.kernel
gen = kernel.diff_commit__attr(attr_diff, ctx={'__caller': 'ws'})
attr_diff, _, commit_ret = gen.next()
# [!] note: here we actually send the attr_diff twice, but in the future
# commit_ret may not be the same
return self.multicast_msg('diff_commit__attr', attr_diff, commit_ret)
|
