Merge "Update mistral tests"
This commit is contained in:
Jenkins
Gerrit Code Review
commit
3b23751166
|
|
@ -0,0 +1,99 @@
|
|||
|
||||
# Copyright 2013 Mirantis, Inc.
|
||||
# All Rights Reserved.
|
||||
#
|
||||
# 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 json
|
||||
import os
|
||||
import testtools
|
||||
|
||||
from tempest import clients
|
||||
from tempest.common import rest_client
|
||||
from tempest import config
|
||||
from tempest import exceptions
|
||||
|
||||
CONF = config.CONF
|
||||
|
||||
|
||||
class MistralClient(rest_client.RestClient):
|
||||
|
||||
def __init__(self, auth_provider):
|
||||
super(MistralClient, self).__init__(auth_provider)
|
||||
|
||||
self.service = 'workflow_service'
|
||||
self.endpoint_url = 'publicURL'
|
||||
|
||||
def get_list_obj(self, name):
|
||||
resp, body = self.get(name)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def create_obj(self, path, name):
|
||||
post_body = '{"name": "%s"}' % name
|
||||
resp, body = self.post(path, post_body)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def delete_obj(self, path, name):
|
||||
return self.delete('{path}/{name}'.format(path=path, name=name))
|
||||
|
||||
def update_obj(self, path, name):
|
||||
post_body = '{"name": "%s"}' % (name + 'updated')
|
||||
resp, body = self.put('{path}/{name}'.format(path=path, name=name),
|
||||
post_body)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def get_workbook_definition(self, name):
|
||||
headers = {'X-Auth-Token': self.auth_provider.get_token()}
|
||||
return self.get('v1/workbooks/{name}/definition'.format(name=name),
|
||||
headers)
|
||||
|
||||
def upload_workbook_definition(self, name):
|
||||
headers = {'Content-Type': 'text/plain',
|
||||
'X-Auth-Token': self.auth_provider.get_token()}
|
||||
|
||||
__location = os.path.realpath(os.path.join(os.getcwd(),
|
||||
os.path.dirname(__file__)))
|
||||
|
||||
file = open(os.path.join(__location, 'demo.yaml'), 'rb').read()
|
||||
return self.put('v1/workbooks/{name}/definition'.format(name=name),
|
||||
file, headers)
|
||||
|
||||
|
||||
class TestCase(testtools.TestCase):
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
"""
|
||||
This method allows to initialize authentication before
|
||||
each test case and define parameters of Mistral API Service
|
||||
"""
|
||||
super(TestCase, cls).setUpClass()
|
||||
|
||||
username = CONF.identity.username
|
||||
password = CONF.identity.password
|
||||
tenant_name = CONF.identity.tenant_name
|
||||
|
||||
mgr = clients.Manager(username, password, tenant_name)
|
||||
auth_provider = mgr.get_auth_provider(mgr.get_default_credentials())
|
||||
|
||||
cls.client = MistralClient(auth_provider)
|
||||
cls.obj = []
|
||||
|
||||
def tearDown(self):
|
||||
super(TestCase, self).tearDown()
|
||||
|
||||
for i in self.obj:
|
||||
try:
|
||||
self.client.delete_obj(i[0], i[1])
|
||||
except exceptions.NotFound:
|
||||
pass
|
||||
|
|
@ -0,0 +1,115 @@
|
|||
|
||||
|
||||
# Copyright 2013 Mirantis, Inc.
|
||||
#
|
||||
# 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 testtools
|
||||
|
||||
from tempest import exceptions
|
||||
from tempest import test
|
||||
|
||||
from functionaltests.api import base
|
||||
|
||||
|
||||
class SanityTests(base.TestCase):
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_get_list_obj(self):
|
||||
resp, _ = self.client.get_list_obj('')
|
||||
self.assertEqual(200, resp.status)
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_get_list_workbooks(self):
|
||||
resp, body = self.client.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertEqual([], body['workbooks'])
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_get_workbook(self):
|
||||
self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.client.get_list_obj('workbooks/test')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertEqual('test', body['name'])
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_get_executions(self):
|
||||
self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.client.get_list_obj('workbooks/test/executions')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertEqual([], body['executions'])
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_create_and_delete_workbook(self):
|
||||
resp, body = self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
|
||||
self.assertEqual(201, resp.status)
|
||||
self.assertEqual('test', body['name'])
|
||||
|
||||
resp, body = self.client.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertEqual('test', body['workbooks'][0]['name'])
|
||||
|
||||
self.client.delete_obj('workbooks', 'test')
|
||||
_, body = self.client.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual([], body['workbooks'])
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_update_workbook(self):
|
||||
self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.client.update_obj('workbooks', 'test')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertEqual('testupdated', body['name'])
|
||||
|
||||
self.obj.append(['workbooks', 'testupdated'])
|
||||
|
||||
@test.attr(type='smoke')
|
||||
def test_get_workbook_definition(self):
|
||||
self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.client.get_workbook_definition('test')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
self.assertIsNotNone(body)
|
||||
|
||||
@testtools.skip('It is not implemented')
|
||||
@test.attr(type='smoke')
|
||||
def test_upload_workbook_definition(self):
|
||||
self.client.create_obj('workbooks', 'test1')
|
||||
self.obj.append(['workbooks', 'test1'])
|
||||
resp, body = self.client.upload_workbook_definition('test1')
|
||||
|
||||
self.assertEqual(200, resp.status)
|
||||
|
||||
@test.attr(type='negative')
|
||||
def test_double_create_obj(self):
|
||||
self.client.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
|
||||
self.assertRaises(exceptions.BadRequest, self.client.create_obj,
|
||||
'workbooks', 'test')
|
||||
|
||||
self.client.delete_obj('workbooks', 'test')
|
||||
_, body = self.client.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual([], body['workbooks'])
|
||||
|
|
@ -0,0 +1,24 @@
|
|||
#!/bin/bash
|
||||
#
|
||||
# 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.
|
||||
|
||||
# This script is executed inside post_test_hook function in devstack gate.
|
||||
|
||||
cd /opt/stack/new/mistral/functionaltests
|
||||
sudo ./run_tests.sh
|
||||
RETVAL=$?
|
||||
|
||||
# Copy tempest log files to be published among other logs upon job completion
|
||||
sudo cp /opt/stack/new/mistral/functionaltests/tempest.log /opt/stack/logs
|
||||
|
||||
exit $RETVAL
|
||||
|
|
@ -0,0 +1,22 @@
|
|||
#!/bin/bash
|
||||
#
|
||||
# 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.
|
||||
|
||||
# This script is executed inside pre_test_hook function in desvstack gate.
|
||||
|
||||
# Install Murano devstack integration
|
||||
MISTRAL_BASE=/opt/stack/new/mistral/contrib/devstack
|
||||
DEVSTACK_BASE=/opt/stack/new/devstack
|
||||
cp $MISTRAL_BASE/lib/* $DEVSTACK_BASE/lib
|
||||
cp $MISTRAL_BASE/extras.d/* $DEVSTACK_BASE/extras.d
|
||||
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
#!/bin/bash
|
||||
#
|
||||
# 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.
|
||||
|
||||
# How many seconds to wait for the API to be responding before giving up
|
||||
API_RESPONDING_TIMEOUT=20
|
||||
|
||||
if ! timeout ${API_RESPONDING_TIMEOUT} sh -c "while ! curl -s http://127.0.0.1:8989/v1/ 2>/dev/null | grep -q 'Authentication required' ; do sleep 1; done"; then
|
||||
echo "Mistral API failed to respond within ${API_RESPONDING_TIMEOUT} seconds"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
echo "Successfully contacted Mistral API"
|
||||
|
||||
# Where tempest code lives
|
||||
TEMPEST_DIR=${TEMPEST_DIR:-/opt/stack/new/tempest}
|
||||
|
||||
# Add tempest source tree to PYTHONPATH
|
||||
export PYTHONPATH=$PYTHONPATH:$TEMPEST_DIR
|
||||
|
||||
nosetests -sv .
|
||||
|
|
@ -1,100 +0,0 @@
|
|||
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
||||
|
||||
# Copyright 2013 Mirantis, Inc.
|
||||
# All Rights Reserved.
|
||||
#
|
||||
# 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 tempest.test
|
||||
import json
|
||||
from tempest.common import rest_client
|
||||
import os
|
||||
import tempest.api.mistral.config as cfg
|
||||
|
||||
|
||||
class MistralTest(tempest.test.BaseTestCase):
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
"""
|
||||
This method allows to initialize authentication before
|
||||
each test case and define parameters of Mistral API Service
|
||||
"""
|
||||
super(MistralTest, cls).setUpClass()
|
||||
|
||||
if not cfg.mistral.service_available:
|
||||
raise cls.skipException("Mistral tests are disabled")
|
||||
|
||||
user = cfg.mistral.user
|
||||
password = cfg.mistral.password
|
||||
tenant = cfg.mistral.tenant
|
||||
auth_url = cfg.mistral.auth_url
|
||||
client_args = (cls.config, user, password, auth_url, tenant)
|
||||
|
||||
cls.client = rest_client.RestClient(*client_args)
|
||||
cls.client.service = 'identity'
|
||||
cls.token = cls.client.get_auth()
|
||||
cls.client.base_url = cfg.mistral.mistral_url
|
||||
cls.obj = []
|
||||
|
||||
def tearDown(self):
|
||||
super(MistralTest, self).tearDown()
|
||||
|
||||
for i in self.obj:
|
||||
try:
|
||||
self.delete_obj(i[0], i[1])
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
def check_base_url(self):
|
||||
resp, body = self.client.get('', self.client.headers)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def check_base_url_with_version(self):
|
||||
resp, body = self.client.get('v1/', self.client.headers)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def get_list_obj(self, name):
|
||||
resp, body = self.client.get('v1/%s' % name, self.client.headers)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def create_obj(self, path, name):
|
||||
post_body = '{"name": "%s"}' % name
|
||||
resp, body = self.client.post('v1/%s/' % path, post_body,
|
||||
self.client.headers)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def delete_obj(self, path, name):
|
||||
self.client.delete('v1/%s/%s' % (path, name), self.client.headers)
|
||||
|
||||
def update_obj(self, path, name):
|
||||
post_body = '{"name": "%s"}' % (name + 'updated')
|
||||
resp, body = self.client.put('v1/%s/%s' % (path, name), post_body,
|
||||
self.client.headers)
|
||||
return resp, json.loads(body)
|
||||
|
||||
def get_workbook_definition(self, name):
|
||||
headers = {'X-Auth-Token': self.client.headers['X-Auth-Token']}
|
||||
resp, body = self.client.get('v1/workbooks/%s/definition' % name,
|
||||
headers)
|
||||
return resp, body
|
||||
|
||||
def upload_workbook_definition(self, name):
|
||||
headers = {'Content-Type': 'text/plain',
|
||||
'X-Auth-Token': self.client.headers['X-Auth-Token']}
|
||||
__location = os.path.realpath(os.path.join(os.getcwd(),
|
||||
os.path.dirname(__file__)))
|
||||
f = open(os.path.join(__location, 'demo.yaml'), 'rb').read()
|
||||
resp, body = self.client.put('v1/workbooks/%s/definition' % name, f,
|
||||
headers)
|
||||
return resp, body
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
[mistral]
|
||||
auth_url = http://127.0.0.1:5000/v2.0/
|
||||
mistral_url = http://127.0.0.1:8084
|
||||
user = admin
|
||||
password = password
|
||||
tenant = admin
|
||||
service_available = True
|
||||
|
|
@ -1,40 +0,0 @@
|
|||
import os
|
||||
from oslo.config import cfg
|
||||
|
||||
|
||||
mistral_group = cfg.OptGroup(name='mistral', title='mistral')
|
||||
|
||||
MistralGroup = [
|
||||
cfg.StrOpt('auth_url',
|
||||
default='http://127.0.0.1:5000/v2.0/',
|
||||
help="keystone url"),
|
||||
cfg.StrOpt('mistral_url',
|
||||
default='http://127.0.0.1:8084',
|
||||
help="mistral url"),
|
||||
cfg.StrOpt('user',
|
||||
default='admin',
|
||||
help="keystone user"),
|
||||
cfg.StrOpt('password',
|
||||
default='password',
|
||||
help="password for keystone user"),
|
||||
cfg.StrOpt('tenant',
|
||||
default='admin',
|
||||
help='keystone tenant'),
|
||||
cfg.BoolOpt('service_available',
|
||||
default='True',
|
||||
help='mistral available')
|
||||
]
|
||||
|
||||
|
||||
def register_config(config, config_group, config_opts):
|
||||
config.register_group(config_group)
|
||||
config.register_opts(config_opts, config_group)
|
||||
|
||||
path = os.path.join("%s/config.conf" % os.getcwd())
|
||||
|
||||
if os.path.exists(path):
|
||||
cfg.CONF([], project='mistralintegration', default_config_files=[path])
|
||||
|
||||
register_config(cfg.CONF, mistral_group, MistralGroup)
|
||||
|
||||
mistral = cfg.CONF.mistral
|
||||
|
|
@ -1,118 +0,0 @@
|
|||
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
||||
|
||||
# Copyright 2013 Mirantis, Inc.
|
||||
#
|
||||
# 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 testtools
|
||||
from tempest.api.mistral import base
|
||||
from tempest.test import attr
|
||||
from tempest import exceptions
|
||||
|
||||
|
||||
class SanityTests(base.MistralTest):
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_check_base_url(self):
|
||||
resp, _ = self.check_base_url()
|
||||
self.assertEqual(resp['status'], '200')
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_get_list_obj(self):
|
||||
resp, _ = self.check_base_url_with_version()
|
||||
self.assertEqual(resp['status'], '200')
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_get_list_workbooks(self):
|
||||
resp, body = self.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertEqual(body['workbooks'], [])
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_get_workbook(self):
|
||||
self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.get_list_obj('workbooks/test')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertEqual(body['name'], 'test')
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_get_executions(self):
|
||||
self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.get_list_obj('workbooks/test/executions')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertEqual(body['executions'], [])
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_create_and_delete_workbook(self):
|
||||
resp, body = self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
|
||||
self.assertEqual(resp['status'], '201')
|
||||
self.assertEqual(body['name'], 'test')
|
||||
|
||||
resp, body = self.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertEqual(body['workbooks'][0]['name'], 'test')
|
||||
|
||||
self.delete_obj('workbooks', 'test')
|
||||
_, body = self.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(body['workbooks'], [])
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_update_workbook(self):
|
||||
self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.update_obj('workbooks', 'test')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertEqual(body['name'], 'testupdated')
|
||||
|
||||
self.obj.append(['workbooks', 'testupdated'])
|
||||
|
||||
@attr(type='smoke')
|
||||
def test_get_workbook_definition(self):
|
||||
self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
resp, body = self.get_workbook_definition('test')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
self.assertIsNotNone(body)
|
||||
|
||||
@testtools.skip('It is not implemented')
|
||||
@attr(type='smoke')
|
||||
def test_upload_workbook_definition(self):
|
||||
self.create_obj('workbooks', 'test1')
|
||||
self.obj.append(['workbooks', 'test1'])
|
||||
resp, body = self.upload_workbook_definition('test1')
|
||||
|
||||
self.assertEqual(resp['status'], '200')
|
||||
|
||||
@attr(type='negative')
|
||||
def test_double_create_obj(self):
|
||||
self.create_obj('workbooks', 'test')
|
||||
self.obj.append(['workbooks', 'test'])
|
||||
|
||||
self.assertRaises(exceptions.BadRequest, self.create_obj, 'workbooks',
|
||||
'test')
|
||||
|
||||
self.delete_obj('workbooks', 'test')
|
||||
_, body = self.get_list_obj('workbooks')
|
||||
|
||||
self.assertEqual(body['workbooks'], [])
|
||||
Loading…
Reference in New Issue