feature: Added Implementation for Interceptors

gen/SourceGenerator/SourceGenerator.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
         <TargetFramework>netstandard2.0</TargetFramework>

src/RestSharp/Options/RestClientOptions.cs

@@ -21,6 +21,7 @@
 using System.Text;
 using RestSharp.Authenticators;
 using RestSharp.Extensions;
+using RestSharp.Interceptors;
 
 namespace RestSharp;
 
@@ -59,6 +60,8 @@ public RestClientOptions(string baseUrl) : this(new Uri(Ensure.NotEmptyString(ba
     /// </summary>
     public IAuthenticator? Authenticator { get; set; }
 
+    public List<IInterceptor> Interceptors { get; set; } = new();
+
     /// <summary>
     /// Passed to <see cref="HttpMessageHandler"/> <code>Credentials</code> property
     /// </summary>

src/RestSharp/RestClient.Async.cs

@@ -86,6 +86,8 @@ async Task<HttpResponse> ExecuteRequestAsync(RestRequest request, CancellationTo
             throw new ObjectDisposedException(nameof(RestClient));
         }
 
+        await OnBeforeSerialization(request);
+
         using var requestContent = new RequestContent(this, request);
 
         var authenticator = request.Authenticator ?? Options.Authenticator;
@@ -112,8 +114,8 @@ async Task<HttpResponse> ExecuteRequestAsync(RestRequest request, CancellationTo
                 .AddAcceptHeader(AcceptedContentTypes)
                 .AddCookieHeaders(cookieContainer, url);
             message.AddHeaders(headers);
-
             if (request.OnBeforeRequest != null) await request.OnBeforeRequest(message).ConfigureAwait(false);
+            await OnBeforeRequest(message);
 
             var responseMessage = await HttpClient.SendAsync(message, request.CompletionOption, ct).ConfigureAwait(false);
 
@@ -130,6 +132,7 @@ async Task<HttpResponse> ExecuteRequestAsync(RestRequest request, CancellationTo
             }
 
             if (request.OnAfterRequest != null) await request.OnAfterRequest(responseMessage).ConfigureAwait(false);
+            await OnAfterRequest(responseMessage);
 
             return new HttpResponse(responseMessage, url, cookieContainer, null, timeoutCts.Token);
         }
@@ -138,6 +141,34 @@ async Task<HttpResponse> ExecuteRequestAsync(RestRequest request, CancellationTo
         }
     }
 
+    /// <summary>
+    /// Will be called before the Request becomes Serialized
+    /// </summary>
+    /// <param name="request">RestRequest before it will be serialized</param>
+    async Task OnBeforeSerialization(RestRequest request) {
+        foreach (var interceptor in Options.Interceptors) {
+            await interceptor.InterceptBeforeSerialization(request); //.ThrowExceptionIfAvailable();
+        }
+    }
+    /// <summary>
+    /// Will be calld before the Request will be sent
+    /// </summary>
+    /// <param name="requestMessage">HttpRequestMessage ready to be sent</param>
+    async Task OnBeforeRequest(HttpRequestMessage requestMessage) {
+        foreach (var interceptor in Options.Interceptors) {
+            await interceptor.InterceptBeforeRequest(requestMessage);
+        }
+    }
+    /// <summary>
+    /// Will be called after the Response has been received from Server
+    /// </summary>
+    /// <param name="responseMessage">HttpResponseMessage as received from server</param>
+    async Task OnAfterRequest(HttpResponseMessage responseMessage) {
+        foreach (var interceptor in Options.Interceptors) {
+            await interceptor.InterceptAfterRequest(responseMessage);
+        }
+    }
+
     record HttpResponse(
         HttpResponseMessage? ResponseMessage,
         Uri                  Url,

src/RestSharp/RestClient.Extensions.cs

@@ -14,7 +14,6 @@
 
 using System.Runtime.CompilerServices;
 using RestSharp.Extensions;
-using RestSharp.Serializers;
 
 namespace RestSharp;
 

src/RestSharp/RestSharp.csproj

@@ -40,4 +40,7 @@
     <ItemGroup>
         <ProjectReference Include="..\..\gen\SourceGenerator\SourceGenerator.csproj" OutputItemType="Analyzer" ReferenceOutputAssembly="false" />
     </ItemGroup>
+    <ItemGroup>
+      <PackageReference Include="System.Threading.Tasks" Version="4.3.0" />
+    </ItemGroup>
 </Project>

src/RestSharp/Serializers/RestSerializers.cs

@@ -37,6 +37,7 @@ internal RestResponse<T> Deserialize<T>(RestRequest request, RestResponse raw, R
 
         try {
             request.OnBeforeDeserialization?.Invoke(raw);
+            OnBeforeDeserialization(raw, options);
             response.Data = DeserializeContent<T>(raw);
         }
         catch (Exception ex) {
@@ -51,6 +52,15 @@ internal RestResponse<T> Deserialize<T>(RestRequest request, RestResponse raw, R
 
         return response;
     }
+    /// <summary>
+    /// Will be called before the Data will be serialized
+    /// </summary>
+    /// <param name="raw">RestResponse with Data still in Content</param>
+    async Task OnBeforeDeserialization(RestResponse raw, ReadOnlyRestClientOptions options) {
+        foreach (var interceptor in options.Interceptors) {
+            await interceptor.InterceptBeforeDeserialize(raw); //.ThrowExceptionIfAvailable();
+        }
+    }
 
     /// <summary>
     /// Deserialize the response content into the specified type