Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 1 | # Copyright 2014 OpenStack Foundation |
| 2 | # All Rights Reserved. |
| 3 | # |
| 4 | # Licensed under the Apache License, Version 2.0 (the "License"); you may |
| 5 | # not use this file except in compliance with the License. You may obtain |
| 6 | # a copy of the License at |
| 7 | # |
| 8 | # http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | # |
| 10 | # Unless required by applicable law or agreed to in writing, software |
| 11 | # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT |
| 12 | # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the |
| 13 | # License for the specific language governing permissions and limitations |
| 14 | # under the License. |
| 15 | |
Sirushti Murugesan | 12dc973 | 2016-07-13 22:49:17 +0530 | [diff] [blame] | 16 | from oslo_serialization import base64 |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 17 | from oslo_serialization import jsonutils as json |
| 18 | |
Masayuki Igawa | 1edf94f | 2014-03-04 18:34:16 +0900 | [diff] [blame] | 19 | from tempest.api.volume import base |
Fei Long Wang | d39431f | 2015-05-14 11:30:48 +1200 | [diff] [blame] | 20 | from tempest.common.utils import data_utils |
Yaroslav Lobankov | ed3a35b | 2016-03-24 22:41:30 -0500 | [diff] [blame] | 21 | from tempest.common import waiters |
Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 22 | from tempest import config |
Ken'ichi Ohmichi | 6b279c7 | 2017-01-27 18:26:59 -0800 | [diff] [blame] | 23 | from tempest.lib import decorators |
Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 24 | |
| 25 | CONF = config.CONF |
Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 26 | |
| 27 | |
lkuchlan | 9dea88e | 2016-06-07 17:12:01 +0300 | [diff] [blame] | 28 | class VolumesBackupsAdminV2Test(base.BaseVolumeAdminTest): |
Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 29 | |
| 30 | @classmethod |
Rohan Kanade | 0574915 | 2015-01-30 17:15:18 +0530 | [diff] [blame] | 31 | def skip_checks(cls): |
lkuchlan | 9dea88e | 2016-06-07 17:12:01 +0300 | [diff] [blame] | 32 | super(VolumesBackupsAdminV2Test, cls).skip_checks() |
Giulio Fidente | 74b08ad | 2014-01-18 04:02:51 +0100 | [diff] [blame] | 33 | if not CONF.volume_feature_enabled.backup: |
| 34 | raise cls.skipException("Cinder backup feature disabled") |
| 35 | |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 36 | def _delete_backup(self, backup_id): |
bkopilov | 62d2175 | 2016-06-08 10:16:11 +0300 | [diff] [blame] | 37 | self.admin_backups_client.delete_backup(backup_id) |
Ken'ichi Ohmichi | 153b3d9 | 2016-08-03 14:35:46 -0700 | [diff] [blame] | 38 | self.admin_backups_client.wait_for_resource_deletion(backup_id) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 39 | |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 40 | def _decode_url(self, backup_url): |
Sirushti Murugesan | 12dc973 | 2016-07-13 22:49:17 +0530 | [diff] [blame] | 41 | return json.loads(base64.decode_as_text(backup_url)) |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 42 | |
| 43 | def _encode_backup(self, backup): |
| 44 | retval = json.dumps(backup) |
Sirushti Murugesan | 12dc973 | 2016-07-13 22:49:17 +0530 | [diff] [blame] | 45 | return base64.encode_as_text(retval) |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 46 | |
| 47 | def _modify_backup_url(self, backup_url, changes): |
| 48 | backup = self._decode_url(backup_url) |
| 49 | backup.update(changes) |
| 50 | return self._encode_backup(backup) |
| 51 | |
Ken'ichi Ohmichi | 6b279c7 | 2017-01-27 18:26:59 -0800 | [diff] [blame] | 52 | @decorators.idempotent_id('a99c54a1-dd80-4724-8a13-13bf58d4068d') |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 53 | def test_volume_backup_export_import(self): |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 54 | """Test backup export import functionality. |
| 55 | |
| 56 | Cinder allows exporting DB backup information through its API so it can |
| 57 | be imported back in case of a DB loss. |
| 58 | """ |
lkuchlan | a2beb49 | 2016-08-17 12:42:44 +0300 | [diff] [blame] | 59 | volume = self.create_volume() |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 60 | # Create backup |
zhufl | c6ce539 | 2016-08-17 14:34:37 +0800 | [diff] [blame] | 61 | backup_name = data_utils.rand_name(self.__class__.__name__ + '-Backup') |
lkuchlan | a2beb49 | 2016-08-17 12:42:44 +0300 | [diff] [blame] | 62 | backup = (self.create_backup(backup_client=self.admin_backups_client, |
| 63 | volume_id=volume['id'], |
| 64 | name=backup_name)) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 65 | self.assertEqual(backup_name, backup['name']) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 66 | |
| 67 | # Export Backup |
bkopilov | 62d2175 | 2016-06-08 10:16:11 +0300 | [diff] [blame] | 68 | export_backup = (self.admin_backups_client.export_backup(backup['id']) |
John Warren | 6cadeee | 2015-08-13 17:00:56 +0000 | [diff] [blame] | 69 | ['backup-record']) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 70 | self.assertIn('backup_service', export_backup) |
| 71 | self.assertIn('backup_url', export_backup) |
| 72 | self.assertTrue(export_backup['backup_service'].startswith( |
| 73 | 'cinder.backup.drivers')) |
| 74 | self.assertIsNotNone(export_backup['backup_url']) |
| 75 | |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 76 | # NOTE(geguileo): Backups are imported with the same backup id |
| 77 | # (important for incremental backups among other things), so we cannot |
| 78 | # import the exported backup information as it is, because that Backup |
| 79 | # ID already exists. So we'll fake the data by changing the backup id |
| 80 | # in the exported backup DB info we have retrieved before importing it |
| 81 | # back. |
| 82 | new_id = data_utils.rand_uuid() |
| 83 | new_url = self._modify_backup_url( |
| 84 | export_backup['backup_url'], {'id': new_id}) |
| 85 | |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 86 | # Import Backup |
bkopilov | 62d2175 | 2016-06-08 10:16:11 +0300 | [diff] [blame] | 87 | import_backup = self.admin_backups_client.import_backup( |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 88 | backup_service=export_backup['backup_service'], |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 89 | backup_url=new_url)['backup'] |
| 90 | |
| 91 | # NOTE(geguileo): We delete both backups, but only one of those |
| 92 | # deletions will delete data from the backup back-end because they |
| 93 | # were both pointing to the same backend data. |
| 94 | self.addCleanup(self._delete_backup, new_id) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 95 | self.assertIn("id", import_backup) |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 96 | self.assertEqual(new_id, import_backup['id']) |
lkuchlan | 8f321d8 | 2016-09-06 10:06:30 +0300 | [diff] [blame] | 97 | waiters.wait_for_backup_status(self.admin_backups_client, |
| 98 | import_backup['id'], 'available') |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 99 | |
| 100 | # Verify Import Backup |
bkopilov | 62d2175 | 2016-06-08 10:16:11 +0300 | [diff] [blame] | 101 | backups = self.admin_backups_client.list_backups( |
| 102 | detail=True)['backups'] |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 103 | self.assertIn(new_id, [b['id'] for b in backups]) |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 104 | |
| 105 | # Restore backup |
bkopilov | 62d2175 | 2016-06-08 10:16:11 +0300 | [diff] [blame] | 106 | restore = self.admin_backups_client.restore_backup( |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 107 | backup['id'])['restore'] |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 108 | self.addCleanup(self.admin_volume_client.delete_volume, |
| 109 | restore['volume_id']) |
Gorka Eguileor | 9de20c1 | 2015-08-13 11:16:43 +0200 | [diff] [blame] | 110 | self.assertEqual(backup['id'], restore['backup_id']) |
Yaroslav Lobankov | ed3a35b | 2016-03-24 22:41:30 -0500 | [diff] [blame] | 111 | waiters.wait_for_volume_status(self.admin_volume_client, |
| 112 | restore['volume_id'], 'available') |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 113 | |
| 114 | # Verify if restored volume is there in volume list |
John Warren | 6177c9e | 2015-08-19 20:00:17 +0000 | [diff] [blame] | 115 | volumes = self.admin_volume_client.list_volumes()['volumes'] |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 116 | self.assertIn(restore['volume_id'], [v['id'] for v in volumes]) |
lkuchlan | 8f321d8 | 2016-09-06 10:06:30 +0300 | [diff] [blame] | 117 | waiters.wait_for_backup_status(self.admin_backups_client, |
| 118 | import_backup['id'], 'available') |
ravikumar-venkatesan | 18c1d0e | 2015-03-18 11:28:37 +0000 | [diff] [blame] | 119 | |
Ken'ichi Ohmichi | 6b279c7 | 2017-01-27 18:26:59 -0800 | [diff] [blame] | 120 | @decorators.idempotent_id('47a35425-a891-4e13-961c-c45deea21e94') |
bkopilov | 19fc5fd | 2016-07-06 12:02:18 +0300 | [diff] [blame] | 121 | def test_volume_backup_reset_status(self): |
lkuchlan | a2beb49 | 2016-08-17 12:42:44 +0300 | [diff] [blame] | 122 | # Create a volume |
| 123 | volume = self.create_volume() |
bkopilov | 19fc5fd | 2016-07-06 12:02:18 +0300 | [diff] [blame] | 124 | # Create a backup |
zhufl | c6ce539 | 2016-08-17 14:34:37 +0800 | [diff] [blame] | 125 | backup_name = data_utils.rand_name( |
| 126 | self.__class__.__name__ + '-Backup') |
lkuchlan | a2beb49 | 2016-08-17 12:42:44 +0300 | [diff] [blame] | 127 | backup = self.create_backup(backup_client=self.admin_backups_client, |
| 128 | volume_id=volume['id'], |
| 129 | name=backup_name) |
bkopilov | 19fc5fd | 2016-07-06 12:02:18 +0300 | [diff] [blame] | 130 | self.assertEqual(backup_name, backup['name']) |
bkopilov | 19fc5fd | 2016-07-06 12:02:18 +0300 | [diff] [blame] | 131 | # Reset backup status to error |
| 132 | self.admin_backups_client.reset_backup_status(backup_id=backup['id'], |
| 133 | status="error") |
lkuchlan | 8f321d8 | 2016-09-06 10:06:30 +0300 | [diff] [blame] | 134 | waiters.wait_for_backup_status(self.admin_backups_client, |
| 135 | backup['id'], 'error') |
bkopilov | 19fc5fd | 2016-07-06 12:02:18 +0300 | [diff] [blame] | 136 | |
jun xie | ebc3da3 | 2014-11-18 14:34:56 +0800 | [diff] [blame] | 137 | |
lkuchlan | 9dea88e | 2016-06-07 17:12:01 +0300 | [diff] [blame] | 138 | class VolumesBackupsAdminV1Test(VolumesBackupsAdminV2Test): |
jun xie | ebc3da3 | 2014-11-18 14:34:56 +0800 | [diff] [blame] | 139 | _api_version = 1 |