From 758190f775b765583de61f5ce5e657ea60ac3302 Mon Sep 17 00:00:00 2001
From: LV-426 <lv-426@taproot.org.il>
Date: Fri, 2 Jan 2015 17:45:22 +0200
Subject: rhizi_api.py: extract core logic to rz_kernel (REST/web-socket
 agnostic)

---
 src/server/rz_kernel.py | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 src/server/rz_kernel.py

(limited to 'src/server/rz_kernel.py')

diff --git a/src/server/rz_kernel.py b/src/server/rz_kernel.py
new file mode 100644
index 00000000..b2bba38a
--- /dev/null
+++ b/src/server/rz_kernel.py
@@ -0,0 +1,36 @@
+"""
+Rhizi kernel, home to core operation login
+"""
+import db_controller
+import logging
+import traceback
+
+log = logging.getLogger('rhizi')
+
+class RZ_Kernel(object):
+
+    def diff_commit__topo(self, db_ctl, topo_diff):
+        """
+        commit a graph topology diff - this is a common pathway for:
+           - RESP API calls
+           - socket.io calls
+           - future interfaces
+        """
+        op = db_controller.DBO_topo_diff_commit(topo_diff)
+        try:
+            op_ret = db_ctl.exec_op(op)
+            return op_ret
+        except Exception as e:
+            log.error(e.message)
+            log.error(traceback.print_exc())
+            raise e
+
+    def diff_commit__attr(self, db_ctl, attr_diff):
+        op = db_controller.DBO_attr_diff_commit(attr_diff)
+        try:
+            op_ret = db_ctl.exec_op(op)
+            return op_ret
+        except Exception as e:
+            log.error(e.message)
+            log.error(traceback.print_exc())
+            raise e
-- 
cgit v1.3.1