66b826868c
When restoring from backup the launch wizard contains all options and performs no customizations based on the information contained in the backup. This patch adds support for restricting the launch instance datastore field to the datastore and datastore version that the backup is relevant to. It also populates the restored backup as the only option in the advanced step backup field. Added a unit test to validate the fields were populated correctly. Change-Id: Iabfefd34b5f7a24699277104fa92ac77b2c74fe3 Closes-Bug: #1647746
262 lines
9.9 KiB
Python
262 lines
9.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 binascii
|
|
|
|
from django.core.urlresolvers import reverse
|
|
from django import http
|
|
from django.utils.translation import ugettext_lazy as _
|
|
from mox3.mox import IsA # noqa
|
|
import six
|
|
|
|
from openstack_auth import policy
|
|
from openstack_dashboard import api as dash_api
|
|
|
|
from troveclient import common
|
|
|
|
from trove_dashboard import api
|
|
from trove_dashboard.content.databases.workflows import create_instance
|
|
from trove_dashboard.test import helpers as test
|
|
|
|
INDEX_URL = reverse('horizon:project:database_backups:index')
|
|
BACKUP_URL = reverse('horizon:project:database_backups:create')
|
|
DETAILS_URL = reverse('horizon:project:database_backups:detail', args=['id'])
|
|
RESTORE_URL = reverse('horizon:project:databases:launch')
|
|
|
|
|
|
class DatabasesBackupsTests(test.TestCase):
|
|
@test.create_stubs({api.trove: ('backup_list', 'instance_get')})
|
|
def test_index(self):
|
|
api.trove.backup_list(IsA(http.HttpRequest))\
|
|
.AndReturn(self.database_backups.list())
|
|
|
|
api.trove.instance_get(IsA(http.HttpRequest),
|
|
IsA(str))\
|
|
.MultipleTimes()\
|
|
.AndReturn(self.databases.first())
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
res = self.client.get(INDEX_URL)
|
|
|
|
self.assertTemplateUsed(res, 'project/database_backups/index.html')
|
|
|
|
@test.create_stubs({api.trove: ('backup_list',)})
|
|
def test_index_exception(self):
|
|
api.trove.backup_list(IsA(http.HttpRequest))\
|
|
.AndRaise(self.exceptions.trove)
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
res = self.client.get(INDEX_URL)
|
|
|
|
self.assertTemplateUsed(
|
|
res, 'project/database_backups/index.html')
|
|
self.assertEqual(res.status_code, 200)
|
|
self.assertMessageCount(res, error=1)
|
|
|
|
@test.create_stubs({
|
|
api.trove: ('instance_list', 'backup_list', 'backup_create'),
|
|
policy: ('check',),
|
|
})
|
|
def test_launch_backup(self):
|
|
policy.check((), IsA(http.HttpRequest)).MultipleTimes().AndReturn(True)
|
|
api.trove.instance_list(IsA(http.HttpRequest))\
|
|
.AndReturn(self.databases.list())
|
|
api.trove.backup_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.database_backups.list())
|
|
|
|
database = self.databases.first()
|
|
backupName = "NewBackup"
|
|
backupDesc = "Backup Description"
|
|
|
|
api.trove.backup_create(
|
|
IsA(http.HttpRequest),
|
|
backupName,
|
|
database.id,
|
|
backupDesc,
|
|
"")
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
post = {
|
|
'name': backupName,
|
|
'instance': database.id,
|
|
'description': backupDesc,
|
|
'parent': ""
|
|
}
|
|
res = self.client.post(BACKUP_URL, post)
|
|
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({
|
|
api.trove: ('instance_list', 'backup_list'),
|
|
policy: ('check',),
|
|
})
|
|
def test_launch_backup_exception(self):
|
|
policy.check((), IsA(http.HttpRequest)).MultipleTimes().AndReturn(True)
|
|
api.trove.instance_list(IsA(http.HttpRequest))\
|
|
.AndRaise(self.exceptions.trove)
|
|
api.trove.backup_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.database_backups.list())
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
res = self.client.get(BACKUP_URL)
|
|
self.assertMessageCount(res, error=1)
|
|
self.assertTemplateUsed(res,
|
|
'project/database_backups/backup.html')
|
|
|
|
@test.create_stubs({
|
|
api.trove: ('instance_list', 'backup_list', 'backup_create'),
|
|
policy: ('check',),
|
|
})
|
|
def test_launch_backup_incr(self):
|
|
policy.check((), IsA(http.HttpRequest)).MultipleTimes().AndReturn(True)
|
|
api.trove.instance_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.databases.list())
|
|
api.trove.backup_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.database_backups.list())
|
|
|
|
database = self.databases.first()
|
|
backupName = "NewBackup"
|
|
backupDesc = "Backup Description"
|
|
backupParent = self.database_backups.first()
|
|
|
|
api.trove.backup_create(
|
|
IsA(http.HttpRequest),
|
|
backupName,
|
|
database.id,
|
|
backupDesc,
|
|
backupParent.id)
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
post = {
|
|
'name': backupName,
|
|
'instance': database.id,
|
|
'description': backupDesc,
|
|
'parent': backupParent.id,
|
|
}
|
|
res = self.client.post(BACKUP_URL, post)
|
|
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({api.trove: ('backup_get', 'instance_get')})
|
|
def test_detail_backup(self):
|
|
api.trove.backup_get(IsA(http.HttpRequest),
|
|
IsA(six.text_type))\
|
|
.AndReturn(self.database_backups.first())
|
|
|
|
api.trove.instance_get(IsA(http.HttpRequest),
|
|
IsA(str))\
|
|
.AndReturn(self.databases.first())
|
|
|
|
self.mox.ReplayAll()
|
|
res = self.client.get(DETAILS_URL)
|
|
|
|
self.assertTemplateUsed(res,
|
|
'project/database_backups/details.html')
|
|
|
|
@test.create_stubs({api.trove: ('backup_get',)})
|
|
def test_detail_backup_notfound(self):
|
|
api.trove.backup_get(IsA(http.HttpRequest),
|
|
IsA(six.text_type))\
|
|
.AndRaise(self.exceptions.trove)
|
|
|
|
self.mox.ReplayAll()
|
|
res = self.client.get(DETAILS_URL)
|
|
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({api.trove: ('backup_get', 'instance_get')})
|
|
def test_detail_backup_incr(self):
|
|
incr_backup = self.database_backups.list()[2]
|
|
parent_backup = self.database_backups.list()[1]
|
|
|
|
api.trove.backup_get(IsA(http.HttpRequest), IsA(six.text_type))\
|
|
.AndReturn(incr_backup)
|
|
api.trove.backup_get(IsA(http.HttpRequest), incr_backup.parent_id) \
|
|
.AndReturn(parent_backup)
|
|
api.trove.instance_get(IsA(http.HttpRequest), IsA(str))\
|
|
.AndReturn(self.databases.list()[1])
|
|
|
|
self.mox.ReplayAll()
|
|
url = reverse('horizon:project:database_backups:detail',
|
|
args=[incr_backup.id])
|
|
res = self.client.get(url)
|
|
self.assertTemplateUsed(res, 'project/database_backups/details.html')
|
|
|
|
@test.create_stubs({
|
|
api.trove: ('backup_get', 'backup_list', 'configuration_list',
|
|
'datastore_flavors', 'datastore_list',
|
|
'datastore_version_list', 'instance_list'),
|
|
dash_api.cinder: ('volume_type_list',),
|
|
dash_api.neutron: ('network_list',),
|
|
dash_api.nova: ('availability_zone_list',),
|
|
policy: ('check',),
|
|
})
|
|
def test_restore_backup(self):
|
|
policy.check((), IsA(http.HttpRequest)).MultipleTimes().AndReturn(True)
|
|
backup = self.database_backups.first()
|
|
api.trove.backup_get(IsA(http.HttpRequest), IsA(six.text_type)) \
|
|
.AndReturn(self.database_backups.first())
|
|
api.trove.backup_list(IsA(http.HttpRequest)).AndReturn(
|
|
self.database_backups.list())
|
|
api.trove.configuration_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.database_configurations.list())
|
|
api.trove.datastore_flavors(IsA(http.HttpRequest),
|
|
IsA(six.string_types),
|
|
IsA(six.string_types)) \
|
|
.AndReturn(self.flavors.list())
|
|
api.trove.datastore_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.datastores.list())
|
|
api.trove.datastore_version_list(IsA(http.HttpRequest),
|
|
backup.datastore['type']) \
|
|
.AndReturn(self.datastore_versions.list())
|
|
api.trove.instance_list(IsA(http.HttpRequest), marker=None) \
|
|
.AndReturn(common.Paginated(self.databases.list()))
|
|
dash_api.cinder.volume_type_list(IsA(http.HttpRequest)).AndReturn([])
|
|
dash_api.neutron.network_list(IsA(http.HttpRequest),
|
|
tenant_id=self.tenant.id,
|
|
shared=False).\
|
|
AndReturn(self.networks.list()[:1])
|
|
dash_api.nova.availability_zone_list(IsA(http.HttpRequest)) \
|
|
.AndReturn(self.availability_zones.list())
|
|
self.mox.ReplayAll()
|
|
|
|
url = RESTORE_URL + '?backup=%s' % self.database_backups.first().id
|
|
res = self.client.get(url)
|
|
self.assertTemplateUsed(res, 'project/databases/launch.html')
|
|
|
|
set_instance_detail_step = \
|
|
[step for step in res.context_data['workflow'].steps
|
|
if isinstance(step, create_instance.SetInstanceDetails)][0]
|
|
fields = set_instance_detail_step.action.fields
|
|
self.assertTrue(len(fields['datastore'].choices), 1)
|
|
text = 'mysql - 5.6'
|
|
choice = fields['datastore'].choices[0]
|
|
self.assertTrue(choice[0], binascii.hexlify(text))
|
|
self.assertTrue(choice[1], text)
|
|
|
|
advanced_step = [step for step in res.context_data['workflow'].steps
|
|
if isinstance(step, create_instance.Advanced)][0]
|
|
fields = advanced_step.action.fields
|
|
self.assertTrue(len(fields['initial_state'].choices), 1)
|
|
choice = fields['initial_state'].choices[0]
|
|
self.assertTrue(choice[0], 'backup')
|
|
self.assertTrue(choice[1], _('Restore from Backup'))
|