Merge pull request #488 from notion-dotnet/478-add-support-for-send-file-upload-endpoint

Add support for send file upload API

Author: KoditkarVedant

Src/Notion.Client/Api/ApiEndpoints.cs

@@ -143,6 +143,7 @@ public static class AuthenticationUrls
         public static class FileUploadsApiUrls
         {
             public static string Create() => "/v1/file_uploads";
+            public static string Send(string fileUploadId) => $"/v1/file_uploads/{fileUploadId}/send";
         }
     }
 }

Src/Notion.Client/Api/FileUploads/IFileUploadsClient.cs

@@ -15,5 +15,19 @@ Task<CreateFileUploadResponse> CreateAsync(
             CreateFileUploadRequest fileUploadObjectRequest,
             CancellationToken cancellationToken = default
         );
+
+        /// <summary>
+        /// Send a file upload
+        /// 
+        /// Requires a `file_upload_id`, obtained from the `id` of the Create File Upload API response.
+        /// 
+        /// </summary>
+        /// <param name="sendFileUploadRequest"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<SendFileUploadResponse> SendAsync(
+            SendFileUploadRequest sendFileUploadRequest,
+            CancellationToken cancellationToken = default
+        );
     }
 }

Src/Notion.Client/Api/FileUploads/Send/FileUploadsClient.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Notion.Client
+{
+    public sealed partial class FileUploadsClient
+    {
+        public async Task<SendFileUploadResponse> SendAsync(
+            SendFileUploadRequest sendFileUploadRequest,
+            CancellationToken cancellationToken = default)
+        {
+            if (sendFileUploadRequest == null)
+            {
+                throw new ArgumentNullException(nameof(sendFileUploadRequest));
+            }
+
+            if (string.IsNullOrWhiteSpace(sendFileUploadRequest.FileUploadId))
+            {
+                throw new ArgumentNullException(nameof(sendFileUploadRequest.FileUploadId));
+            }
+
+            if (sendFileUploadRequest.PartNumber != null)
+            {
+                if (!int.TryParse(sendFileUploadRequest.PartNumber, out int partNumberValue) || partNumberValue < 1 || partNumberValue > 1000)
+                {
+                    throw new ArgumentOutOfRangeException(nameof(sendFileUploadRequest.PartNumber), "PartNumber must be between 1 and 1000.");
+                }
+            }
+
+            var path = ApiEndpoints.FileUploadsApiUrls.Send(sendFileUploadRequest.FileUploadId);
+
+            return await _restClient.PostAsync<SendFileUploadResponse>(
+                path,
+                formData: sendFileUploadRequest,
+                cancellationToken: cancellationToken
+            );
+        }
+    }
+}

Src/Notion.Client/Api/FileUploads/Send/Request/FileData.cs

@@ -0,0 +1,22 @@
+using System.IO;
+
+namespace Notion.Client
+{
+    public class FileData
+    {
+        /// <summary>
+        /// The name of the file being uploaded.
+        /// </summary>
+        public string FileName { get; set; }
+
+        /// <summary>
+        /// The content of the file being uploaded.
+        /// </summary>
+        public Stream Data { get; set; }
+
+        /// <summary>
+        /// The MIME type of the file being uploaded.
+        /// </summary>
+        public string ContentType { get; set; }
+    }
+}

Src/Notion.Client/Api/FileUploads/Send/Request/ISendFileUploadFormDataParameters.cs

@@ -0,0 +1,18 @@
+using Newtonsoft.Json;
+
+namespace Notion.Client
+{
+    public interface ISendFileUploadFormDataParameters
+    {
+        /// <summary>
+        /// The raw binary file contents to upload.
+        /// </summary>
+        FileData File { get; }
+
+        /// <summary>
+        /// When using a mode=multi_part File Upload to send files greater than 20 MB in parts, this is the current part number. 
+        /// Must be an integer between 1 and 1000 provided as a string form field.
+        /// </summary>
+        string PartNumber { get; }
+    }
+}

Src/Notion.Client/Api/FileUploads/Send/Request/ISendFileUploadPathParameters.cs

@@ -0,0 +1,10 @@
+namespace Notion.Client
+{
+    public interface ISendFileUploadPathParameters
+    {
+        /// <summary>
+        /// The `file_upload_id` obtained from the `id` of the Create File Upload API response.
+        /// </summary>
+        string FileUploadId { get; }
+    }
+}

Src/Notion.Client/Api/FileUploads/Send/Request/SendFileUploadRequest.cs

@@ -0,0 +1,21 @@
+namespace Notion.Client
+{
+    public class SendFileUploadRequest : ISendFileUploadFormDataParameters, ISendFileUploadPathParameters
+    {
+        public FileData File { get; private set; }
+        public string PartNumber { get; private set; }
+        public string FileUploadId { get; private set; }
+
+        private SendFileUploadRequest() { }
+
+        public static SendFileUploadRequest Create(string fileUploadId, FileData file, string partNumber = null)
+        {
+            return new SendFileUploadRequest
+            {
+                FileUploadId = fileUploadId,
+                File = file,
+                PartNumber = partNumber
+            };
+        }
+    }
+}

Src/Notion.Client/Api/FileUploads/Send/Response/SendFileUploadResponse.cs

@@ -0,0 +1,6 @@
+namespace Notion.Client
+{
+    public class SendFileUploadResponse : FileObjectResponse
+    {
+    }
+}

Src/Notion.Client/RestClient/IRestClient.cs

@@ -23,6 +23,15 @@ Task<T> PostAsync<T>(
             IBasicAuthenticationParameters basicAuthenticationParameters = null,
             CancellationToken cancellationToken = default);
 
+        Task<T> PostAsync<T>(
+            string uri,
+            ISendFileUploadFormDataParameters formData,
+            IEnumerable<KeyValuePair<string, string>> queryParams = null,
+            IDictionary<string, string> headers = null,
+            JsonSerializerSettings serializerSettings = null,
+            IBasicAuthenticationParameters basicAuthenticationParameters = null,
+            CancellationToken cancellationToken = default);
+
         Task<T> PatchAsync<T>(
             string uri,
             object body,

Src/Notion.Client/RestClient/RestClient.cs

@@ -70,6 +70,46 @@ void AttachContent(HttpRequestMessage httpRequest)
             return await response.ParseStreamAsync<T>(serializerSettings);
         }
 
+        public async Task<T> PostAsync<T>(
+            string uri,
+            ISendFileUploadFormDataParameters formData,
+            IEnumerable<KeyValuePair<string, string>> queryParams = null,
+            IDictionary<string, string> headers = null,
+            JsonSerializerSettings serializerSettings = null,
+            IBasicAuthenticationParameters basicAuthenticationParameters = null,
+            CancellationToken cancellationToken = default)
+        {
+            void AttachContent(HttpRequestMessage httpRequest)
+            {
+                var fileContent = new StreamContent(formData.File.Data);
+                fileContent.Headers.ContentType = new MediaTypeHeaderValue(formData.File.ContentType);
+
+                var form = new MultipartFormDataContent
+                {
+                    { fileContent, "file", formData.File.FileName }
+                };
+
+                if (!string.IsNullOrEmpty(formData.PartNumber))
+                {
+                    form.Add(new StringContent(formData.PartNumber), "part_number");
+                }
+
+                httpRequest.Content = form;
+            }
+
+            var response = await SendAsync(
+                uri,
+                HttpMethod.Post,
+                queryParams,
+                headers,
+                AttachContent,
+                basicAuthenticationParameters,
+                cancellationToken
+            );
+
+            return await response.ParseStreamAsync<T>(serializerSettings);
+        }
+
         public async Task<T> PatchAsync<T>(
             string uri,
             object body,