Initial commit

[ta/config-manager.git] / cmframework / src / cmframework / server / cmvalidator.py

diff --git a/cmframework/src/cmframework/server/cmvalidator.py b/cmframework/src/cmframework/server/cmvalidator.py
new file mode 100644 (file)
index 0000000..ca60a18
--- /dev/null
+++ b/cmframework/src/cmframework/server/cmvalidator.py
@@ -0,0 +1,55 @@
+# Copyright 2019 Nokia
+
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# vim: tabstop=8 expandtab shiftwidth=4 softtabstop=4
+import logging
+
+from cmframework.utils.cmpluginloader import CMPluginLoader
+from cmframework.utils.cmpluginmanager import CMPluginManager
+
+
+class CMValidator(CMPluginManager):
+    def __init__(self, plugins_path, plugin_client):
+        logging.info('Validator constructor, plugins_path is %s', plugins_path)
+        CMPluginManager.__init__(self, plugins_path)
+        self.load_plugin()
+        self.plugin_client = plugin_client
+
+    def load_plugin(self):
+        pl = CMPluginLoader(self.plugins_path)
+        self.pluginlist, self.filterdict = pl.load()
+        logging.info('Plugin(s): %r', self.pluginlist)
+        logging.info('Subscription(s): %r', self.filterdict)
+
+    def validate_delete(self, indata):
+        self.validate_plugins(indata, 'validate_delete')
+
+    def validate_set(self, indata):
+        self.validate_plugins(indata, 'validate_set')
+
+    def validate_plugins(self, indata, operation):
+        # import pdb; pdb.set_trace()
+        logging.debug('validate_plugins called with data %s', indata)
+        for plugin, objectname in self.pluginlist.iteritems():
+            filtername = self.filterdict[plugin]
+            inputdata = self.build_input(indata, filtername)
+            if inputdata:
+                logging.debug('Calling validation plugin %s with %s', plugin, inputdata)
+                class_name = getattr(objectname, plugin)
+                instance = class_name()
+                instance.plugin_client = self.plugin_client
+                try:
+                    func = getattr(instance, operation)
+                    func(inputdata)
+                except AttributeError:
+                    logging.info('Plugin %s does have function %s implemented', plugin, operation)