# 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)