first upload

Author: cuiliang

Api/Base/BaseObjectCommand.cs

@@ -0,0 +1,30 @@
+using Cuiliang.AliyunOssSdk.Entites;
+using Cuiliang.AliyunOssSdk.Request;
+
+namespace Cuiliang.AliyunOssSdk.Api.Base
+{
+    /// <summary>
+    /// 对某个对象进行的操作的命令基类，主要是保存了Bucket信息和key
+    /// </summary>
+    /// <typeparam name="TResult"></typeparam>
+    public abstract class BaseObjectCommand<TResult>: BaseOssCommand<TResult>
+    {
+        /// <summary>
+        /// 对象所处的Bucket
+        /// </summary>
+        public BucketInfo Bucket { get; set; }
+
+        /// <summary>
+        /// 目标对象的Key
+        /// </summary>
+        public string Key { get; set; }
+
+        public BaseObjectCommand(RequestContext requestContext, 
+            BucketInfo bucket,
+            string key) : base(requestContext)
+        {
+            Bucket = bucket;
+            Key = key;
+        }
+    }
+}

Api/Base/BaseOssCommand.cs

@@ -0,0 +1,140 @@
+using System;
+using System.Net;
+using System.Net.Http;
+using System.Threading.Tasks;
+using Cuiliang.AliyunOssSdk.Api.Common.Consts;
+using Cuiliang.AliyunOssSdk.Entites;
+using Cuiliang.AliyunOssSdk.Request;
+using Cuiliang.AliyunOssSdk.Utility;
+
+namespace Cuiliang.AliyunOssSdk.Api.Base
+{
+    /// <summary>
+    /// OSS API命令基类，负责构建request，并对结果进行解析
+    /// </summary>
+    /// <typeparam name="TResult"></typeparam>
+    public abstract class BaseOssCommand<TResult>
+    {
+        protected RequestContext RequestContext { get; private set; }
+
+        public BaseOssCommand(RequestContext requestContext)
+        {
+            RequestContext = requestContext;
+        }
+
+        /// <summary>
+        /// 构造Request请求，由派生类实现
+        /// </summary>
+        /// <returns></returns>
+        public abstract ServiceRequest BuildRequest();
+
+        /// <summary>
+        /// 解析结果对象。基类提供通用方式处理：解析xml。对于特殊返回结果，定义重载函数来进行处理。
+        /// </summary>
+        /// <param name="response"></param>
+        /// <returns></returns>
+        public virtual async Task<OssResult<TResult>> ParseResultAsync(HttpResponseMessage response)
+        {
+            //成功情况下的默认解析处理
+            var length = response.Content?.Headers?.ContentLength;
+            if (length > 0)
+            {
+                var result = SerializeHelper.Deserialize<TResult>(await response.Content.ReadAsStreamAsync());
+                var ossResult = new OssResult<TResult>()
+                {
+                    IsSuccess =  true,
+                    SuccessResult = result
+                };
+
+                return ossResult;
+            }
+
+            return new OssResult<TResult>()
+            {
+                IsSuccess =  false,
+                ErrorMessage = "ContentLength = 0"
+            };
+        }
+
+        /// <summary>
+        /// 执行请求并返回结果
+        /// </summary>
+        /// <returns></returns>
+        public async Task<OssResult<TResult>> ExecuteAsync()
+        {
+            try
+            {
+                ServiceRequest request = BuildRequest();
+
+                //加入dateheader
+                request.Headers[HttpHeaders.Date] = DateUtils.FormatRfc822Date(DateTime.UtcNow);
+                
+
+                if (RequestContext.OssCredential.UseToken)
+                {
+                    request.Headers[HttpHeaders.SecurityToken] = RequestContext.OssCredential.SecurityToken;
+                }
+
+
+                // 发送请求
+                var caller = new ServiceCaller(RequestContext);
+                HttpResponseMessage response = await caller.CallServiceAsync(request);
+
+                // 解析结果
+                return await ProcessResponseInternal(response);
+            }
+            catch (Exception ex)
+            {
+                return new OssResult<TResult>()
+                {
+                    IsSuccess = false,
+                    InnerException = ex,
+                    ErrorMessage = ex.Message
+                };
+            }
+            
+        }
+
+        /// <summary>
+        /// 初步处理返回的结果，对于失败的http代码，进行错误解析处理
+        /// </summary>
+        /// <param name="response"></param>
+        /// <returns></returns>
+        private async Task<OssResult<TResult>> ProcessResponseInternal(HttpResponseMessage response)
+        {
+            if (response.IsSuccessStatusCode)
+            {
+                return await ParseResultAsync(response);
+            }
+            else if (response.StatusCode == HttpStatusCode.NotModified) //此处处理是参考官方的sdk
+            {
+                return new OssResult<TResult>()
+                {
+                    IsSuccess =  false,
+                    ErrorMessage = "NOT_MODIFIED"
+                };
+            }else
+            {
+                //错误的http代码
+                if (response.Content?.Headers.ContentLength > 0)
+                {
+                    var errorResult =
+                        SerializeHelper.Deserialize<ErrorResult>(await response.Content.ReadAsStreamAsync());
+                    
+                    return new OssResult<TResult>()
+                    {
+                        IsSuccess = false,
+                        ErrorResult = errorResult,
+                        ErrorMessage = errorResult.Message
+                    };
+                }
+
+                return new OssResult<TResult>()
+                {
+                    IsSuccess = false,
+                    ErrorMessage = "STATUSCODE:" + response.StatusCode
+                };
+            }
+        }
+    }
+}

Api/Bucket/List/ListBucketCommand.cs

@@ -0,0 +1,34 @@
+using System.Net.Http;
+using Cuiliang.AliyunOssSdk.Api.Base;
+using Cuiliang.AliyunOssSdk.Api.Common.Consts;
+using Cuiliang.AliyunOssSdk.Entites;
+using Cuiliang.AliyunOssSdk.Request;
+
+namespace Cuiliang.AliyunOssSdk.Api.Bucket.List
+{
+    public class ListBucketCommand: BaseOssCommand<ListBucketsResult>
+    {
+        private ListBucketsRequest _request;
+        private string _region;
+
+        public ListBucketCommand(RequestContext requestContext, string region, ListBucketsRequest request) : base(requestContext)
+        {
+            _request = request;
+            _region = region;
+        }
+
+        public override ServiceRequest BuildRequest()
+        {
+            
+            var req = new ServiceRequest(BucketInfo.CreateByRegion(_region, ""), "", HttpMethod.Get);
+
+            //
+            req.AddParameter(RequestParameters.PREFIX, _request.Prefix);
+            req.AddParameter(RequestParameters.MARKER, _request.Marker);
+            req.AddParameter(RequestParameters.MAX_KEYS, _request.MaxKeys?.ToString());
+
+            return req;
+        }
+        
+    }
+}

Api/Bucket/List/ListBucketsRequest.cs

@@ -0,0 +1,33 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ * 版权所有 （C）阿里云计算有限公司
+ */
+
+using Cuiliang.AliyunOssSdk.Api.Common;
+
+namespace Cuiliang.AliyunOssSdk.Api.Bucket.List
+{
+    /// <summary>
+    /// 包含获取<see cref="Bucket" />列表的请求信息。
+    /// </summary>
+    public class ListBucketsRequest
+    {
+        /// <summary>
+        /// 获取或设置一个值，限定返回的<see cref="Bucket" />的Key必须以该值作为前缀。
+        /// </summary>
+        public string Prefix { get; set; }
+
+        /// <summary>
+        /// 获取或设置一个值，用户设定结果从该值之后按字母排序的第一个开始返回。
+        /// </summary>
+        public string Marker { get; set; }
+
+        /// <summary>
+        /// 获取或设置一个值，用于限定此次返回bucket的最大数。
+        /// 如果不设定，默认为100。
+        /// </summary>
+        public int? MaxKeys { get; set; }
+    }
+}

Api/Bucket/List/ListBucketsResult.cs

@@ -0,0 +1,75 @@
+/*
+ * Copyright (C) Alibaba Cloud Computing
+ * All rights reserved.
+ * 
+ * 版权所有 （C）阿里云计算有限公司
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Xml.Serialization;
+using Cuiliang.AliyunOssSdk.Api.Common;
+
+namespace Cuiliang.AliyunOssSdk.Api.Bucket.List
+{
+    /// <summary>
+    /// 列举Bucket的请求结果。
+    /// </summary>
+    [XmlRoot("ListAllMyBucketsResult")]
+    public class ListBucketsResult
+    {
+        /// <summary>
+        /// 获取一个值，限定返回的<see cref="Bucket" />的Key必须以该值作为前缀。
+        /// </summary>
+        public string Prefix { get;  set; }
+
+        /// <summary>
+        /// 获取一个值，用户设定结果从该值之后按字母排序的第一个开始返回。
+        /// </summary>
+        public string Marker { get;  set; }
+
+        /// <summary>
+        /// 获取一个值，用于限定此次返回bucket的最大数。
+        /// 如果不设定，默认为100。
+        /// </summary>
+        public int? MaxKeys { get;  set; }
+
+        /// <summary>
+        /// 获取一个值，指明是否所有的结果都已经返回。
+        /// </summary>
+        public bool? IsTruncated { get;  set; }
+
+        /// <summary>
+        /// 获取一个值，指明下一个Marker。
+        /// </summary>
+        public string NextMaker { get;  set; }
+
+        [XmlElement("Owner")]
+        public Owner Owner { get; set; }
+
+        /// <summary>
+        /// 获取一个值，指明Bucket请求列表。
+        /// </summary>
+        [XmlArrayItem("Bucket")]
+        public List<Common.Bucket> Buckets { get;  set; }
+    }
+
+    [XmlRoot("Bucket")]
+    public class BucketModel
+    {
+        [XmlElement("Location")]
+        public string Location { get; set; }
+
+        [XmlElement("Name")]
+        public string Name { get; set; }
+
+        [XmlElement("CreationDate")]
+        public DateTime CreationDate { get; set; }
+
+        public string ExtranetEndpoint { get; set; }
+
+        public string IntranetEndpoint { get; set; }
+    }
+
+    
+}

Api/Common/Bucket.cs

@@ -0,0 +1,78 @@
+/*
+///Copyright (C) Alibaba Cloud Computing
+///All rights reserved.
+///
+///版权所有 （C）阿里云计算有限公司
+ */
+
+using System;
+using System.Globalization;
+
+namespace Cuiliang.AliyunOssSdk.Api.Common
+{
+    ///<summary>
+    ///Bucket是OSS上的命名空间，可以理解为存储空间
+    ///</summary>
+    /// <remarks>
+    ///<para>
+    ///Bucket名在整个 OSS 中具有全局唯一性，且不能修改；存储在OSS上的每个Object必须都包含在某个Bucket中。
+    ///一个应用，例如图片分享网站，可以对应一个或多个 Bucket。一个用户最多可创建 10 个Bucket，
+    ///但每个Bucket 中存放的Object的数量和大小总和没有限制，用户不需要考虑数据的可扩展性。
+    ///</para>
+    ///<para>
+    ///Bucket 命名规范
+    ///<list type="">
+    /// <item>只能包括小写字母，数字和短横线（-）</item>
+    /// <item>必须以小写字母或者数字开头</item>
+    /// <item>长度必须在 3-63 字节之间</item>
+    ///</list>
+    ///</para>
+    /// </remarks>
+    public class Bucket
+    {
+        /// <summary>
+        /// 获取/设置Bucket的Location。
+        /// </summary>
+        public string Location { get;  set; }
+
+        /// <summary>
+        /// 获取/设置Bucket的名称。
+        /// </summary>
+        public string Name { get;  set; }
+
+        /// <summary>
+        /// 获取/设置Bucket的<see cref="Owner" />
+        /// </summary>
+        public Owner Owner { get;  set; }
+
+        /// <summary>
+        /// 获取/设置Bucket的创建时间。
+        /// </summary>
+        public DateTime CreationDate { get;  set; }
+
+        public Bucket()
+        {
+        }
+
+        /// <summary>
+        /// 使用指定的Bucket名称构造一个新的<see cref="Bucket" />实例。
+        /// </summary>
+        /// <param name="name">Bucket的名称。</param>
+        public Bucket(string name)
+        {
+            Name = name;
+        }
+
+        /// <summary>
+        /// 返回该对象的字符串表示。
+        /// </summary>
+        /// <returns>对象的字符串表示形式</returns>
+        public override string ToString()
+        {
+            return string.Format(CultureInfo.InvariantCulture,
+                                 "OSS Bucket [Name={0}], [Location={1}] [Owner={2}], [CreationTime={3}]",
+                                 Name, Location, Owner, CreationDate);
+        }
+
+    }
+}