2ec96b6672
Add endpoint_override keyword to v2.Client() and check for the session argument in DesignateAdapter() Add unit test, fix minor typos Change-Id: I038ec7b0d1feadc9642bd47285e397b3fe84c13c Closes-Bug: 1469739
100 lines
3.8 KiB
Python
100 lines
3.8 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 keystoneclient 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.tlds import TLDController
|
|
from designateclient.v2.zones import ZoneController
|
|
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 = {}
|
|
|
|
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.tlds = TLDController(self)
|
|
self.zones = ZoneController(self)
|
|
self.zone_transfers = ZoneTransfersController(self)
|