NuGet v1.3.3, S3 folder creation support

Author: jchristn

BlobHelper/BlobHelper.csproj

@@ -3,15 +3,15 @@
   <PropertyGroup>
     <TargetFrameworks>netstandard2.0;net462</TargetFrameworks>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <Version>1.3.2</Version>
+    <Version>1.3.3</Version>
     <Authors>Joel Christner</Authors>
     <Description>BLOB storage wrapper for Microsoft Azure, Amazon S3, Kvpbase, and local filesystem written in C#.</Description>
     <Copyright>(c)2019 Joel Christner</Copyright>
     <PackageProjectUrl>https://github.com/jchristn/BlobHelper</PackageProjectUrl>
     <RepositoryUrl>https://github.com/jchristn/BlobHelper</RepositoryUrl>
     <RepositoryType>Github</RepositoryType>
     <PackageLicenseUrl>https://github.com/jchristn/BlobHelper/blob/master/LICENSE.TXT</PackageLicenseUrl>
-    <PackageReleaseNotes>Modify test app and constructors to support S3 and S3-compatible storage.</PackageReleaseNotes>
+    <PackageReleaseNotes>Support for creating S3 folders using keys containing '/'</PackageReleaseNotes>
     <PackageIconUrl>https://raw.githubusercontent.com/jchristn/BlobHelper/master/assets/icon.ico</PackageIconUrl>
     <PackageTags>blob azure storage s3 object rest</PackageTags>
   </PropertyGroup>

BlobHelper/Blobs.cs

@@ -825,17 +825,26 @@ private async Task<bool> S3Write(string key, string contentType, byte[] data)
         {
             try
             {
-                Stream s = new MemoryStream(data);
-
-                PutObjectRequest request = new PutObjectRequest
+                PutObjectRequest request = new PutObjectRequest();
+
+                if (data == null || data.Length < 0)
+                { 
+                    request.BucketName = _AwsSettings.Bucket;
+                    request.Key = key;
+                    request.ContentType = contentType;
+                    request.UseChunkEncoding = false;
+                    request.InputStream = new MemoryStream(new byte[0]);
+                }
+                else
                 {
-                    BucketName = _AwsSettings.Bucket,
-                    Key = key,
-                    InputStream = s,
-                    ContentType = contentType,
-                    UseChunkEncoding = false
-                };
-
+                    Stream s = new MemoryStream(data);
+                    request.BucketName = _AwsSettings.Bucket;
+                    request.Key = key;
+                    request.ContentType = contentType;
+                    request.UseChunkEncoding = false;
+                    request.InputStream = s;
+                }
+                 
                 PutObjectResponse response = await _S3Client.PutObjectAsync(request);
                 int statusCode = (int)response.HttpStatusCode;
 
@@ -852,15 +861,25 @@ private bool S3Write(string key, string contentType, long contentLength, Stream
         {
             try
             {
-                PutObjectRequest request = new PutObjectRequest
-                {
-                    BucketName = _AwsSettings.Bucket,
-                    Key = key,
-                    InputStream = stream,
-                    ContentType = contentType,
-                    UseChunkEncoding = false
-                };
+                PutObjectRequest request = new PutObjectRequest();
 
+                if (stream == null || contentLength < 1)
+                {
+                    request.BucketName = _AwsSettings.Bucket;
+                    request.Key = key;
+                    request.ContentType = contentType;
+                    request.UseChunkEncoding = false;
+                    request.InputStream = new MemoryStream(new byte[0]);
+                }
+                else
+                { 
+                    request.BucketName = _AwsSettings.Bucket;
+                    request.Key = key;
+                    request.ContentType = contentType;
+                    request.UseChunkEncoding = false;
+                    request.InputStream = stream;
+                }
+                 
                 PutObjectResponse response = _S3Client.PutObjectAsync(request).Result;
                 int statusCode = (int)response.HttpStatusCode;
 

README.md

@@ -17,6 +17,7 @@ This project was built to provide a simple interface over external storage to he
 
 ## New in v1.3.x
 
+- Better support for creating S3 folders using objects with keys ending in '/' and no data
 - New constructor to better support S3-compatible storage, update to test app
 - Fix to allow non-SSL connections to S3
 - Added enumeration capabilities to list contents of a bucket or container

Test/Program.cs

@@ -225,10 +225,21 @@ static void Menu()
 
         static void WriteBlob()
         {
-            bool success = _Blobs.Write(
-                InputString("Key:", null, false),
-                InputString("Content type:", "text/plain", false),
-                Encoding.UTF8.GetBytes(InputString("Data:", null, false))).Result;
+            string key = InputString("Key:", null, false);
+            string contentType = InputString("Content type:", "text/plain", true);
+            string data = InputString("Data:", null, true);
+
+            bool success = false;
+
+            if (String.IsNullOrEmpty(data))
+            {
+                success = _Blobs.Write(key, contentType, null).Result;
+            }
+            else
+            {
+                success = _Blobs.Write(key, contentType, Encoding.UTF8.GetBytes(data)).Result;
+            }
+
             Console.WriteLine("Success: " + success);
         }