Merge pull request #48 from autodesk-platform-services/DAS-215

Upload function now accept memory stream and consumed docs team changes

oss/source/Http/BucketsApi.gen.cs

@@ -47,7 +47,7 @@ public interface IBucketsApi
         ///
         ///Buckets are virtual container within the Object Storage Service (OSS), which you can use to store and manage objects (files) in the cloud. The application creating the bucket is the owner of the bucket.
         ///
-        ///**Note:** Do not use this operation to create buckets for BIM360 Document Management. Use [POST projects/{project_id}/storage](/en/docs/data/v2/reference/http/projects-project_id-storage-POST>_ instead. For details, see `Upload Files to BIM 360 Document Management </en/docs/bim360/v1/tutorials/document-management/upload-document).
+        ///**Note:** Do not use this operation to create buckets for BIM360 Document Management. Use [POST projects/{project_id}/storage](/en/docs/data/v2/reference/http/projects-project_id-storage-POST>) instead. For details, see [Upload Files to BIM 360 Document Management](/en/docs/bim360/v1/tutorials/document-management/upload-document).
         /// </remarks>
         /// <exception cref="HttpRequestException">Thrown when fails to make API call</exception>
         /// <param name="policyKey">
@@ -62,7 +62,7 @@ public interface IBucketsApi
         /// </param>
         /// <returns>Task of ApiResponse&lt;Bucket&gt;</returns>
 
-        System.Threading.Tasks.Task<ApiResponse<Bucket>> CreateBucketAsync(CreateBucketsPayload policyKey, Region xAdsRegion , string accessToken = null, bool throwOnError = true);
+        System.Threading.Tasks.Task<ApiResponse<Bucket>> CreateBucketAsync(CreateBucketsPayload policyKey, Region xAdsRegion, string accessToken = null, bool throwOnError = true);
         /// <summary>
         /// Delete Bucket
         /// </summary>

oss/source/Model/Access.gen.cs

@@ -33,9 +33,9 @@
 namespace Autodesk.Oss.Model
 {
     /// <summary>
-    /// Access for signed resource Acceptable values: read, write, readwrite Default value: read
+    /// Access for signed resource Possible values: read, write, readwrite Default value: read
     /// </summary>
-    ///<value>Access for signed resource Acceptable values: read, write, readwrite Default value: read</value>
+    ///<value>Access for signed resource Possible values: read, write, readwrite Default value: read</value>
 
     [JsonConverter(typeof(StringEnumConverter))]
 

oss/source/Model/Batchsigneds3downloadResponse.gen.cs

@@ -46,8 +46,11 @@ public Batchsigneds3downloadResponse()
         }
 
         /// <summary>
-        ///Gets or Sets Results
+        ///A map of the returned results; each key in the map corresponds to an object key in the batch, and the value includes the results for that object.
         /// </summary>
+        /// <value>
+        ///A map of the returned results; each key in the map corresponds to an object key in the batch, and the value includes the results for that object.
+        /// </value>
         [DataMember(Name="results", EmitDefaultValue=false)]
         public Dictionary<string, DownloadResults> Results { get; set; }
 

oss/source/Model/Batchsigneds3uploadResponse.gen.cs

@@ -46,8 +46,11 @@ public Batchsigneds3uploadResponse()
         }
 
         /// <summary>
-        ///Gets or Sets Results
+        ///A map of the returned results; each key in the map corresponds to an object key in the batch, and the value includes the results for that object.
         /// </summary>
+        /// <value>
+        ///A map of the returned results; each key in the map corresponds to an object key in the batch, and the value includes the results for that object.
+        /// </value>
         [DataMember(Name="results", EmitDefaultValue=false)]
         public Dictionary<string, Batchsigneds3uploadResponseResultsValue> Results { get; set; }
 

oss/source/Model/DownloadResults.gen.cs

@@ -33,7 +33,7 @@
 namespace Autodesk.Oss.Model
 {
     /// <summary>
-    /// An object that represents the response to a Batch Generate Signed S3 Download URLs operation.   **Note**: objectKeyN is a placeholder for the first object key for which the client requested a download signed URL. The attributes within contain the success data / error information for the request for that object. &#x60;results&#x60; will contain one such attribute for each requested object in the batch. 
+    /// An object that represents the response to a Batch Generate Signed S3 Download URLs operation.   **Note**: &#x60;&#x60;objectKeyN&#x60;&#x60; is a placeholder for the first object key for which the client requested a download signed URL. The attributes within contain the success data / error information for the request for that object. &#x60;results&#x60; will contain one such attribute for each requested object in the batch. 
     /// </summary>
     [DataContract]
     public partial class DownloadResults 

oss/source/Model/Region.gen.cs

@@ -33,15 +33,15 @@
 namespace Autodesk.Oss.Model
 {
     /// <summary>
-    /// Specifies where the bucket containing the object stored. Possible values are:
+    /// Specifies where the bucket containing the object is stored. Possible values are:
 ///
 ///        - `US` - (Default) Data center for the US region.
 ///        - `EMEA` - Data center for the European Union, Middle East, and Africa.
 ///        - `APAC` -  (Beta) Data center for Australia.
 ///
 ///        **Note:** Beta features are subject to change. Please do not use in production environments.
     /// </summary>
-    ///<value>Specifies where the bucket containing the object stored. Possible values are:
+    ///<value>Specifies where the bucket containing the object is stored. Possible values are:
 ///
 ///        - `US` - (Default) Data center for the US region.
 ///        - `EMEA` - Data center for the European Union, Middle East, and Africa.

oss/source/Model/Result.gen.cs

@@ -46,8 +46,11 @@ public Result()
         }
 
         /// <summary>
-        ///Gets or Sets _Result
+        ///A human friendly description of the state of processing.
         /// </summary>
+        /// <value>
+        ///A human friendly description of the state of processing.
+        /// </value>
         [DataMember(Name="result", EmitDefaultValue=false)]
         public string _Result { get; set; }
 

oss/source/custom-code/IOSSFileTransfer.cs

@@ -23,6 +23,7 @@
 using System.Net.Http;
 using System.Threading.Tasks;
 using System.Threading;
+using System.IO;
 namespace Autodesk.Oss
 {
     public interface IOSSFileTransfer
@@ -31,7 +32,7 @@ public interface IOSSFileTransfer
         Task<HttpResponseMessage> Upload(
             string bucketKey,
             string objectKey,
-            string sourceToUpload,
+            Stream sourceToUpload,
             string accessToken,
             CancellationToken cancellationToken,
             string projectScope = "",

oss/source/custom-code/OSSFileTransfer.cs

@@ -92,27 +92,25 @@ public OSSFileTransfer(IFileTransferConfigurations configuration,
             _authentication = authentication;
         }
 
-        private async Task<bool> IsFileSizeAllowed(string filePath)
+        private async Task<bool> IsFileSizeAllowed(Stream filePath)
         {
             return await Task.Run(() =>
             {
-                using (FileStream fileStream = File.OpenRead(filePath))
-                {
-                    long fileSize = fileStream.Length;
+
+                    long fileSize = filePath.Length;
                     double numberOfChunks = CalculateNumberOfChunks((ulong)fileSize);
                     if (numberOfChunks > this._maxChunkCountAllowed)
                     {
                         return false;
                     }
-                }
                 return true;
             });
         }
 
         public async Task<HttpResponseMessage> Upload(
             string bucketKey,
             string objectKey,
-            string sourceToUpload,
+            Stream sourceToUpload,
             string accessToken,
             CancellationToken cancellationToken,
             string projectScope = "",
@@ -128,10 +126,7 @@ public async Task<HttpResponseMessage> Upload(
             ValidateProjectScopeName(requestId, projectScope);
 
             progress?.Report(1);
-
-            using (FileStream fileStream = File.OpenRead(sourceToUpload))
-            {
-                ulong numberOfChunks = (ulong)CalculateNumberOfChunks((ulong)fileStream.Length);
+                ulong numberOfChunks = (ulong)CalculateNumberOfChunks((ulong)sourceToUpload.Length);
                 ulong chunksUploaded = 0;
 
                 long start = 0;
@@ -140,15 +135,15 @@ public async Task<HttpResponseMessage> Upload(
 
                 _logger.LogInformation("{requestId} Total chunk to be uploaded: {numberOfChunks}", requestId, numberOfChunks);
 
-                using (BinaryReader reader = new BinaryReader(fileStream))
+                using (BinaryReader reader = new BinaryReader(sourceToUpload))
                 {
                     while (chunksUploaded < numberOfChunks)
                     {
                         ThrowIfCancellationRequested(cancellationToken, requestId);
 
                         int attempts = 0;
 
-                        long end = Math.Min((long)((chunksUploaded + 1) * Constants.ChunkSize), fileStream.Length);
+                        long end = Math.Min((long)((chunksUploaded + 1) * Constants.ChunkSize), sourceToUpload.Length);
                         byte[] fileBytes = readFileBytes(reader, start, end);
 
                         var retryUrlExpiryCount = 0;
@@ -237,7 +232,6 @@ public async Task<HttpResponseMessage> Upload(
 
                 progress?.Report(100);
                 return completeResponse;
-            }
         }
 
         private byte[] readFileBytes(BinaryReader reader, long start, long end)
@@ -460,7 +454,7 @@ private async Task<ApiResponse<Signeds3downloadResponse>> GetS3SignedDownloadUrl
             throw new OssApiException($"{requestId} Failed to get download urls after maximum retry.");
         }
 
-        private async Task ValidateFileSize(string requestId, string sourceToUpload)
+        private async Task ValidateFileSize(string requestId, Stream sourceToUpload)
         {
             var sizeAllowed = await IsFileSizeAllowed(sourceToUpload);
             if (!sizeAllowed)