Merge pull request #50 from aliyun/crc

Add Crc Test Cases

Author: baiyubin2020

sdk/Commands/GetBucketLocationCommand.cs

@@ -0,0 +1,51 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using System;
+using System.Collections.Generic;
+using Aliyun.OSS.Common.Communication;
+using Aliyun.OSS.Util;
+using Aliyun.OSS.Transform;
+
+namespace Aliyun.OSS.Commands
+{
+    internal class GetBucketLocationCommand : OssCommand<BucketLocationResult>
+    {
+         private readonly string _bucketName;
+
+         protected override string Bucket
+         {
+             get { return _bucketName; }
+         }
+
+         private GetBucketLocationCommand(IServiceClient client, Uri endpoint, ExecutionContext context,
+                                          string bucketName, IDeserializer<ServiceResponse, BucketLocationResult> deserializer)
+            : base(client, endpoint, context, deserializer)
+        {
+            OssUtils.CheckBucketName(bucketName);
+            _bucketName = bucketName;
+        }
+
+         public static GetBucketLocationCommand Create(IServiceClient client, Uri endpoint,
+                                                       ExecutionContext context,
+                                                       string bucketName)
+        {
+            return new GetBucketLocationCommand(client, endpoint, context, bucketName,
+                                                DeserializerFactory.GetFactory().CreateGetBucketLocationResultDeserializer());
+        }
+
+        protected override IDictionary<string, string> Parameters
+        {
+            get
+            {
+                return new Dictionary<string, string>()
+                {
+                    { RequestParameters.SUBRESOURCE_LOCATION, null }
+                };
+            }
+        }
+    }
+}

sdk/Commands/GetBucketMetadataCommand.cs

@@ -0,0 +1,48 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using System;
+using Aliyun.OSS.Common.Communication;
+using Aliyun.OSS.Util;
+using Aliyun.OSS.Transform;
+using System.Collections.Generic;
+
+namespace Aliyun.OSS.Commands
+{
+    internal class GetBucketMetadataCommand : OssCommand<BucketMetadata>
+    {
+        private readonly string _bucketName;
+
+        protected override HttpMethod Method
+        {
+            get { return HttpMethod.Head; }
+        }
+
+        protected override string Bucket
+        {
+            get { return _bucketName; }
+        }
+
+        private GetBucketMetadataCommand(IServiceClient client, Uri endpoint, ExecutionContext context,
+                                         IDeserializer<ServiceResponse, BucketMetadata> deserializer,
+                                         string bucketName)
+            : base(client, endpoint, context, deserializer)
+        {
+            OssUtils.CheckBucketName(bucketName);
+
+            _bucketName = bucketName;
+        }
+
+        public static GetBucketMetadataCommand Create(IServiceClient client, Uri endpoint, ExecutionContext context,
+                                                      string bucketName)
+        {
+            return new GetBucketMetadataCommand(client, endpoint, context,
+                                                DeserializerFactory.GetFactory().CreateGetBucketMetadataResultDeserializer(),
+                                                bucketName);
+        }
+    }
+
+}

sdk/Commands/GetBucketStorageCapacityCommand.cs

@@ -0,0 +1,51 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using System;
+using System.Collections.Generic;
+using Aliyun.OSS.Common.Communication;
+using Aliyun.OSS.Util;
+using Aliyun.OSS.Transform;
+
+namespace Aliyun.OSS.Commands
+{
+    internal class GetBucketStorageCapacityCommand : OssCommand<GetBucketStorageCapacityResult>
+    {
+         private readonly string _bucketName;
+
+         protected override string Bucket
+         {
+             get { return _bucketName; }
+         }
+
+         private GetBucketStorageCapacityCommand(IServiceClient client, Uri endpoint, ExecutionContext context,
+                                       string bucketName, IDeserializer<ServiceResponse, GetBucketStorageCapacityResult> deserializer)
+            : base(client, endpoint, context, deserializer)
+        {
+            OssUtils.CheckBucketName(bucketName);
+            _bucketName = bucketName;
+        }
+
+         public static GetBucketStorageCapacityCommand Create(IServiceClient client, Uri endpoint,
+                                                    ExecutionContext context,
+                                                    string bucketName)
+        {
+            return new GetBucketStorageCapacityCommand(client, endpoint, context, bucketName,
+                                           DeserializerFactory.GetFactory().CreateGetBucketStorageCapacityResultDeserializer());
+        }
+
+        protected override IDictionary<string, string> Parameters
+        {
+            get
+            {
+                return new Dictionary<string, string>()
+                {
+                    { RequestParameters.SUBRESOURCE_QOS, null }
+                };
+            }
+        }
+    }
+}

sdk/Commands/SetBucketStorageCapacityCommand.cs

@@ -0,0 +1,71 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using System;
+using System.IO;
+using System.Collections.Generic;
+
+using Aliyun.OSS.Common.Communication;
+using Aliyun.OSS.Util;
+using Aliyun.OSS.Transform;
+
+namespace Aliyun.OSS.Commands
+{
+    internal class SetBucketStorageCapacityCommand : OssCommand
+    {
+        private readonly string _bucketName;
+        private readonly SetBucketStorageCapacityRequest _setBucketStorageCapacityRequest;
+
+        protected override HttpMethod Method
+        {
+            get { return HttpMethod.Put; }
+        }
+
+        protected override string Bucket
+        {
+            get { return _bucketName; }
+        }
+
+        private SetBucketStorageCapacityCommand(IServiceClient client, Uri endpoint, ExecutionContext context,
+                                                string bucketName, SetBucketStorageCapacityRequest setBucketStorageCapacityRequest)
+            : base(client, endpoint, context)
+        {
+            OssUtils.CheckBucketName(bucketName);
+            if (setBucketStorageCapacityRequest.StorageCapacity < -1)
+                throw new ArgumentException("storage capacity must greater than -1");
+
+            _bucketName = bucketName;
+            _setBucketStorageCapacityRequest = setBucketStorageCapacityRequest;
+        }
+
+        public static SetBucketStorageCapacityCommand Create(IServiceClient client, Uri endpoint, 
+                                                    ExecutionContext context,
+                                                    string bucketName, SetBucketStorageCapacityRequest setBucketStorageCapacityRequest)
+        {
+            return new SetBucketStorageCapacityCommand(client, endpoint, context, bucketName, setBucketStorageCapacityRequest);
+        }
+        
+        
+        protected override IDictionary<string, string> Parameters
+        {
+            get
+            {
+                return new Dictionary<string, string>()
+                {
+                    { RequestParameters.SUBRESOURCE_QOS, null }
+                };
+            }
+        }
+        protected override Stream Content
+        {
+            get
+            {
+                return SerializerFactory.GetFactory().CreateSetBucketStorageCapacityRequestSerializer()
+                    .Serialize(_setBucketStorageCapacityRequest);
+            }
+        }
+    }
+}

sdk/Common/Handlers/CompleteMultipartUploadCrc64Handler.cs

@@ -22,12 +22,26 @@ public CompleteMultipartUploadCrc64Handler(CompleteMultipartUploadRequest reques
 
         public override void Handle(Communication.ServiceResponse response)
         {
+            
             if (response.Headers.ContainsKey(HttpHeaders.HashCrc64Ecma))
             {
                 ulong crc64 = 0;
+                bool checkCrc = true;
                 foreach (var part in _request.PartETags)
                 {
-                    crc64 = Crc64.Combine(crc64, ulong.Parse(part.Crc64), part.Length);
+                    if (!String.IsNullOrEmpty(part.Crc64) && part.Length != 0)
+                    {
+                        crc64 = Crc64.Combine(crc64, ulong.Parse(part.Crc64), part.Length);
+                    }
+                    else
+                    {
+                        checkCrc = false;
+                    }
+                }
+
+                if (!checkCrc) // the request does not have CRC64 for at least one part, skip the check
+                {
+                    return;
                 }
 
                 var ossCalculatedHashStr = response.Headers[HttpHeaders.HashCrc64Ecma];

sdk/Domain/BucketLocationResult.cs

@@ -0,0 +1,21 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using Aliyun.OSS.Model;
+
+namespace Aliyun.OSS
+{
+    /// <summary>
+    /// The result class of the operation to get bucket's location.
+    /// </summary>
+    public class BucketLocationResult : GenericResult
+    {
+        /// <summary>
+        /// The bucket location.
+        /// </summary>
+        public string Location { get; internal set; }
+    }
+}

sdk/Domain/BucketMetadata.cs

@@ -0,0 +1,57 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Net;
+using Aliyun.OSS.Util;
+
+namespace Aliyun.OSS
+{
+    /// <summary>
+    /// OSS bucket's metadata, which is the collection of 'key,value' pair.
+    /// </summary>
+    public class BucketMetadata
+    {      
+        private readonly IDictionary<string, string> _metadata = 
+            new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
+
+        /// <summary>
+        /// Gets HTTP standard headers and their values.
+        /// </summary>
+        public IDictionary<string, string> HttpMetadata
+        {
+            get { return _metadata; }
+        }
+
+        /// <summary>
+        /// Gets or sets the bucket region(location)
+        /// </summary>
+        public string BucketRegion
+        {
+            get
+            {
+                return _metadata.ContainsKey(HttpHeaders.BucketRegion)
+                    ? _metadata[HttpHeaders.BucketRegion] : null;
+            }
+            set
+            {
+                _metadata[HttpHeaders.BucketRegion] = value;
+            }
+
+        }
+
+        /// <summary>
+        /// Adds one HTTP header and its value.
+        /// </summary>
+        /// <param name="key">header name</param>
+        /// <param name="value">header value</param>
+        public void AddHeader(string key, string value)
+        {
+            _metadata.Add(key, value);
+        }
+    }
+}

sdk/Domain/GetBucketStorageCapacityResult.cs

@@ -0,0 +1,21 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+using Aliyun.OSS.Model;
+
+namespace Aliyun.OSS
+{
+    /// <summary>
+    /// The result class of the operation to get bucket's storage capacity.
+    /// </summary>
+    public class GetBucketStorageCapacityResult : GenericResult
+    {
+        /// <summary>
+        /// The bucket storage capacity.
+        /// </summary>
+        public long StorageCapacity { get; internal set; }
+    }
+}

sdk/Domain/SetBucketStorageCapacityRequest.cs

@@ -0,0 +1,35 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ */
+
+namespace Aliyun.OSS
+{
+    /// <summary>
+    /// The request class of the operation to set the bucket storage capacity
+    /// </summary>
+    public class SetBucketStorageCapacityRequest
+    {
+        /// <summary>
+        /// Gets the bucket name
+        /// </summary>
+        public string BucketName { get; private set; }
+
+        /// <summary>
+        /// The bucket storage capacity
+        /// </summary>
+        public long StorageCapacity { get; private set; }
+
+        /// <summary>
+        /// Creates a new instance of <see cref="SetBucketStorageCapacityRequest" />.
+        /// </summary>
+        /// <param name="bucketName"><see cref="OssObject" />bucket name</param>
+        /// <param name="storageCapacity">storage capacity</param>
+        public SetBucketStorageCapacityRequest(string bucketName, long storageCapacity)
+        {
+            BucketName = bucketName;
+            StorageCapacity = storageCapacity;
+        }
+    }
+}