240 lines
7.9 KiB
Python
240 lines
7.9 KiB
Python
|
|
|
|
# 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 json
|
|
import testtools
|
|
import uuid
|
|
|
|
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)
|
|
|
|
@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)
|
|
self.assertIsNotNone(body)
|
|
|
|
@test.attr(type='negative')
|
|
def test_double_create_obj(self):
|
|
self.client.create_obj('workbooks', 'test')
|
|
self.obj.append(['workbooks', 'test'])
|
|
|
|
self.assertRaises(exceptions.Conflict, self.client.create_obj,
|
|
'workbooks', 'test')
|
|
|
|
self.client.delete_obj('workbooks', 'test')
|
|
_, body = self.client.get_list_obj('workbooks')
|
|
|
|
self.assertEqual([], body['workbooks'])
|
|
|
|
@test.attr(type='negative')
|
|
def test_get_nonexistent_workbook_definition(self):
|
|
self.assertRaises(exceptions.NotFound,
|
|
self.client.get_workbook_definition,
|
|
'fksn')
|
|
|
|
@testtools.skip('https://bugs.launchpad.net/mistral/+bug/1325933')
|
|
@test.attr(type='negative')
|
|
def test_get_executions_list_from_nonexistent_workbook(self):
|
|
self.assertRaises(exceptions.NotFound, self.client.get_list_obj,
|
|
'workbooks/nonexistentworkbook/executions')
|
|
|
|
|
|
class AdvancedTests(base.TestCaseAdvanced):
|
|
|
|
@test.attr(type='positive')
|
|
def test_create_execution(self):
|
|
resp, body = self._create_execution('test123', 'aloha')
|
|
|
|
self.assertEqual(201, resp.status)
|
|
self.assertEqual('test123', body["workbook_name"])
|
|
|
|
@test.attr(type='positive')
|
|
def test_get_execution(self):
|
|
_, execution = self._create_execution('test123', 'aloha')
|
|
|
|
resp, body = self.client.get_execution('test123', execution['id'])
|
|
|
|
body = json.loads(body)
|
|
del execution['state']
|
|
del body['state']
|
|
|
|
self.assertEqual(200, resp.status)
|
|
self.assertEqual(execution, body)
|
|
|
|
#TODO(smurashov): Need to add test which would check execution update
|
|
|
|
@test.attr(type='positive')
|
|
def test_get_tasks_list(self):
|
|
execution = self._create_execution('test123', 'aloha')[1]
|
|
|
|
resp, tasks = self.client.get_tasks_list('test123', execution['id'])
|
|
|
|
self.assertEqual(200, resp.status)
|
|
for task in tasks:
|
|
self.assertEqual(execution['id'], task['execution_id'])
|
|
self.assertEqual('test123', task['workbook_name'])
|
|
|
|
@test.attr(type='positive')
|
|
def test_get_task(self):
|
|
_, execution = self._create_execution('test123', 'aloha')
|
|
|
|
tasks = self.client.get_tasks_list('test123', execution['id'])[1]
|
|
|
|
resp, task = self.client.get_task('test123', execution['id'],
|
|
tasks[0]['id'])
|
|
|
|
del tasks[0]['state']
|
|
del task['state']
|
|
|
|
self.assertEqual(200, resp.status)
|
|
self.assertEqual(tasks[0], task)
|
|
|
|
#TODO(smurashov): Need to add test which would check task update
|
|
|
|
@testtools.skip('https://bugs.launchpad.net/mistral/+bug/1325914')
|
|
@test.attr(type='negative')
|
|
def test_create_execution_in_nonexistent_workbook(self):
|
|
self.assertRaises(exceptions.NotFound, self._create_execution,
|
|
'nonexistentworkbook', 'catchme')
|
|
|
|
def test_get_nonexistent_execution(self):
|
|
|
|
self.assertRaises(exceptions.NotFound, self.client.get_execution,
|
|
'test123', str(uuid.uuid4()))
|
|
|
|
@test.attr(type='negative')
|
|
def test_update_nonexistent_execution(self):
|
|
|
|
id = str(uuid.uuid4())
|
|
put_body = {
|
|
"id": id,
|
|
"state": "STOPPED"
|
|
}
|
|
|
|
self.assertRaises(exceptions.NotFound, self.client.update_execution,
|
|
'test123', id, put_body)
|
|
|
|
@testtools.skip('https://bugs.launchpad.net/mistral/+bug/1326287')
|
|
@test.attr(type='negative')
|
|
def test_get_tasks_list_of_nonexistent_execution(self):
|
|
|
|
self.assertRaises(exceptions.NotFound, self.client.get_tasks_list,
|
|
'test123', str(uuid.uuid4()))
|
|
|
|
|
|
class AdvancedNegativeTestsWithExecutionCreate(base.TestCaseAdvanced):
|
|
|
|
def setUp(self):
|
|
super(AdvancedNegativeTestsWithExecutionCreate, self).setUp()
|
|
|
|
self.execution = self._create_execution('test123', 'aloha')[1]
|
|
|
|
@testtools.skip('https://bugs.launchpad.net/mistral/+bug/1326278')
|
|
@test.attr(type='negative')
|
|
def test_get_nonexistent_task(self):
|
|
self.assertRaises(exceptions.NotFound, self.client.get_task,
|
|
'test123', self.execution['id'], str(uuid.uuid4()))
|
|
|
|
@test.attr(type='negative')
|
|
def test_update_nonexistent_task(self):
|
|
|
|
id = str(uuid.uuid4())
|
|
put_body = {
|
|
"id": id,
|
|
"state": "ERROR"
|
|
}
|
|
|
|
self.assertRaises(exceptions.NotFound, self.client.update_task,
|
|
'test123', self.execution['id'], str(uuid.uuid4()),
|
|
put_body)
|