From: zhangshaowen <zhang_shaowen@139.com>
Date: Wed, 7 Jun 2017 08:55:34 +0000 (+0800)
Subject: Add test case for checking bucket index after completing multipart upload
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c6be46fe02c31e95e993b3ef41d975dc2ad68d58;p=ragweed.git

Add test case for checking bucket index after completing multipart upload
when bucket versioning is enabled.

Signed-off-by: Zhang Shaowen <zhangshaowen@cmss.chinamobile.com>
---

diff --git a/ragweed/framework.py b/ragweed/framework.py
index 9fb9b7a..761c162 100644
--- a/ragweed/framework.py
+++ b/ragweed/framework.py
@@ -64,6 +64,9 @@ class RGWRESTAdmin:
         result = self.read_meta_key('bucket.instance:' + bucket_name + ":" + bucket_id)
         return result.data.bucket_info
 
+    def check_bucket_index(self, bucket_name):
+        return self.get_resource('/admin/bucket',{'index' : None, 'bucket':bucket_name})
+
     def get_obj_layout(self, key):
         path = '/' + key.bucket.name + '/' + key.name
         params = {'layout': None}
diff --git a/ragweed/tests/tests.py b/ragweed/tests/tests.py
index c37a41a..0825ded 100644
--- a/ragweed/tests/tests.py
+++ b/ragweed/tests/tests.py
@@ -221,6 +221,34 @@ class r_test_multipart_simple(RTest):
 
         validate_obj(rb, self.r_obj, self.r_crc)
 
+# prepare:
+# init, upload, and complete a multipart object
+# check:
+# part index is removed
+class r_test_multipart_index_versioning(RTest):
+    def init(self):
+        self.obj_size = 18 * 1024 * 1024
+        self.part_size = 5 * 1024 * 1024
+
+    def prepare(self):
+        rb = self.create_bucket()
+        rb.bucket.configure_versioning('true')
+        self.r_obj = 'foo'
+
+        uploader = MultipartUploader(rb, self.r_obj, self.obj_size, self.part_size)
+
+        uploader.prepare()
+        uploader.upload_all()
+        uploader.complete()
+
+    def check(self):
+        for rb in self.get_buckets():
+            break
+        index_check_result = rgwa().check_bucket_index(rb.name)
+        print index_check_result
+
+        eq(0, len(index_check_result))
+
 
 # prepare:
 # init, upload multipart object