Add proxy settings for WebSocket connections for .NET 451 and 461

Source/MQTTnet/Client/MqttClientOptionsBuilder.cs

@@ -76,6 +76,29 @@ namespace MQTTnet.Client
             return this;
         }
 
+#if NET452 || NET461
+
+        public MqttClientOptionsBuilder WithProxy(string address, string username = null, string password = null, string domain = null, bool bypassOnLocal = false, string[] bypassList = null)
+        {
+            if (_webSocketOptions == null)
+            {
+                throw new InvalidOperationException("A WebSocket channel must be set if MqttClientWebSocketProxy is configured.");
+            }
+
+            _webSocketOptions.MqttClientWebSocketProxy = new MqttClientWebSocketProxyOptions
+            {
+                Address = address,
+                Username = username,
+                Password = password,
+                Domain = domain,
+                BypassOnLocal = bypassOnLocal,
+                BypassList = bypassList
+            };
+
+            return this;
+        }
+#endif
+
         public MqttClientOptionsBuilder WithWebSocketServer(string uri)
         {
             _webSocketOptions = new MqttClientWebSocketOptions

Source/MQTTnet/Client/MqttClientWebSocketOptions.cs

@@ -13,6 +13,10 @@ namespace MQTTnet.Client
 
         public CookieContainer CookieContainer { get; set; }
 
+#if NET452 || NET461
+        public MqttClientWebSocketProxyOptions MqttClientWebSocketProxy { get; set; } = new MqttClientWebSocketProxyOptions();
+#endif
+
         public MqttClientTlsOptions TlsOptions { get; set; } = new MqttClientTlsOptions();
 
         public override string ToString()

Source/MQTTnet/Client/MqttClientWebSocketProxyOptions.cs

@@ -0,0 +1,21 @@
+#if NET452 || NET461
+
+namespace MQTTnet.Client
+{
+    public class MqttClientWebSocketProxyOptions
+    {
+        public string Address { get; set; }
+
+        public string Username { get; set; }
+
+        public string Password { get; set; }
+
+        public string Domain { get; set; }
+
+        public bool BypassOnLocal { get; set; } = true;
+
+        public string[] BypassList { get; set; }
+    }
+}
+
+#endif

Source/MQTTnet/Implementations/MqttWebSocketChannel.cs

@@ -6,6 +6,10 @@ using System.Threading.Tasks;
 using MQTTnet.Channel;
 using MQTTnet.Client;
 
+#if NET452 || NET461
+    using System.Net;
+#endif
+
 namespace MQTTnet.Implementations
 {
     public class MqttWebSocketChannel : IMqttChannel
@@ -14,7 +18,7 @@ namespace MQTTnet.Implementations
         private readonly MqttClientWebSocketOptions _options;
 
         private WebSocket _webSocket;
-        
+
         public MqttWebSocketChannel(MqttClientWebSocketOptions options)
         {
             _options = options ?? throw new ArgumentNullException(nameof(options));
@@ -45,6 +49,26 @@ namespace MQTTnet.Implementations
 
             var clientWebSocket = new ClientWebSocket();
 
+#if NET452 || NET461
+            // use proxy if we have an address
+            if (string.IsNullOrEmpty(_options.MqttClientWebSocketProxy.Address) == false)
+            {
+                var proxyUri = new Uri(_options.MqttClientWebSocketProxy.Address);
+
+                // use proxy credentials if we have them
+                if (string.IsNullOrEmpty(_options.MqttClientWebSocketProxy.Username) == false && string.IsNullOrEmpty(_options.MqttClientWebSocketProxy.Password) == false)
+                {
+                    var credentials = new NetworkCredential(_options.MqttClientWebSocketProxy.Username, _options.MqttClientWebSocketProxy.Password, _options.MqttClientWebSocketProxy.Domain);
+                    clientWebSocket.Options.Proxy = new WebProxy(proxyUri, _options.MqttClientWebSocketProxy.BypassOnLocal, _options.MqttClientWebSocketProxy.BypassList, credentials);
+                }
+                else
+                {
+                    // use proxy without credentials
+                    clientWebSocket.Options.Proxy = new WebProxy(proxyUri, _options.MqttClientWebSocketProxy.BypassOnLocal, _options.MqttClientWebSocketProxy.BypassList);
+                }
+            }
+#endif
+
             if (_options.RequestHeaders != null)
             {
                 foreach (var requestHeader in _options.RequestHeaders)