c9ca48e7a0
When heat is trying to delete floating ip association and nova can't find an association between floating ip and server nova raises conflict exception instead of not_found. It happens because nova assumes that request was incorrect (floating ip is existing but link is not actual). So heat need to support such kind of cases. Change-Id: I3cc1fb13b9d3f0c1a2f7ee1c8ae7a99160b28951 Closes-bug: #1418878
139 lines
5.0 KiB
Python
139 lines
5.0 KiB
Python
#
|
|
# 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.
|
|
|
|
import abc
|
|
|
|
from keystoneclient import exceptions
|
|
from keystoneclient import session
|
|
from oslo.config import cfg
|
|
import six
|
|
|
|
|
|
@six.add_metaclass(abc.ABCMeta)
|
|
class ClientPlugin(object):
|
|
|
|
# Module which contains all exceptions classes which the client
|
|
# may emit
|
|
exceptions_module = None
|
|
|
|
def __init__(self, context):
|
|
self.context = context
|
|
self.clients = context.clients
|
|
self._client = None
|
|
self._keystone_session_obj = None
|
|
|
|
@property
|
|
def _keystone_session(self):
|
|
# FIXME(jamielennox): This session object is essentially static as the
|
|
# options won't change. Further it is allowed to be shared by multiple
|
|
# authentication requests so there is no reason to construct it fresh
|
|
# for every client plugin. It should be global and shared amongst them.
|
|
if not self._keystone_session_obj:
|
|
o = {'cacert': self._get_client_option('keystone', 'ca_file'),
|
|
'insecure': self._get_client_option('keystone', 'insecure'),
|
|
'cert': self._get_client_option('keystone', 'cert_file'),
|
|
'key': self._get_client_option('keystone', 'key_file')}
|
|
|
|
self._keystone_session_obj = session.Session.construct(o)
|
|
|
|
return self._keystone_session_obj
|
|
|
|
def client(self):
|
|
if not self._client:
|
|
self._client = self._create()
|
|
return self._client
|
|
|
|
@abc.abstractmethod
|
|
def _create(self):
|
|
'''Return a newly created client.'''
|
|
pass
|
|
|
|
@property
|
|
def auth_token(self):
|
|
# NOTE(jamielennox): use the session defined by the keystoneclient
|
|
# options as traditionally the token was always retrieved from
|
|
# keystoneclient.
|
|
return self.context.auth_plugin.get_token(self._keystone_session)
|
|
|
|
def url_for(self, **kwargs):
|
|
# NOTE(jamielennox): use the session defined by the keystoneclient
|
|
# options as traditionally the token was always retrieved from
|
|
# keystoneclient.
|
|
try:
|
|
kwargs.setdefault('interface', kwargs.pop('endpoint_type'))
|
|
except KeyError:
|
|
pass
|
|
|
|
reg = self.context.region_name or cfg.CONF.region_name_for_services
|
|
kwargs.setdefault('region_name', reg)
|
|
|
|
url = self.context.auth_plugin.get_endpoint(self._keystone_session,
|
|
**kwargs)
|
|
|
|
# NOTE(jamielennox): raising exception maintains compatibility with
|
|
# older keystoneclient service catalog searching.
|
|
if url is None:
|
|
raise exceptions.EndpointNotFound()
|
|
|
|
return url
|
|
|
|
def _get_client_option(self, client, option):
|
|
# look for the option in the [clients_${client}] section
|
|
# unknown options raise cfg.NoSuchOptError
|
|
try:
|
|
group_name = 'clients_' + client
|
|
cfg.CONF.import_opt(option, 'heat.common.config',
|
|
group=group_name)
|
|
v = getattr(getattr(cfg.CONF, group_name), option)
|
|
if v is not None:
|
|
return v
|
|
except cfg.NoSuchGroupError:
|
|
pass # do not error if the client is unknown
|
|
# look for the option in the generic [clients] section
|
|
cfg.CONF.import_opt(option, 'heat.common.config', group='clients')
|
|
return getattr(cfg.CONF.clients, option)
|
|
|
|
def is_client_exception(self, ex):
|
|
'''Returns True if the current exception comes from the client.'''
|
|
if self.exceptions_module:
|
|
if isinstance(self.exceptions_module, list):
|
|
for m in self.exceptions_module:
|
|
if type(ex) in m.__dict__.values():
|
|
return True
|
|
else:
|
|
return type(ex) in self.exceptions_module.__dict__.values()
|
|
return False
|
|
|
|
def is_not_found(self, ex):
|
|
'''Returns True if the exception is a not-found.'''
|
|
return False
|
|
|
|
def is_over_limit(self, ex):
|
|
'''Returns True if the exception is an over-limit.'''
|
|
return False
|
|
|
|
def is_conflict(self, ex):
|
|
"""Returns True if the exception is a conflict."""
|
|
return False
|
|
|
|
def ignore_not_found(self, ex):
|
|
'''Raises the exception unless it is a not-found.'''
|
|
if not self.is_not_found(ex):
|
|
raise ex
|
|
|
|
def ignore_conflict_and_not_found(self, ex):
|
|
"""Raises the exception unless it is a conflict or not-found."""
|
|
if self.is_conflict(ex) or self.is_not_found(ex):
|
|
return
|
|
else:
|
|
raise ex |