designate-bind zaza tests
This commit is contained in:
Adam Dyess
73
zaza/openstack/charm_tests/designate/__init__.py
Normal file
73
zaza/openstack/charm_tests/designate/__init__.py
Normal file
@@ -0,0 +1,73 @@
|
||||
# Copyright 2018 Canonical Ltd.
|
||||
#
|
||||
# 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.
|
||||
|
||||
"""Collection of code for setting up and testing designate."""
|
||||
import zaza.openstack.charm_tests.test_utils as test_utils
|
||||
import zaza.openstack.utilities.openstack as openstack_utils
|
||||
|
||||
|
||||
class BaseDesignateTest(test_utils.OpenStackBaseTest):
|
||||
"""Base for Designate charm tests."""
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls, application_name=None, model_alias=None):
|
||||
"""Run class setup for running Designate charm operation tests."""
|
||||
application_name = application_name or "designate"
|
||||
model_alias = model_alias or ""
|
||||
super(BaseDesignateTest, cls).setUpClass(application_name, model_alias)
|
||||
os_release = openstack_utils.get_os_release
|
||||
|
||||
if os_release() >= os_release('bionic_rocky'):
|
||||
cls.designate_svcs = [
|
||||
'designate-agent', 'designate-api', 'designate-central',
|
||||
'designate-mdns', 'designate-worker', 'designate-sink',
|
||||
'designate-producer',
|
||||
]
|
||||
else:
|
||||
cls.designate_svcs = [
|
||||
'designate-agent', 'designate-api', 'designate-central',
|
||||
'designate-mdns', 'designate-pool-manager', 'designate-sink',
|
||||
'designate-zone-manager',
|
||||
]
|
||||
|
||||
# Get keystone session
|
||||
keystone_api = 3 if (os_release() >= os_release('xenial_queens')) else 2
|
||||
cls.keystone_session = openstack_utils.get_overcloud_keystone_session()
|
||||
cls.keystone = openstack_utils.get_keystone_session_client(
|
||||
cls.keystone_session, keystone_api
|
||||
)
|
||||
|
||||
if os_release() >= os_release('xenial_queens'):
|
||||
cls.designate = openstack_utils.get_designate_session_client(
|
||||
session=cls.keystone_session
|
||||
)
|
||||
cls.zones_list = cls.designate.zones.list
|
||||
cls.zones_delete = cls.designate.zones.delete
|
||||
else:
|
||||
# Authenticate admin with designate endpoint
|
||||
designate_ep = cls.keystone.service_catalog.url_for(
|
||||
service_type='dns',
|
||||
interface='publicURL')
|
||||
keystone_ep = cls.keystone.service_catalog.url_for(
|
||||
service_type='identity',
|
||||
interface='publicURL')
|
||||
cls.designate = openstack_utils.get_designate_session_client(
|
||||
version=1,
|
||||
auth_url=keystone_ep,
|
||||
username="admin",
|
||||
password="openstack",
|
||||
tenant_name="admin",
|
||||
endpoint=designate_ep)
|
||||
cls.zones_list = cls.designate.domains.list
|
||||
cls.zones_delete = cls.designate.domains.delete
|
||||
175
zaza/openstack/charm_tests/designate/tests.py
Normal file
175
zaza/openstack/charm_tests/designate/tests.py
Normal file
@@ -0,0 +1,175 @@
|
||||
# Copyright 2018 Canonical Ltd.
|
||||
#
|
||||
# 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.
|
||||
|
||||
"""Encapsulate designate testing."""
|
||||
import logging
|
||||
import tenacity
|
||||
import subprocess
|
||||
import designateclient.v1.domains as domains
|
||||
import designateclient.v1.records as records
|
||||
import zaza.model as model
|
||||
import zaza.openstack.utilities.juju as zaza_juju
|
||||
from zaza.openstack.charm_tests.designate import (
|
||||
BaseDesignateTest,
|
||||
)
|
||||
import zaza.openstack.utilities.openstack as openstack_utils
|
||||
|
||||
|
||||
class BaseTests(BaseDesignateTest):
|
||||
def test_100_services(self):
|
||||
"""Verify the expected services are running on the corresponding
|
||||
service units."""
|
||||
logging.debug('Checking system services on units...')
|
||||
|
||||
model.block_until_service_status(
|
||||
self.application_name,
|
||||
self.designate_svcs,
|
||||
'running',
|
||||
self.model_name,
|
||||
timeout=30
|
||||
)
|
||||
|
||||
logging.debug('OK')
|
||||
|
||||
|
||||
class BindTests(BaseDesignateTest):
|
||||
TEST_DOMAIN = 'amuletexample.com.'
|
||||
TEST_WWW_RECORD = "www.{}".format(TEST_DOMAIN)
|
||||
TEST_RECORD = {TEST_WWW_RECORD: '10.0.0.23'}
|
||||
|
||||
def _get_domain_id(self, domain_name):
|
||||
domain_id = None
|
||||
for dom in self.zones_list():
|
||||
if isinstance(dom, dict):
|
||||
if dom['name'] == domain_name:
|
||||
domain_id = dom['name']
|
||||
break
|
||||
else:
|
||||
if dom.name == domain_name:
|
||||
domain_id = dom.id
|
||||
break
|
||||
return domain_id
|
||||
|
||||
def _get_test_domain_id(self):
|
||||
return self._get_domain_id(self.TEST_DOMAIN)
|
||||
|
||||
@tenacity.retry(
|
||||
wait=tenacity.wait_exponential(multiplier=1, min=5, max=10),
|
||||
reraise=True
|
||||
)
|
||||
def _wait_on_domain_gone(self):
|
||||
logging.debug('Waiting for domain to disappear')
|
||||
if self._get_test_domain_id():
|
||||
raise Exception("Domain Exists")
|
||||
|
||||
@tenacity.retry(
|
||||
wait=tenacity.wait_exponential(multiplier=1, min=5, max=10),
|
||||
reraise=True
|
||||
)
|
||||
def _wait_to_resolve_test_record(self, dns_ip):
|
||||
logging.debug('Waiting for dns record to propagate')
|
||||
lookup_cmd = [
|
||||
'dig', '+short', '@{}'.format(dns_ip),
|
||||
self.TEST_WWW_RECORD]
|
||||
cmd_out = subprocess.check_output(
|
||||
lookup_cmd, universal_newlines=True).rstrip()
|
||||
if not self.TEST_RECORD[self.TEST_WWW_RECORD] == cmd_out:
|
||||
raise Exception("Record Doesn't Exist")
|
||||
|
||||
def test_205_designate_designate_bind_relation(self):
|
||||
"""Verify the designate to designate-bind dns-backend relation data"""
|
||||
logging.debug('Checking designate:designate-bind dns-backend relation'
|
||||
'data...')
|
||||
|
||||
unit_name = 'designate/0'
|
||||
remote_unit_name = 'designate-bind/0'
|
||||
relation_name = 'dns-backend'
|
||||
remote_unit = model.get_unit_from_name(remote_unit_name)
|
||||
remote_ip = remote_unit.public_address
|
||||
relation = zaza_juju.get_relation_from_unit(
|
||||
unit_name,
|
||||
remote_unit_name,
|
||||
relation_name
|
||||
)
|
||||
# Get private-address in relation
|
||||
rel_private_ip = relation.get('private-address')
|
||||
# The private address in relation should match designate-bind/0 address
|
||||
self.assertEqual(rel_private_ip, remote_ip)
|
||||
|
||||
def test_206_designate_bind_designate_relation(self):
|
||||
"""Verify the designate_bind to designate dns-backend relation data"""
|
||||
logging.debug('Checking designate-bind:designate dns-backend relation'
|
||||
'data...')
|
||||
|
||||
unit_name = 'designate-bind/0'
|
||||
remote_unit_name = 'designate/0'
|
||||
relation_name = 'dns-backend'
|
||||
remote_unit = model.get_unit_from_name(remote_unit_name)
|
||||
remote_ip = remote_unit.public_address
|
||||
relation = zaza_juju.get_relation_from_unit(
|
||||
unit_name,
|
||||
remote_unit_name,
|
||||
relation_name
|
||||
)
|
||||
# Get private-address in relation
|
||||
rel_private_ip = relation.get('private-address')
|
||||
# The private address in relation should match designate-bind/0 address
|
||||
self.assertEqual(rel_private_ip, remote_ip)
|
||||
|
||||
def test_400_domain_creation(self):
|
||||
"""Simple api calls to create domain"""
|
||||
logging.debug('Checking if domain exists before trying to create it')
|
||||
old_dom_id = self._get_test_domain_id()
|
||||
if old_dom_id:
|
||||
logging.debug('Deleting old domain')
|
||||
self.zones_delete(old_dom_id)
|
||||
self._wait_on_domain_gone()
|
||||
|
||||
logging.debug('Creating new domain')
|
||||
domain = domains.Domain(
|
||||
name=self.TEST_DOMAIN,
|
||||
email="fred@amuletexample.com")
|
||||
|
||||
os_release = openstack_utils.get_os_release
|
||||
if os_release() >= os_release('xenial_queens'):
|
||||
new_domain = self.designate.zones.create(
|
||||
name=domain.name, email=domain.email)
|
||||
else:
|
||||
new_domain = self.designate.domains.create(domain)
|
||||
self.assertIsNotNone(new_domain)
|
||||
|
||||
logging.debug('Creating new test record')
|
||||
_record = records.Record(
|
||||
name=self.TEST_WWW_RECORD,
|
||||
type="A",
|
||||
data=self.TEST_RECORD[self.TEST_WWW_RECORD])
|
||||
|
||||
if os_release() >= os_release('xenial_queens'):
|
||||
_domain_id = new_domain['id']
|
||||
self.designate.recordsets.create(
|
||||
_domain_id, _record.name, _record.type, [_record.data])
|
||||
else:
|
||||
_domain_id = new_domain.id
|
||||
self.designate.records.create(_domain_id, _record)
|
||||
|
||||
dns_ip = zaza_juju.get_relation_from_unit(
|
||||
'designate-bind/0',
|
||||
'designate/0',
|
||||
'dns-backend'
|
||||
).get('private-address')
|
||||
self._wait_to_resolve_test_record(dns_ip)
|
||||
|
||||
logging.debug('Tidy up delete test record')
|
||||
self.zones_delete(_domain_id)
|
||||
logging.debug('OK')
|
||||
@@ -29,6 +29,7 @@ from aodhclient.v2 import client as aodh_client
|
||||
from cinderclient import client as cinderclient
|
||||
from heatclient import client as heatclient
|
||||
from glanceclient import Client as GlanceClient
|
||||
from designateclient.client import Client as DesignateClient
|
||||
|
||||
from keystoneclient.v2_0 import client as keystoneclient_v2
|
||||
from keystoneclient.v3 import client as keystoneclient_v3
|
||||
@@ -208,6 +209,19 @@ def get_glance_session_client(session):
|
||||
return GlanceClient('2', session=session)
|
||||
|
||||
|
||||
def get_designate_session_client(**kwargs):
|
||||
"""Return designateclient authenticated by keystone session.
|
||||
|
||||
:param kwargs: Designate Client Arguments
|
||||
:returns: Authenticated designateclient
|
||||
:rtype: DesignateClient
|
||||
"""
|
||||
version = kwargs.pop('version', None) or 2
|
||||
return DesignateClient(session=session,
|
||||
version=str(version),
|
||||
**kwargs)
|
||||
|
||||
|
||||
def get_nova_session_client(session):
|
||||
"""Return novaclient authenticated by keystone session.
|
||||
|
||||
|
||||
Reference in New Issue
Block a user