Builder implemented for MinioClient, Arguments (#446)

Also added Versioning API support

Docs/zh_CN/API.md

@@ -29,7 +29,10 @@ var s3Client = new MinioClient("s3.amazonaws.com",
 | [`removeBucket`](#removeBucket)  | [`statObject`](#statObject) |   | [`getBucketNotification`](#getBucketNotification)  |
 | [`listObjects`](#listObjects)  | [`removeObject`](#removeObject) |   |  [`removeAllBucketNotification`](#removeAllBucketNotification) |
 | [`listIncompleteUploads`](#listIncompleteUploads)  | [`removeObjects`](#removeObjects) |   |   |
-| | [`removeIncompleteUpload`](#removeIncompleteUpload) |   |   |
+| [`listenBucketNotifications`](#listenBucketNotifications) | [`removeIncompleteUpload`](#removeIncompleteUpload) |   |   |
+| [`setVersioning`](#setVersioning)  | [`selectObjectContent`](#selectObjectContent) |   |   |
+| [`getVersioning`](#getVersioning)  |  |   |   |
+
 
 
 ## 1. 构造函数

Minio.Examples/Cases/BucketExists.cs

@@ -28,7 +28,8 @@ public async static Task Run(MinioClient minio,
             try
             {
                 Console.WriteLine("Running example for API: BucketExistsAsync");
-                bool found = await minio.BucketExistsAsync(bucketName);
+                BucketExistsArgs args = new BucketExistsArgs(bucketName);
+                bool found = await minio.BucketExistsAsync(args);
                 Console.WriteLine((found ? "Found" : "Couldn't find ") + "bucket " + bucketName);
                 Console.WriteLine();
             }
@@ -38,4 +39,4 @@ public async static Task Run(MinioClient minio,
             }
         }
     }
-}
+}

Minio.Examples/Cases/EnableSuspendVersioning.cs

@@ -0,0 +1,48 @@
+/*
+ * MinIO .NET Library for Amazon S3 Compatible Cloud Storage, (C) 2020 MinIO, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+using System;
+using System.Threading.Tasks;
+using Minio.DataModel;
+
+namespace Minio.Examples.Cases
+{
+    class EnableSuspendVersioning
+    {
+        // Enable Versioning on a bucket
+        public async static Task Run(MinioClient minio,
+                                     string bucketName = "my-bucket-name")
+        {
+            try
+            {
+                Console.WriteLine("Running example for API: EnableSuspendVersioning, ");
+                // First Enable the Versioning.
+                var setArgs = new SetVersioningArgs(bucketName)
+                                        .WithVersioningEnabled();
+                await minio.SetVersioningAsync(setArgs);
+                Console.WriteLine("Versioning Enable operation called for bucket " + bucketName);
+                // Next Suspend the Versioning.
+                setArgs = setArgs.WithVersioningSuspended();
+                await minio.SetVersioningAsync(setArgs);
+                Console.WriteLine("Versioning Suspend operation called for bucket " + bucketName);
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine($"[Bucket]  Exception: {e}");
+            }
+        }
+    }
+}

Minio.Examples/Cases/GetVersioning.cs

@@ -0,0 +1,51 @@
+/*
+ * MinIO .NET Library for Amazon S3 Compatible Cloud Storage, (C) 2020 MinIO, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+using System;
+using System.Threading.Tasks;
+using Minio.DataModel;
+
+namespace Minio.Examples.Cases
+{
+    class GetVersioning
+    {
+        // Check if Versioning is Enabled on a bucket
+        public async static Task Run(MinioClient minio,
+                                     string bucketName = "my-bucket-name")
+        {
+            var args = new GetVersioningArgs(bucketName);
+
+            try
+            {
+                Console.WriteLine("Running example for API: GetVersioning, ");
+                VersioningConfiguration config = await minio.GetVersioningAsync(args);
+                if ( config == null )
+                {
+                    Console.WriteLine("Versioning Configuration not available for bucket " + bucketName);
+                    Console.WriteLine();
+                    return;
+                }
+                Console.WriteLine("Versioning Configuration Status " + config.Status + " for bucket " + bucketName);
+                Console.WriteLine();
+
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine($"[Bucket]  Exception: {e}");
+            }
+        }
+    }
+}

Minio.Examples/Cases/MakeBucket.cs

@@ -23,12 +23,15 @@ public class MakeBucket
     {
         // Make a bucket
         public async static Task Run(MinioClient minio,
-                                     string bucketName = "my-bucket-name")
+                                     string bucketName = "my-bucket-name", string loc = "us-east-1")
         {
             try
             {
                 Console.WriteLine("Running example for API: MakeBucketAsync");
-                await minio.MakeBucketAsync(bucketName);
+                await minio.MakeBucketAsync(
+                    new MakeBucketArgs(bucketName)
+                        .WithLocation(loc)
+                );
                 Console.WriteLine($"Created bucket {bucketName}");
                 Console.WriteLine();
             } 
@@ -38,4 +41,4 @@ public async static Task Run(MinioClient minio,
             }
         }
     }
-}
+}

Minio.Examples/Cases/RemoveBucket.cs

@@ -27,7 +27,9 @@ public async static Task Run(MinioClient minio,
         {
             try
             {
-                await minio.RemoveBucketAsync(bucketName);
+                await minio.RemoveBucketAsync(
+                                new RemoveBucketArgs(bucketName)
+                );
                 Console.WriteLine($"Removed the bucket {bucketName} successfully");
             }
             catch (Exception e)
@@ -36,4 +38,4 @@ public async static Task Run(MinioClient minio,
             }
         }
     }
-}
+}

Minio.Examples/Minio.Examples.csproj

@@ -1,15 +1,15 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <TargetFramework>netcoreapp2.1</TargetFramework>
     <OutputType>Exe</OutputType>
     <IsPackable>False</IsPackable>
   </PropertyGroup>
-
   <ItemGroup>
-    <PackageReference Include="Polly" Version="7.2.0" />
+    <PackageReference Include="Polly" Version="7.2.0"/>
+    <PackageReference Include="System.Net.Http" Version="4.3.0"/>
+    <PackageReference Include="System.Net.Primitives" Version="4.3.0"/>
   </ItemGroup>
-
   <ItemGroup>
-    <ProjectReference Include="..\Minio\Minio.csproj" />
+    <ProjectReference Include="..\Minio\Minio.csproj"/>
   </ItemGroup>
 </Project>

Minio.Examples/Program.cs

@@ -60,15 +60,26 @@ public static void Main(string[] args)
             string accessKey = null;
             string secretKey = null;
             bool enableHTTPS = false;
+            int port = 80;
 
             if (Environment.GetEnvironmentVariable("SERVER_ENDPOINT") != null)
             {
                 endPoint = Environment.GetEnvironmentVariable("SERVER_ENDPOINT");
+                int posColon = endPoint.LastIndexOf(':');
+                if ( posColon != -1 )
+                {
+                    port = Int32.Parse(endPoint.Substring(posColon+1, (endPoint.Length - posColon - 1)));
+                    endPoint = endPoint.Substring(0, posColon);
+                }
                 accessKey = Environment.GetEnvironmentVariable("ACCESS_KEY");
                 secretKey = Environment.GetEnvironmentVariable("SECRET_KEY");
                 if (Environment.GetEnvironmentVariable("ENABLE_HTTPS") != null)
                 {
                     enableHTTPS = Environment.GetEnvironmentVariable("ENABLE_HTTPS").Equals("1");
+                    if ( enableHTTPS && port == 80 )
+                    {
+                        port = 443;
+                    }
                 }
             }
             else
@@ -77,22 +88,29 @@ public static void Main(string[] args)
                 accessKey = "Q3AM3UQ867SPQQA43P2F";
                 secretKey = "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG";
                 enableHTTPS = true;
+                port = 443;
             }
 
             ServicePointManager.ServerCertificateValidationCallback +=
                         (sender, certificate, chain, sslPolicyErrors) => true;
 
             // WithSSL() enables SSL support in MinIO client
             MinioClient minioClient = null;
-            if (enableHTTPS)
+            if ( enableHTTPS )
             {
-                minioClient = new MinioClient(endPoint, accessKey, secretKey).WithSSL();
+                minioClient = new MinioClient()
+                                        .WithEndpoint(endPoint, port)
+                                        .WithCredentials(accessKey, secretKey)
+                                        .WithSSL()
+                                        .Build();
             }
             else
             {
-                minioClient = new MinioClient(endPoint, accessKey, secretKey);
+                minioClient = new MinioClient()
+                                        .WithEndpoint(endPoint, port)
+                                        .WithCredentials(accessKey, secretKey)
+                                        .Build();
             }
-
             try
             {
                 // Assign parameters before starting the test 
@@ -123,6 +141,10 @@ public static void Main(string[] args)
 
                 Cases.MakeBucket.Run(minioClient, destBucketName).Wait();
 
+                //Versioning tests
+                Cases.GetVersioning.Run(minioClient, bucketName).Wait();
+                Cases.EnableSuspendVersioning.Run(minioClient, bucketName).Wait();
+                Cases.GetVersioning.Run(minioClient, bucketName).Wait();
                 // List all the buckets on the server
                 Cases.ListBuckets.Run(minioClient).Wait();
 
@@ -227,6 +249,7 @@ public static void Main(string[] args)
                 Cases.CustomRequestLogger.Run(minioClient).Wait();
 
                 // Remove the buckets
+                Console.WriteLine();
                 Cases.RemoveBucket.Run(minioClient, bucketName).Wait();
                 Cases.RemoveBucket.Run(minioClient, destBucketName).Wait();
 
@@ -242,4 +265,4 @@ public static void Main(string[] args)
             }
         }
     }
-}
+}