#
#    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 cinderclient import api_versions
from cinderclient import client as cc
from cinderclient import exceptions
from keystoneauth1 import exceptions as ks_exceptions
from oslo_config import cfg
from oslo_log import log as logging
from heat.common import exception
from heat.common.i18n import _
from heat.engine.clients import client_plugin
from heat.engine.clients import microversion_mixin
from heat.engine.clients import os as os_client
from heat.engine import constraints
LOG = logging.getLogger(__name__)
CLIENT_NAME = 'cinder'
[docs]
class CinderClientPlugin(microversion_mixin.MicroversionMixin,
                         os_client.ExtensionMixin,
                         client_plugin.ClientPlugin):
    exceptions_module = exceptions
    service_types = [VOLUME_V3] = ['volumev3']
    CINDER_API_VERSION = '3'
    max_microversion = cfg.CONF.max_cinder_api_microversion
[docs]
    def get_volume_api_version(self):
        '''Returns the most recent API version.'''
        self.interface = self._get_client_option(CLIENT_NAME, 'endpoint_type')
        try:
            self.context.keystone_session.get_endpoint(
                service_type=self.VOLUME_V3,
                interface=self.interface)
        except ks_exceptions.EndpointNotFound:
            raise exception.Error(_('No volume service available.')) 
    def _create(self, version=None):
        if version is None:
            version = self.CINDER_API_VERSION
        self.get_volume_api_version()
        extensions = cc.discover_extensions(self.CINDER_API_VERSION)
        args = {
            'session': self.context.keystone_session,
            'extensions': extensions,
            'interface': self.interface,
            'service_type': self.VOLUME_V3,
            'region_name': self._get_region_name(),
            'connect_retries': cfg.CONF.client_retry_limit,
            'http_log_debug': self._get_client_option(CLIENT_NAME,
                                                      'http_log_debug')
        }
        client = cc.Client(version, **args)
        return client
[docs]
    def get_max_microversion(self):
        if not self.max_microversion:
            self.max_microversion = api_versions.get_highest_version(
                self._create()).get_string()
        return self.max_microversion 
[docs]
    def is_version_supported(self, version):
        api_ver = api_versions.APIVersion(version)
        max_api_ver = api_versions.APIVersion(self.get_max_microversion())
        return max_api_ver >= api_ver 
    @os_client.MEMOIZE_EXTENSIONS
    def _list_extensions(self):
        extensions = self.client().list_extensions.show_all()
        return set(extension.alias for extension in extensions)
[docs]
    def get_volume(self, volume):
        try:
            return self.client().volumes.get(volume)
        except exceptions.NotFound:
            raise exception.EntityNotFound(entity='Volume', name=volume) 
[docs]
    def get_volume_snapshot(self, snapshot):
        try:
            return self.client().volume_snapshots.get(snapshot)
        except exceptions.NotFound:
            raise exception.EntityNotFound(entity='VolumeSnapshot',
                                           name=snapshot) 
[docs]
    def get_volume_backup(self, backup):
        try:
            return self.client().backups.get(backup)
        except exceptions.NotFound:
            raise exception.EntityNotFound(entity='Volume backup',
                                           name=backup) 
[docs]
    def get_volume_type(self, volume_type):
        vt_id = None
        volume_type_list = self.client().volume_types.list()
        for vt in volume_type_list:
            if volume_type in [vt.name, vt.id]:
                vt_id = vt.id
                break
        if vt_id is None:
            raise exception.EntityNotFound(entity='VolumeType',
                                           name=volume_type)
        return vt_id 
[docs]
    def get_qos_specs(self, qos_specs):
        try:
            qos = self.client().qos_specs.get(qos_specs)
        except exceptions.NotFound:
            qos = self.client().qos_specs.find(name=qos_specs)
        return qos.id 
[docs]
    def is_not_found(self, ex):
        return isinstance(ex, exceptions.NotFound) 
[docs]
    def is_over_limit(self, ex):
        return isinstance(ex, exceptions.OverLimit) 
[docs]
    def is_conflict(self, ex):
        return (isinstance(ex, exceptions.ClientException) and
                ex.code == 409) 
[docs]
    def check_detach_volume_complete(self, vol_id, server_id=None):
        try:
            vol = self.client().volumes.get(vol_id)
        except Exception as ex:
            self.ignore_not_found(ex)
            return True
        server_ids = [
            a['server_id'] for a in vol.attachments if 'server_id' in a]
        if server_id and server_id not in server_ids:
            return True
        if vol.status in ('in-use', 'detaching', 'reserved'):
            LOG.debug('%s - volume still in use', vol_id)
            return False
        LOG.debug('Volume %(id)s - status: %(status)s', {
            'id': vol.id, 'status': vol.status})
        if vol.status not in ('available', 'deleting'):
            LOG.debug("Detachment failed - volume %(vol)s "
                      "is in %(status)s status",
                      {"vol": vol.id, "status": vol.status})
            raise exception.ResourceUnknownStatus(
                resource_status=vol.status,
                result=_('Volume detachment failed'))
        else:
            return True 
[docs]
    def check_attach_volume_complete(self, vol_id):
        vol = self.client().volumes.get(vol_id)
        if vol.status in ('available', 'attaching', 'reserved'):
            LOG.debug("Volume %(id)s is being attached - "
                      "volume status: %(status)s",
                      {'id': vol_id, 'status': vol.status})
            return False
        if vol.status != 'in-use':
            LOG.debug("Attachment failed - volume %(vol)s is "
                      "in %(status)s status",
                      {"vol": vol_id, "status": vol.status})
            raise exception.ResourceUnknownStatus(
                resource_status=vol.status,
                result=_('Volume attachment failed'))
        LOG.info('Attaching volume %(id)s complete', {'id': vol_id})
        return True 
 
[docs]
class BaseCinderConstraint(constraints.BaseCustomConstraint):
    resource_client_name = CLIENT_NAME 
[docs]
class VolumeConstraint(BaseCinderConstraint):
    resource_getter_name = 'get_volume' 
[docs]
class VolumeSnapshotConstraint(BaseCinderConstraint):
    resource_getter_name = 'get_volume_snapshot' 
[docs]
class VolumeTypeConstraint(BaseCinderConstraint):
    resource_getter_name = 'get_volume_type' 
[docs]
class VolumeBackupConstraint(BaseCinderConstraint):
    resource_getter_name = 'get_volume_backup' 
[docs]
class QoSSpecsConstraint(BaseCinderConstraint):
    expected_exceptions = (exceptions.NotFound,)
    resource_getter_name = 'get_qos_specs'