You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cloudstack.apache.org by ra...@apache.org on 2015/04/29 07:44:19 UTC
[35/50] git commit: updated refs/heads/master to 0b83559
Browser Based Volume additional test scenarios
Project: http://git-wip-us.apache.org/repos/asf/cloudstack/repo
Commit: http://git-wip-us.apache.org/repos/asf/cloudstack/commit/651f8c93
Tree: http://git-wip-us.apache.org/repos/asf/cloudstack/tree/651f8c93
Diff: http://git-wip-us.apache.org/repos/asf/cloudstack/diff/651f8c93
Branch: refs/heads/master
Commit: 651f8c9339de27857feafc3571f636a6ca93d5a4
Parents: 3d6318e
Author: sailajamada <sa...@citrix.com>
Authored: Sat Apr 4 20:31:27 2015 +0530
Committer: sailajamada <sa...@citrix.com>
Committed: Sat Apr 4 20:31:27 2015 +0530
----------------------------------------------------------------------
.../component/test_browse_volumes.py | 170 ++++++++++++++++---
1 file changed, 150 insertions(+), 20 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/651f8c93/test/integration/component/test_browse_volumes.py
----------------------------------------------------------------------
diff --git a/test/integration/component/test_browse_volumes.py b/test/integration/component/test_browse_volumes.py
index 929cea8..b2b7caf 100644
--- a/test/integration/component/test_browse_volumes.py
+++ b/test/integration/component/test_browse_volumes.py
@@ -145,29 +145,35 @@ class TestBrowseUploadVolume(cloudstackTestCase):
def validate_uploaded_volume(self,up_volid,volumestate):
- config = Configurations.list(
+ config1 = Configurations.list(
self.apiclient,
name='upload.operation.timeout'
)
- uploadtimeout = int(config[0].value)
- time.sleep(uploadtimeout*60)
+ config2 = Configurations.list(
+ self.apiclient,
+ name='upload.monitornsving.interval'
+ )
+
+ uploadtimeout = int(config1[0].value)
+ monitoringinterval=int(config2[0].value)
+
+ time.sleep((uploadtimeout*60)+monitoringinterval)
list_volume_response = Volume.list(
self.apiclient,
id=up_volid
)
- self.assertNotEqual(
- list_volume_response,
- None,
- "Check if volume exists in ListVolumes"
- )
+ if list_volume_response is None:
+ self.debug("Volume got deleted after timeout")
+ return
self.assertEqual(
list_volume_response[0].state,
volumestate,
"Check volume state in ListVolumes"
)
+ return
def browse_upload_volume(self):
cmd = getUploadParamsForVolume.getUploadParamsForVolumeCmd()
@@ -718,11 +724,19 @@ class TestBrowseUploadVolume(cloudstackTestCase):
id=volumeid,
type='DATADISK'
)
+ self.debug(list_volume_response)
+
self.assertEqual(
- list_volume_response,
- None,
- "Check if volume exists in ListVolumes"
- )
+ isinstance(list_volume_response, list),
+ True,
+ "Check VOLUME is deleted from list Volumes"
+ )
+ self.assertEqual(
+ list_volume_response,
+ None,
+ "Check VOLUME is deleted from list Volumes"
+ )
+
return
def download_volume(self,volumeid):
@@ -1682,6 +1696,50 @@ class TestBrowseUploadVolume(cloudstackTestCase):
self.validate_uploaded_volume(getuploadparamsresponce.id,'Uploaded')
+
+
+ def uploadwithimagestoreid(self):
+
+ sscmd=listImageStores.listImageStoresCmd()
+ sscmd.zoneid=self.zone.id
+ sscmdresponse=self.apiclient.listImageStores(sscmd)
+
+ cmd = getUploadParamsForVolume.getUploadParamsForVolumeCmd()
+ cmd.zoneid = self.zone.id
+ cmd.format = self.uploadvolumeformat
+ cmd.name=self.volname+self.account.name+(random.choice(string.ascii_uppercase))
+ cmd.account=self.account.name
+ cmd.domainid=self.domain.id
+ cmd.imagestoreuuid=sscmdresponse[0].id
+ getuploadparamsresponce=self.apiclient.getUploadParamsForVolume(cmd)
+
+ signt=getuploadparamsresponce.signature
+ posturl=getuploadparamsresponce.postURL
+ metadata=getuploadparamsresponce.metadata
+ expiredata=getuploadparamsresponce.expires
+ self.globalurl=getuploadparamsresponce.postURL
+ #url = 'http://10.147.28.7/templates/rajani-thin-volume.vhd'
+ url=self.uploadurl
+
+ uploadfile = url.split('/')[-1]
+ r = requests.get(url, stream=True)
+ with open(uploadfile, 'wb') as f:
+ for chunk in r.iter_content(chunk_size=1024):
+ if chunk: # filter out keep-alive new chunks
+ f.write(chunk)
+ f.flush()
+
+ files={'file':(uploadfile,open(uploadfile,'rb'),'application/octet-stream')}
+
+ headers={'X-signature':signt,'X-metadata':metadata,'X-expires':expiredata}
+
+ results = requests.post(posturl,files=files,headers=headers,verify=False)
+
+ print results.status_code
+ if results.status_code !=200:
+ self.fail("Upload is not fine")
+
+ self.validate_uploaded_volume(getuploadparamsresponce.id,'Uploaded')
def uploadwithsamedisplaytext(self,voldetails):
@@ -1789,6 +1847,44 @@ class TestBrowseUploadVolume(cloudstackTestCase):
self.validate_uploaded_volume(getuploadparamsresponce.id,'Uploaded')
+
+
+ def posturlwithdeletedvolume(self,getuploadparamsresponce):
+
+ signt=getuploadparamsresponce.signature
+ posturl=getuploadparamsresponce.postURL
+ metadata=getuploadparamsresponce.metadata
+ expiredata=getuploadparamsresponce.expires
+ self.validate_uploaded_volume(getuploadparamsresponce.id,'UploadAbandoned')
+
+ cmd = deleteVolume.deleteVolumeCmd()
+ cmd.id = getuploadparamsresponce.id
+
+ self.apiclient.deleteVolume(cmd)
+
+ success = False
+
+ url=self.extuploadurl
+
+ uploadfile = url.split('/')[-1]
+ r = requests.get(url, stream=True)
+ with open(uploadfile, 'wb') as f:
+ for chunk in r.iter_content(chunk_size=1024):
+ if chunk: # filter out keep-alive new chunks
+ f.write(chunk)
+ f.flush()
+
+ files={'file':(uploadfile,open(uploadfile,'rb'),'application/octet-stream')}
+
+ headers={'X-signature':signt,'X-metadata':metadata,'X-expires':expiredata}
+
+ results = requests.post(posturl,files=files,headers=headers,verify=False)
+
+ print results.status_code
+ if results.status_code ==200:
+ return("FAIL")
+ return("PASS")
+
@attr(tags = ["advanced", "advancedns", "smoke", "basic"], required_hardware="true")
def test_01_Browser_volume_Life_cycle_tpath(self):
"""
@@ -2068,10 +2164,6 @@ class TestBrowseUploadVolume(cloudstackTestCase):
self.debug("========================= Test 33 Upload Volume with custom offering id=========================")
self.uploadwithcustomoffering()
-
- self.debug("========================= Test 34 Upload Volume with tampered post URL=========================")
- invaliduploadvolume=self.invalidposturl()
-
except Exception as e:
self.fail("Exception occurred : %s" % e)
return
@@ -2083,7 +2175,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
"""
try:
- self.debug("========================= Test 35 Upload volume with Multiple SSVM=========================")
+ self.debug("========================= Test 34 Upload volume with Multiple SSVM=========================")
testresult=self.uploadvolwithmultissvm()
if testresult==0:
@@ -2103,7 +2195,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
"""
try:
- self.debug("========================= Test 36 Upload volume with extended file extenstions=========================")
+ self.debug("========================= Test 35 Upload volume with extended file extenstions=========================")
if self.uploadvolumeformat=="OVA":
raise unittest.SkipTest("This test is need not be executed on VMWARE")
self.uploadwithextendedfileextentions()
@@ -2118,7 +2210,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
"""
Test Browser_Upload_Volume_Storage_Cleanup_Config_Validation
"""
- self.debug("========================= Test 37 Validate storage.cleanup.enabled and storage.cleanup.interval ========================= ")
+ self.debug("========================= Test 36 Validate storage.cleanup.enabled and storage.cleanup.interval ========================= ")
config1 = Configurations.list(
self.apiclient,
name='storage.cleanup.enabled'
@@ -2151,7 +2243,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
Test Browser_Upload_Volume_Negative_Scenarios
"""
try:
- self.debug("========================= Test 34 Upload Volume with tampered post URL=========================")
+ self.debug("========================= Test 37 Upload Volume with tampered post URL=========================")
invaliduploadvolume=self.invalidposturl()
except Exception as e:
@@ -2165,3 +2257,41 @@ class TestBrowseUploadVolume(cloudstackTestCase):
except Exception as e:
raise Exception("Warning: Exception during cleanup : %s" % e)
return
+
+
+
+ @attr(tags = ["advanced", "advancedns", "smoke", "basic"], required_hardware="true")
+ def test_09_Browser_Upload_Volume_PostURL_with_Deleted_Uploadvolume_Details(self):
+ """
+ Test Browser_Upload_Volume_PostURL_with_Deleted_Uploadvolume_Details
+ """
+ self.debug("========================= Test 38 PostURL_with_Deleted_Upload_Abondaned volume details=========================")
+ browse_up_vol=self.onlyupload()
+ res=self.posturlwithdeletedvolume(browse_up_vol)
+
+ if res=="FAIL":
+ self.fail("Verify - PostURL_with_Deleted_Uploadvolume_Details ")
+
+ return
+
+
+ @attr(tags = ["advanced", "advancedns", "smoke", "basic"], required_hardware="true")
+ def test_10_Browser_Upload_Volume_API_with_imagepoolid(self):
+ """
+ Test Browser_Upload_Volume_API_with_imagepoolid
+ """
+ self.debug("========================= Test 39 Test Browser_Upload_Volume_API_with_imagepoolid=========================")
+ self.uploadwithimagestoreid()
+
+ return
+
+ @classmethod
+ def tearDownClass(self):
+ try:
+ self.apiclient = super(TestBrowseUploadVolume,self).getClsTestClient().getApiClient()
+ cleanup_resources(self.apiclient, self._cleanup)
+ except Exception as e:
+ raise Exception("Warning: Exception during cleanup : %s" % e)
+ return
+
+