blob: 2c13a3ced10614c357a8b8597ecb52323f49edb3 [file] [log] [blame]
wingwjcbd82dc2013-10-22 16:38:39 +08001# Copyright 2013 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
Zhi Kun Liubb363a22013-11-28 18:47:39 +080016from tempest.api.volume import base
Yaroslav Lobankoved3a35b2016-03-24 22:41:30 -050017from tempest.common import waiters
Ken'ichi Ohmichi6b279c72017-01-27 18:26:59 -080018from tempest.lib import decorators
wingwjcbd82dc2013-10-22 16:38:39 +080019
20
Ken'ichi Ohmichie8afb8c2017-03-27 11:25:37 -070021class VolumesTransfersTest(base.BaseVolumeTest):
wingwjcbd82dc2013-10-22 16:38:39 +080022
Andrea Frittolib21de6c2015-02-06 20:12:38 +000023 credentials = ['primary', 'alt', 'admin']
Rohan Kanade05749152015-01-30 17:15:18 +053024
25 @classmethod
26 def setup_clients(cls):
Ken'ichi Ohmichie8afb8c2017-03-27 11:25:37 -070027 super(VolumesTransfersTest, cls).setup_clients()
wingwjcbd82dc2013-10-22 16:38:39 +080028
Jordan Pittier8160d312017-04-18 11:52:23 +020029 cls.client = cls.os_primary.volume_transfers_v2_client
ghanshyam59614b42017-02-24 16:32:02 +000030 cls.alt_client = cls.os_alt.volume_transfers_v2_client
31 cls.alt_volumes_client = cls.os_alt.volumes_v2_client
Jordan Pittier8160d312017-04-18 11:52:23 +020032 cls.adm_volumes_client = cls.os_admin.volumes_v2_client
wingwjcbd82dc2013-10-22 16:38:39 +080033
Ken'ichi Ohmichi6b279c72017-01-27 18:26:59 -080034 @decorators.idempotent_id('4d75b645-a478-48b1-97c8-503f64242f1a')
wingwjcbd82dc2013-10-22 16:38:39 +080035 def test_create_get_list_accept_volume_transfer(self):
36 # Create a volume first
Ken'ichi Ohmichi5687d552013-12-26 19:00:12 +090037 volume = self.create_volume()
ghanshyam59614b42017-02-24 16:32:02 +000038 self.addCleanup(self.delete_volume,
39 self.adm_volumes_client,
40 volume['id'])
wingwjcbd82dc2013-10-22 16:38:39 +080041
42 # Create a volume transfer
Ghanshyam58a9e872015-12-18 10:46:07 +090043 transfer = self.client.create_volume_transfer(
44 volume_id=volume['id'])['transfer']
wingwjcbd82dc2013-10-22 16:38:39 +080045 transfer_id = transfer['id']
46 auth_key = transfer['auth_key']
lkuchlan52d7b0d2016-11-07 20:53:19 +020047 waiters.wait_for_volume_resource_status(
ghanshyam59614b42017-02-24 16:32:02 +000048 self.volumes_client, volume['id'], 'awaiting-transfer')
wingwjcbd82dc2013-10-22 16:38:39 +080049
50 # Get a volume transfer
John Warren6177c9e2015-08-19 20:00:17 +000051 body = self.client.show_volume_transfer(transfer_id)['transfer']
wingwjcbd82dc2013-10-22 16:38:39 +080052 self.assertEqual(volume['id'], body['volume_id'])
53
54 # List volume transfers, the result should be greater than
55 # or equal to 1
John Warren6177c9e2015-08-19 20:00:17 +000056 body = self.client.list_volume_transfers()['transfers']
Ferenc Horváth268ccce2017-06-08 12:39:02 +020057 self.assertNotEmpty(body)
wingwjcbd82dc2013-10-22 16:38:39 +080058
59 # Accept a volume transfer by alt_tenant
Ghanshyam58a9e872015-12-18 10:46:07 +090060 body = self.alt_client.accept_volume_transfer(
61 transfer_id, auth_key=auth_key)['transfer']
ghanshyam59614b42017-02-24 16:32:02 +000062 waiters.wait_for_volume_resource_status(self.alt_volumes_client,
lkuchlan52d7b0d2016-11-07 20:53:19 +020063 volume['id'], 'available')
jeremy.zhang768b3342017-05-11 11:14:46 +080064 accepted_volume = self.alt_volumes_client.show_volume(
65 volume['id'])['volume']
66 self.assertEqual(self.os_alt.credentials.user_id,
67 accepted_volume['user_id'])
68 self.assertEqual(self.os_alt.credentials.project_id,
69 accepted_volume['os-vol-tenant-attr:tenant_id'])
wingwjcbd82dc2013-10-22 16:38:39 +080070
Ken'ichi Ohmichi6b279c72017-01-27 18:26:59 -080071 @decorators.idempotent_id('ab526943-b725-4c07-b875-8e8ef87a2c30')
wingwjcbd82dc2013-10-22 16:38:39 +080072 def test_create_list_delete_volume_transfer(self):
73 # Create a volume first
Ken'ichi Ohmichi5687d552013-12-26 19:00:12 +090074 volume = self.create_volume()
ghanshyam59614b42017-02-24 16:32:02 +000075 self.addCleanup(self.delete_volume,
76 self.adm_volumes_client,
77 volume['id'])
wingwjcbd82dc2013-10-22 16:38:39 +080078
79 # Create a volume transfer
jeremy.zhangc2618d92017-04-20 09:21:05 +080080 transfer_id = self.client.create_volume_transfer(
81 volume_id=volume['id'])['transfer']['id']
lkuchlan52d7b0d2016-11-07 20:53:19 +020082 waiters.wait_for_volume_resource_status(
ghanshyam59614b42017-02-24 16:32:02 +000083 self.volumes_client, volume['id'], 'awaiting-transfer')
wingwjcbd82dc2013-10-22 16:38:39 +080084
jeremy.zhangc2618d92017-04-20 09:21:05 +080085 # List all volume transfers with details, check the detail-specific
86 # elements, and look for the created transfer.
87 transfers = self.client.list_volume_transfers(detail=True)['transfers']
88 self.assertNotEmpty(transfers)
89 for transfer in transfers:
90 self.assertIn('created_at', transfer)
91 volume_list = [transfer['volume_id'] for transfer in transfers]
92 self.assertIn(volume['id'], volume_list,
93 'Transfer not found for volume %s' % volume['id'])
wingwjcbd82dc2013-10-22 16:38:39 +080094
95 # Delete a volume transfer
Swapnil Kulkarnid9df38c2014-08-16 18:06:52 +000096 self.client.delete_volume_transfer(transfer_id)
lkuchlan52d7b0d2016-11-07 20:53:19 +020097 waiters.wait_for_volume_resource_status(
ghanshyam59614b42017-02-24 16:32:02 +000098 self.volumes_client, volume['id'], 'available')