[Fix] obs multipart upload fix for swiss region

Author: anton-sidelnikov

examples/obs/multipart_upload.py

@@ -16,7 +16,7 @@
 """
 
 openstack.enable_logging(True)
-conn = openstack.connect(cloud='otc')
+conn = openstack.connect(cloud='swiss')
 sdk.register_otc_extensions(conn)
 sdk.get_ak_sk(conn)
 
@@ -27,8 +27,8 @@
 )
 
 obj = conn.obs.upload_object(
-    name='pdfs/book.pdf',
-    filename='my-book.pdf',
+    name='rancheros-openstack',
+    filename='rancheros-openstack.img',
     container=container,
-    segment_size=1400000
+    segment_size=14000000
 )

otcextensions/sdk/obs/v1/obj.py

@@ -334,6 +334,7 @@ def initiate_multipart_upload(proxy, endpoint, name, **params):
         root = ET.fromstring(response.content)
         for element in root:
             dict_raw_resource = _base.BaseResource.etree_to_dict(element)
+            dict_raw_resource = Object.clear_element(dict_raw_resource, proxy)
             dict_resource.update(dict_raw_resource)
         return dict_resource['UploadId']
 
@@ -344,19 +345,32 @@ def get_parts(proxy, endpoint, requests_auth):
         root = ET.fromstring(response.content)
         for element in root:
             dict_raw_resource = _base.BaseResource.etree_to_dict(element)
-            if element.tag == 'Part':
-                dict_resource.setdefault('Parts', []).\
-                    append(dict_raw_resource['Part'])
+            dict_raw_resource = Object.clear_element(dict_raw_resource, proxy)
+            if element.tag.endswith('Part'):
+                dict_resource.setdefault('Parts', []).append(dict_raw_resource['Part'])
                 continue
             dict_resource.update(dict_raw_resource)
         return dict_resource
 
+    @staticmethod
+    def clear_element(dict_raw_resource, proxy):
+        if proxy.region_name == 'eu-ch2':
+            cleaned_dict = {}
+            for full_key, value in dict_raw_resource.items():
+                # Strip namespace if present
+                cleaned_key = full_key.split('}', 1)[1] \
+                    if full_key.startswith('{') else full_key
+                cleaned_dict[cleaned_key] = value
+            dict_raw_resource = cleaned_dict
+        return dict_raw_resource
+
     @staticmethod
     def complete_multipart_upload(
             proxy, endpoint, upload_id, data, headers, requests_auth):
         url = f'{endpoint}?uploadId={upload_id}'
         root = ET.Element("CompleteMultipartUpload")
         for item in data:
+            item = Object.clear_element(item, proxy)
             part = ET.SubElement(root, "Part")
             ET.SubElement(part, 'PartNumber').text = item['PartNumber']
             ET.SubElement(part, 'ETag').text = item['ETag']