Merge branch 'develop' of https://github.com/justcoding121/titanium-web-proxy into develop

Author: honfika

src/Titanium.Web.Proxy/Network/TcpConnection/TcpConnectionFactory.cs

@@ -538,6 +538,8 @@ internal Task<TcpServerConnection> GetServerConnection(ProxyServer proxyServer,
                         connectRequest.Headers.AddHeader(HttpHeader.GetProxyAuthorizationHeader(externalProxy.UserName, externalProxy.Password));
                     }
 
+                    await proxyServer.onBeforeUpStreamConnectRequest(connectRequest);
+
                     await stream.WriteRequestAsync(connectRequest, cancellationToken);
 
                     var httpStatus = await stream.ReadResponseStatus(cancellationToken);

src/Titanium.Web.Proxy/ProxyServer.cs

@@ -11,6 +11,7 @@
 using Titanium.Web.Proxy.Extensions;
 using Titanium.Web.Proxy.Helpers;
 using Titanium.Web.Proxy.Helpers.WinHttp;
+using Titanium.Web.Proxy.Http;
 using Titanium.Web.Proxy.Models;
 using Titanium.Web.Proxy.Network;
 using Titanium.Web.Proxy.Network.Tcp;
@@ -387,6 +388,11 @@ public ExceptionHandler ExceptionFunc
         /// </summary>
         public event AsyncEventHandler<Socket>? OnServerConnectionCreate;
 
+        /// <summary>
+        ///     Intercept connect request sent to upstream proxy.
+        /// </summary>
+        public event AsyncEventHandler<ConnectRequest>? BeforeUpStreamConnectRequest;
+
         /// <summary>
         /// Customize the minimum ThreadPool size (increase it on a server)
         /// </summary>

src/Titanium.Web.Proxy/RequestHandler.cs

@@ -406,6 +406,19 @@ private async Task onBeforeRequest(SessionEventArgs args)
             }
         }
 
+        /// <summary>
+        ///     Invoke before request handler if it is set.
+        /// </summary>
+        /// <param name="request">The COONECT request.</param>
+        /// <returns></returns>
+        internal async Task onBeforeUpStreamConnectRequest(ConnectRequest request)
+        {
+            if (BeforeUpStreamConnectRequest != null)
+            {
+                await BeforeUpStreamConnectRequest.InvokeAsync(this, request, ExceptionFunc);
+            }
+        }
+
 #if DEBUG
         internal bool ShouldCallBeforeRequestBodyWrite()
         {