FIX: Set default IPMI privilege level
[ta/cm-plugins.git] / validators / src / OpenstackValidation.py
1 #!/usr/bin/python
2 # Copyright 2019 Nokia
3 #
4 # Licensed under the Apache License, Version 2.0 (the "License");
5 # you may not use this file except in compliance with the License.
6 # You may obtain a copy of the License at
7 #
8 #    http://www.apache.org/licenses/LICENSE-2.0
9 #
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
15
16 # pylint: disable=invalid-name, missing-docstring, too-few-public-methods,
17 # pylint: disable=logging-not-lazy, too-many-locals
18
19 import logging
20 import json
21
22 from cmframework.apis import cmvalidator
23 from cmdatahandlers.api import validation
24
25
26 class OpenstackValidationError(validation.ValidationError):
27     pass
28
29
30 class OpenstackValidation(cmvalidator.CMValidator):
31     domain = "cloud.openstack"
32
33     def get_subscription_info(self):  # pylint: disable=no-self-use
34         logging.debug('get_subscription info called')
35         return r'^cloud\.openstack$'
36
37     def validate_set(self, dict_key_value):
38         logging.debug('validate_set called with %s' % str(dict_key_value))
39
40         client = self.get_plugin_client()
41
42         for key, value in dict_key_value.iteritems():
43             value_str = value
44             value_dict = json.loads(value_str)
45
46             if key == self.domain:
47                 openstack_config = value_dict
48                 if not isinstance(value_dict, dict):
49                     raise validation.ValidationError('%s value is not a dict' % self.domain)
50             else:
51                 raise validation.ValidationError('Unexpected configuration %s' % key)
52             self.validate_openstack(openstack_config)
53
54     def validate_delete(self, properties):
55         logging.debug('validate_delete called with %s' % str(properties))
56         if self.domain in properties:
57             raise validation.ValidationError('%s cannot be deleted' % self.domain)
58         else:
59             raise validation.ValidationError('References in %s, cannot be deleted' % self.domain)
60
61     def validate_openstack(self, openstack_config):
62         if not openstack_config:
63             raise validation.ValidationError('No value for %s' % self.domain)
64
65         self.validate_admin_password(openstack_config)
66
67     @staticmethod
68     def validate_admin_password(openstack_config):
69         password = 'admin_password'
70         passwd = openstack_config.get(password)
71         if not passwd:
72             raise validation.ValidationError('Missing %s' % password)