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
|
"""
Rhizi kernel, home to core operation login
"""
import json
import logging
import traceback
import db_controller
from db_op import DBO_diff_commit__attr, DBO_block_chain__commit
from db_op import DBO_diff_commit__topo
from model.graph import Topo_Diff
log = logging.getLogger('rhizi')
class RZ_Kernel(object):
def exec_chain_commit_op(self, diff_obj, ctx):
# FIXME: clean
if isinstance(diff_obj, Topo_Diff):
commit_obj = diff_obj.to_json_dict()
chain_commit_op = DBO_block_chain__commit(commit_obj, ctx)
self.db_ctl.exec_op(chain_commit_op)
def diff_commit__topo(self, topo_diff, ctx=None):
"""
commit a graph topology diff - this is a common pathway for:
- RESP API calls
- socket.io calls
- future interfaces
@return: a tuple containing the input diff and the result of it's commit
"""
op = DBO_diff_commit__topo(topo_diff)
try:
op_ret = self.db_ctl.exec_op(op)
self.exec_chain_commit_op(topo_diff, ctx)
return topo_diff, op_ret
except Exception as e:
log.error(e.message)
log.error(traceback.print_exc())
raise e
def diff_commit__attr(self, attr_diff, ctx=None):
"""
commit a graph attribute diff - this is a common pathway for:
- RESP API calls
- socket.io calls
- future interfaces
@return: a tuple containing the input diff and the result of it's commit
"""
op = DBO_diff_commit__attr(attr_diff)
try:
op_ret = self.db_ctl.exec_op(op)
self.exec_chain_commit_op(attr_diff, ctx)
return attr_diff, op_ret
except Exception as e:
log.error(e.message)
log.error(traceback.print_exc())
raise e
|
