feat: insert option to choose http method

Author: diegofesanto

Functions/Client.cs

@@ -1,16 +1,16 @@
-using Newtonsoft.Json;
-using Supabase.Core;
-using Supabase.Core.Extensions;
-using Supabase.Functions.Interfaces;
-using Supabase.Functions.Responses;
-using System;
+using System;
 using System.Collections.Generic;
 using System.Net.Http;
 using System.Runtime.CompilerServices;
 using System.Text;
 using System.Threading.Tasks;
 using System.Web;
+using Newtonsoft.Json;
+using Supabase.Core;
+using Supabase.Core.Extensions;
 using Supabase.Functions.Exceptions;
+using Supabase.Functions.Interfaces;
+using Supabase.Functions.Responses;
 
 [assembly: InternalsVisibleTo("FunctionsTests")]
 
@@ -24,7 +24,7 @@ public partial class Client : IFunctionsClient
 
         /// <summary>
         /// Function that can be set to return dynamic headers.
-        /// 
+        ///
         /// Headers specified in the method parameters will ALWAYS take precedence over headers returned by this function.
         /// </summary>
         public Func<Dictionary<string, string>>? GetHeaders { get; set; }
@@ -45,8 +45,11 @@ public Client(string baseUrl)
         /// <param name="token">Anon Key.</param>
         /// <param name="options">Options</param>
         /// <returns></returns>
-        public async Task<HttpContent> RawInvoke(string functionName, string? token = null,
-            InvokeFunctionOptions? options = null)
+        public async Task<HttpContent> RawInvoke(
+            string functionName,
+            string? token = null,
+            InvokeFunctionOptions? options = null
+        )
         {
             var url = $"{_baseUrl}/{functionName}";
 
@@ -60,8 +63,11 @@ public async Task<HttpContent> RawInvoke(string functionName, string? token = nu
         /// <param name="token">Anon Key.</param>
         /// <param name="options">Options</param>
         /// <returns></returns>
-        public async Task<string> Invoke(string functionName, string? token = null,
-            InvokeFunctionOptions? options = null)
+        public async Task<string> Invoke(
+            string functionName,
+            string? token = null,
+            InvokeFunctionOptions? options = null
+        )
         {
             var url = $"{_baseUrl}/{functionName}";
             var response = await HandleRequest(url, token, options);
@@ -77,8 +83,12 @@ public async Task<string> Invoke(string functionName, string? token = null,
         /// <param name="token">Anon Key.</param>
         /// <param name="options">Options</param>
         /// <returns></returns>
-        public async Task<T?> Invoke<T>(string functionName, string? token = null,
-            InvokeFunctionOptions? options = null) where T : class
+        public async Task<T?> Invoke<T>(
+            string functionName,
+            string? token = null,
+            InvokeFunctionOptions? options = null
+        )
+            where T : class
         {
             var url = $"{_baseUrl}/{functionName}";
             var response = await HandleRequest(url, token, options);
@@ -96,8 +106,11 @@ public async Task<string> Invoke(string functionName, string? token = null,
         /// <param name="options"></param>
         /// <returns></returns>
         /// <exception cref="FunctionsException"></exception>
-        private async Task<HttpResponseMessage> HandleRequest(string url, string? token = null,
-            InvokeFunctionOptions? options = null)
+        private async Task<HttpResponseMessage> HandleRequest(
+            string url,
+            string? token = null,
+            InvokeFunctionOptions? options = null
+        )
         {
             options ??= new InvokeFunctionOptions();
 
@@ -118,21 +131,24 @@ private async Task<HttpResponseMessage> HandleRequest(string url, string? token
 
             builder.Query = query.ToString();
 
-            using var requestMessage = new HttpRequestMessage(HttpMethod.Post, builder.Uri);
-            requestMessage.Content = new StringContent(JsonConvert.SerializeObject(options.Body), Encoding.UTF8,
-                "application/json");
+            using var requestMessage = new HttpRequestMessage(options.HttpMethod, builder.Uri);
+            requestMessage.Content = new StringContent(
+                JsonConvert.SerializeObject(options.Body),
+                Encoding.UTF8,
+                "application/json"
+            );
 
             foreach (var kvp in options.Headers)
             {
                 requestMessage.Headers.TryAddWithoutValidation(kvp.Key, kvp.Value);
             }
-            
+
             if (_httpClient.Timeout != options.HttpTimeout)
             {
                 _httpClient = new HttpClient();
                 _httpClient.Timeout = options.HttpTimeout;
             }
-            
+
             var response = await _httpClient.SendAsync(requestMessage);
 
             if (response.IsSuccessStatusCode && !response.Headers.Contains("x-relay-error"))
@@ -143,10 +159,11 @@ private async Task<HttpResponseMessage> HandleRequest(string url, string? token
             {
                 Content = content,
                 Response = response,
-                StatusCode = (int)response.StatusCode
+                StatusCode = (int)response.StatusCode,
             };
             exception.AddReason();
             throw exception;
         }
     }
-}
+}
+

Functions/InvokeFunctionOptions.cs

@@ -1,23 +1,24 @@
 using System;
-using Newtonsoft.Json;
 using System.Collections.Generic;
+using System.Net.Http;
+using Newtonsoft.Json;
 
 namespace Supabase.Functions
 {
     public partial class Client
     {
         /// <summary>
         /// Options that can be supplied to a function invocation.
-        /// 
+        ///
         /// Note: If Headers.Authorization is set, it can be later overriden if a token is supplied in the method call.
         /// </summary>
         public class InvokeFunctionOptions
         {
             /// <summary>
             /// Headers to be included on the request.
             /// </summary>
-            public Dictionary<string, string> Headers { get; set; } = new Dictionary<string, string>();
-
+            public Dictionary<string, string> Headers { get; set; } =
+                new Dictionary<string, string>();
 
             /// <summary>
             /// Body of the Request
@@ -30,6 +31,11 @@ public class InvokeFunctionOptions
             /// https://learn.microsoft.com/en-us/dotnet/api/system.net.http.httpclient.timeout?view=net-8.0#remarks
             /// </summary>
             public TimeSpan HttpTimeout { get; set; } = TimeSpan.FromSeconds(100);
+
+            /// <summary>
+            /// Http method of the Request
+            /// </summary>
+            public HttpMethod HttpMethod { get; set; } = HttpMethod.Post;
         }
     }
-}
+}

FunctionsTests/ClientTests.cs

@@ -28,37 +28,38 @@ public async Task Invokes()
         {
             const string function = "hello";
 
-            var result = await _client.Invoke(function, _token, new InvokeFunctionOptions
-            {
-                Body = new Dictionary<string, object>
+            var result = await _client.Invoke(
+                function,
+                _token,
+                new InvokeFunctionOptions
                 {
-                    {"name", "supabase" }
+                    Body = new Dictionary<string, object> { { "name", "supabase" } },
                 }
-            });
+            );
 
             Assert.IsTrue(result.Contains("supabase"));
 
-
-            var result2 = await _client.Invoke<Dictionary<string, string>>(function, _token, new InvokeFunctionOptions
-            {
-                Body = new Dictionary<string, object>
+            var result2 = await _client.Invoke<Dictionary<string, string>>(
+                function,
+                _token,
+                new InvokeFunctionOptions
                 {
-                    { "name", "functions" }
+                    Body = new Dictionary<string, object> { { "name", "functions" } },
                 }
-            });
+            );
 
             Assert.IsInstanceOfType(result2, typeof(Dictionary<string, string>));
             Assert.IsTrue(result2.ContainsKey("message"));
             Assert.IsTrue(result2["message"].Contains("functions"));
 
-
-            var result3 = await _client.RawInvoke(function, _token, new InvokeFunctionOptions
-            {
-                Body = new Dictionary<string, object>
+            var result3 = await _client.RawInvoke(
+                function,
+                _token,
+                new InvokeFunctionOptions
                 {
-                    { "name", "functions" }
+                    Body = new Dictionary<string, object> { { "name", "functions" } },
                 }
-            });
+            );
 
             var bytes = await result3.ReadAsByteArrayAsync();
 
@@ -71,7 +72,10 @@ private static string GenerateToken(string secret)
 
             var tokenDescriptor = new SecurityTokenDescriptor
             {
-                SigningCredentials = new SigningCredentials(signingKey, SecurityAlgorithms.HmacSha256Signature)
+                SigningCredentials = new SigningCredentials(
+                    signingKey,
+                    SecurityAlgorithms.HmacSha256Signature
+                ),
             };
 
             var tokenHandler = new JwtSecurityTokenHandler();