| import functools |
| import logging |
| import os_client_config |
| import time |
| |
| from salt.exceptions import CommandExecutionError |
| |
| log = logging.getLogger(__name__) |
| |
| NEUTRON_VERSION_HEADER = 'x-openstack-networking-version' |
| ADAPTER_VERSION = '2.0' |
| |
| |
| class NeutronException(Exception): |
| |
| _msg = "Neutron module exception occured." |
| |
| def __init__(self, message=None, **kwargs): |
| super(NeutronException, self).__init__(message or self._msg) |
| |
| |
| class NoNeutronEndpoint(NeutronException): |
| _msg = "Neutron endpoint not found in keystone catalog." |
| |
| |
| class NoAuthPluginConfigured(NeutronException): |
| _msg = ("You are using keystoneauth auth plugin that does not support " |
| "fetching endpoint list from token (noauth or admin_token).") |
| |
| |
| class NoCredentials(NeutronException): |
| _msg = "Please provide cloud name present in clouds.yaml." |
| |
| |
| class ResourceNotFound(NeutronException): |
| _msg = "Uniq resource: {resource} with name: {name} not found." |
| |
| def __init__(self, resource, name, **kwargs): |
| super(NeutronException, self).__init__( |
| self._msg.format(resource=resource, name=name)) |
| |
| |
| class MultipleResourcesFound(NeutronException): |
| _msg = "Multiple resource: {resource} with name: {name} found." |
| |
| def __init__(self, resource, name, **kwargs): |
| super(NeutronException, self).__init__( |
| self._msg.format(resource=resource, name=name)) |
| |
| |
| def _get_raw_client(cloud_name): |
| service_type = 'network' |
| config = os_client_config.OpenStackConfig() |
| cloud = config.get_one_cloud(cloud_name) |
| adapter = cloud.get_session_client(service_type) |
| adapter.version = ADAPTER_VERSION |
| try: |
| access_info = adapter.session.auth.get_access(adapter.session) |
| access_info.service_catalog.get_endpoints() |
| except (AttributeError, ValueError): |
| e = NoAuthPluginConfigured() |
| log.exception('%s' % e) |
| raise e |
| return adapter |
| |
| |
| def send(method): |
| def wrap(func): |
| @functools.wraps(func) |
| def wrapped_f(*args, **kwargs): |
| cloud_name = kwargs.pop('cloud_name') |
| connect_retries = 30 |
| connect_retry_delay = 1 |
| if not cloud_name: |
| e = NoCredentials() |
| log.error('%s' % e) |
| raise e |
| adapter = _get_raw_client(cloud_name) |
| # Remove salt internal kwargs |
| kwarg_keys = list(kwargs.keys()) |
| for k in kwarg_keys: |
| if k.startswith('__'): |
| kwargs.pop(k) |
| url, request_kwargs = func(*args, **kwargs) |
| if 'microversion' in kwargs: |
| request_kwargs['headers'][ |
| NEUTRON_VERSION_HEADER] = kwargs['microversion'] |
| response = None |
| for i in range(connect_retries): |
| try: |
| response = getattr(adapter, method)( |
| url, connect_retries=connect_retries, |
| **request_kwargs) |
| except Exception as e: |
| if not hasattr(e, 'http_status') or (e.http_status >= 500 |
| or e.http_status == 0): |
| msg = ("Got retriable exception when contacting " |
| "Neutron API. Sleeping for %ss. Attepmpts " |
| "%s of %s") |
| log.error(msg % (connect_retry_delay, i, connect_retries)) |
| time.sleep(connect_retry_delay) |
| continue |
| break |
| if not response or not response.content: |
| return {} |
| try: |
| resp = response.json() |
| except ValueError: |
| resp = response.content |
| return resp |
| return wrapped_f |
| return wrap |
| |
| def wait_for_api_ready(cloud_name, retries=1, retry_timeout=10, **kwargs): |
| |
| adapter = _get_raw_client(cloud_name) |
| response = None |
| for i in range(1, retries+1): |
| try: |
| response = getattr(adapter, 'get')( |
| '/', connect_retries=retries, |
| **kwargs) |
| except Exception as e: |
| msg = ("Error: %s " |
| "Sleeping for %ss. " |
| "Attempts %s of %s ") |
| log.error(msg % (e, retry_timeout, i, retries)) |
| time.sleep(retry_timeout) |
| continue |
| break |
| if not response or not response.content: |
| if e: |
| raise CommandExecutionError(e) |
| else: |
| return {} |
| try: |
| resp = response.json() |
| except ValueError: |
| resp = response.content |
| return resp |
| |