b68dca09b1
This patch migrates designateclient to using keystoneauth Session instead of deprecated keystoneclient's Session and plugins. Also, this patch removes the old designateclient.auth module as it is not used anywhere else in the code base and its purpose is overridden by the fact that keystoneauth acts as an abstraction layer for authentication (handling requests and reauthentication internally). Change-Id: Ic3cc0fbb76977a04bab322ebcb1c818e75646772
107 lines
4.2 KiB
Python
107 lines
4.2 KiB
Python
# Copyright 2015 Hewlett-Packard Development Company, L.P.
|
|
#
|
|
# Author: Endre Karlson <endre.karlson@hp.com>
|
|
#
|
|
# 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 keystoneauth1 import adapter
|
|
|
|
from designateclient import exceptions
|
|
from designateclient.v2.blacklists import BlacklistController
|
|
from designateclient.v2.limits import LimitController
|
|
from designateclient.v2.nameservers import NameServerController
|
|
from designateclient.v2.recordsets import RecordSetController
|
|
from designateclient.v2.reverse import FloatingIPController
|
|
from designateclient.v2.service_statuses import ServiceStatusesController
|
|
from designateclient.v2.tlds import TLDController
|
|
from designateclient.v2.zones import ZoneController
|
|
from designateclient.v2.zones import ZoneExportsController
|
|
from designateclient.v2.zones import ZoneImportsController
|
|
from designateclient.v2.zones import ZoneTransfersController
|
|
from designateclient import version
|
|
|
|
|
|
class DesignateAdapter(adapter.LegacyJsonAdapter):
|
|
"""
|
|
Adapter around LegacyJsonAdapter.
|
|
The user can pass a timeout keyword that will apply only to
|
|
the Designate Client, in order:
|
|
- timeout keyword passed to request()
|
|
- timeout attribute on keystone session
|
|
"""
|
|
def __init__(self, *args, **kwargs):
|
|
self.timeout = kwargs.pop('timeout', None)
|
|
super(self.__class__, self).__init__(*args, **kwargs)
|
|
|
|
def request(self, *args, **kwargs):
|
|
kwargs.setdefault('raise_exc', False)
|
|
|
|
if self.timeout is not None:
|
|
kwargs.setdefault('timeout', self.timeout)
|
|
|
|
kwargs.setdefault('headers', {}).setdefault(
|
|
'Content-Type', 'application/json')
|
|
|
|
response, body = super(self.__class__, self).request(*args, **kwargs)
|
|
|
|
# Decode is response, if possible
|
|
try:
|
|
response_payload = response.json()
|
|
except ValueError:
|
|
response_payload = {}
|
|
body = response.text
|
|
|
|
if response.status_code == 400:
|
|
raise exceptions.BadRequest(**response_payload)
|
|
elif response.status_code in (401, 403):
|
|
raise exceptions.Forbidden(**response_payload)
|
|
elif response.status_code == 404:
|
|
raise exceptions.NotFound(**response_payload)
|
|
elif response.status_code == 409:
|
|
raise exceptions.Conflict(**response_payload)
|
|
elif response.status_code >= 500:
|
|
raise exceptions.Unknown(**response_payload)
|
|
return response, body
|
|
|
|
|
|
class Client(object):
|
|
def __init__(self, region_name=None, endpoint_type='publicURL',
|
|
extensions=None, service_type='dns', service_name=None,
|
|
http_log_debug=False, session=None, auth=None, timeout=None,
|
|
endpoint_override=None):
|
|
if session is None:
|
|
raise ValueError("A session instance is required")
|
|
|
|
self.session = DesignateAdapter(
|
|
session,
|
|
auth=auth,
|
|
region_name=region_name,
|
|
service_type=service_type,
|
|
interface=endpoint_type.rstrip('URL'),
|
|
user_agent='python-designateclient-%s' % version.version_info,
|
|
version=('2'),
|
|
endpoint_override=endpoint_override,
|
|
timeout=timeout
|
|
)
|
|
|
|
self.blacklists = BlacklistController(self)
|
|
self.floatingips = FloatingIPController(self)
|
|
self.limits = LimitController(self)
|
|
self.nameservers = NameServerController(self)
|
|
self.recordsets = RecordSetController(self)
|
|
self.service_statuses = ServiceStatusesController(self)
|
|
self.tlds = TLDController(self)
|
|
self.zones = ZoneController(self)
|
|
self.zone_transfers = ZoneTransfersController(self)
|
|
self.zone_exports = ZoneExportsController(self)
|
|
self.zone_imports = ZoneImportsController(self)
|