blob: e1080a3fb5557e99402036420b5d82789f642d1d (
plain)
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
"""
Rhizi REST web API:
- make use of rz_kernel for core logic execution
- make use of rz_api_common for common API logic
"""
from flask import Flask
from flask import escape
from flask import jsonify
from flask import make_response
from flask import redirect
from flask import render_template
from flask import request
from flask import send_from_directory
from flask import session
from flask import url_for
import flask
import logging
import traceback
from model.graph import Attr_Diff
from model.graph import Topo_Diff
from rz_api_common import sanitize_input__attr_diff
from rz_api_common import sanitize_input__topo_diff
from rz_api_common import validate_obj__attr_diff
from rz_req_handling import common_resp_handle
log = logging.getLogger('rhizi')
db_ctl = None # injected: DB controller
def diff_commit__topo():
"""
REST API wrapper around diff_commit__topo():
- extract topo_diff from request
- handle success/error outcomes
"""
def sanitize_input(req):
topo_diff_dict = request.get_json()['topo_diff']
topo_diff = Topo_Diff.from_json_dict(topo_diff_dict)
sanitize_input__topo_diff(topo_diff)
return topo_diff;
try:
topo_diff = sanitize_input(request)
except Exception as e:
return common_resp_handle(error='malformed input')
try:
kernel = flask.current_app.kernel
for _, _, op_ret in kernel.diff_commit__topo(topo_diff): # discard diff_obj, original op
return common_resp_handle(data=op_ret)
except Exception as e:
log.error(e.message)
log.error(traceback.print_exc())
return common_resp_handle(error=e)
def diff_commit__attr():
"""
commit a graph attribute diff
"""
def sanitize_input(req):
attr_diff_dict = request.get_json()['attr_diff']
attr_diff = Attr_Diff.from_json_dict(attr_diff_dict)
sanitize_input__attr_diff(attr_diff)
return attr_diff;
def on_error(e):
# handle DB ERRORS, eg. name attr change error
return common_resp_handle(error='error occurred')
try:
attr_diff = sanitize_input(request)
validate_obj__attr_diff(attr_diff)
except Exception as e:
return common_resp_handle(error='malformed input')
try:
kernel = flask.current_app.kernel
for _, _, op_ret in kernel.diff_commit__attr(attr_diff): # discard diff_obj, original op
return common_resp_handle(data=op_ret)
except Exception as e:
log.error(e.message)
log.error(traceback.print_exc())
return common_resp_handle(error=e)
def diff_commit__vis():
pass
|
