#
# 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.
from openstack import exceptions
from heat.common import exception
from heat.common.i18n import _
from heat.engine.clients.os import openstacksdk as sdk_plugin
from heat.engine import constraints
CLIENT_NAME = 'senlin'
[docs]class SenlinClientPlugin(sdk_plugin.OpenStackSDKPlugin):
exceptions_module = exceptions
def _create(self, version=None):
client = super(SenlinClientPlugin, self)._create(version=version)
return client.clustering
def _get_additional_create_args(self, version):
return {
'clustering_api_version': version or '1'
}
[docs] def generate_spec(self, spec_type, spec_props):
spec = {'properties': spec_props}
spec['type'], spec['version'] = spec_type.split('-')
return spec
[docs] def check_action_status(self, action_id):
action = self.client().get_action(action_id)
if action.status == 'SUCCEEDED':
return True
elif action.status == 'FAILED':
raise exception.ResourceInError(
status_reason=action.status_reason,
resource_status=action.status,
)
return False
[docs] def cluster_is_active(self, cluster_id):
cluster = self.client().get_cluster(cluster_id)
if cluster.status == 'ACTIVE':
return True
elif cluster.status == 'ERROR':
raise exception.ResourceInError(
status_reason=cluster.status_reason,
resource_status=cluster.status,
)
return False
[docs] def get_profile_id(self, profile_name):
profile = self.client().get_profile(profile_name)
return profile.id
[docs] def get_cluster_id(self, cluster_name):
cluster = self.client().get_cluster(cluster_name)
return cluster.id
[docs] def get_policy_id(self, policy_name):
policy = self.client().get_policy(policy_name)
return policy.id
[docs] def is_bad_request(self, ex):
return (isinstance(ex, exceptions.HttpException) and
ex.status_code == 400)
[docs] def execute_actions(self, actions):
all_executed = True
for action in actions:
if action['done']:
continue
all_executed = False
if 'action_id' in action:
if action['action_id'] is None:
func = getattr(self.client(), action['func'])
ret = func(**action['params'])
if isinstance(ret, dict):
action['action_id'] = ret['action']
else:
action['action_id'] = ret.location.split('/')[-1]
else:
ret = self.check_action_status(action['action_id'])
action['done'] = ret
else:
ret = self.cluster_is_active(action['cluster_id'])
action['done'] = ret
# Execute these actions one by one.
break
return all_executed
[docs]class ProfileConstraint(constraints.BaseCustomConstraint):
# If name is not unique, will raise exceptions.HttpException
expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, profile):
client.client(CLIENT_NAME).get_profile(profile)
[docs]class ClusterConstraint(constraints.BaseCustomConstraint):
# If name is not unique, will raise exceptions.HttpException
expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, value):
client.client(CLIENT_NAME).get_cluster(value)
[docs]class PolicyConstraint(constraints.BaseCustomConstraint):
# If name is not unique, will raise exceptions.HttpException
expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, value):
client.client(CLIENT_NAME).get_policy(value)
[docs]class ProfileTypeConstraint(constraints.BaseCustomConstraint):
expected_exceptions = (exception.StackValidationFailed,)
[docs] def validate_with_client(self, client, value):
conn = client.client(CLIENT_NAME)
type_list = conn.profile_types()
names = [pt.name for pt in type_list]
if value not in names:
not_found_message = (
_("Unable to find senlin profile type '%(pt)s', "
"available profile types are %(pts)s.") %
{'pt': value, 'pts': names}
)
raise exception.StackValidationFailed(message=not_found_message)
[docs]class PolicyTypeConstraint(constraints.BaseCustomConstraint):
expected_exceptions = (exception.StackValidationFailed,)
[docs] def validate_with_client(self, client, value):
conn = client.client(CLIENT_NAME)
type_list = conn.policy_types()
names = [pt.name for pt in type_list]
if value not in names:
not_found_message = (
_("Unable to find senlin policy type '%(pt)s', "
"available policy types are %(pts)s.") %
{'pt': value, 'pts': names}
)
raise exception.StackValidationFailed(message=not_found_message)
