5 // Marek Safar <marek.safar@gmail.com>
7 // Copyright (C) 2011 Xamarin Inc (http://www.xamarin.com)
9 // Permission is hereby granted, free of charge, to any person obtaining
10 // a copy of this software and associated documentation files (the
11 // "Software"), to deal in the Software without restriction, including
12 // without limitation the rights to use, copy, modify, merge, publish,
13 // distribute, sublicense, and/or sell copies of the Software, and to
14 // permit persons to whom the Software is furnished to do so, subject to
15 // the following conditions:
17 // The above copyright notice and this permission notice shall be
18 // included in all copies or substantial portions of the Software.
20 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
21 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
22 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
23 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
24 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
25 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
30 using System.Collections;
31 using System.Collections.Generic;
32 using NUnit.Framework;
33 using System.Net.Http;
34 using System.Net.Http.Headers;
35 using System.Threading;
36 using System.Threading.Tasks;
41 using MonoTests.Helpers;
43 namespace MonoTests.System.Net.Http
46 public class HttpClientTest
48 class HttpMessageHandlerMock : HttpMessageHandler
50 public Func<HttpRequestMessage, Task<HttpResponseMessage>> OnSend;
51 public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendFull;
53 public HttpMessageHandlerMock ()
57 protected override Task<HttpResponseMessage> SendAsync (HttpRequestMessage request, CancellationToken cancellationToken)
60 return OnSend (request);
62 if (OnSendFull != null)
63 return OnSendFull (request, cancellationToken);
70 class HttpClientHandlerMock : HttpClientHandler
72 public Func<HttpRequestMessage, Task<HttpResponseMessage>> OnSend;
73 public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendFull;
75 protected override Task<HttpResponseMessage> SendAsync (HttpRequestMessage request, CancellationToken cancellationToken)
78 return OnSend (request);
80 if (OnSendFull != null)
81 return OnSendFull (request, cancellationToken);
88 class CustomStream : Stream
90 public override void Flush ()
92 throw new NotImplementedException ();
97 public override int Read (byte[] buffer, int offset, int count)
106 public override long Seek (long offset, SeekOrigin origin)
108 throw new NotImplementedException ();
111 public override void SetLength (long value)
113 throw new NotImplementedException ();
116 public override void Write (byte[] buffer, int offset, int count)
118 throw new NotImplementedException ();
121 public override bool CanRead {
127 public override bool CanSeek {
133 public override bool CanWrite {
135 throw new NotImplementedException ();
139 public override long Length {
141 throw new NotImplementedException ();
145 public override long Position {
147 throw new NotImplementedException ();
150 throw new NotImplementedException ();
155 class ThrowOnlyProxy : IWebProxy
157 public ICredentials Credentials {
159 throw new NotImplementedException ();
163 throw new NotImplementedException ();
167 public Uri GetProxy (Uri destination)
169 throw new NotImplementedException ();
172 public bool IsBypassed (Uri host)
174 throw new NotImplementedException ();
178 const int WaitTimeout = 5000;
181 public void Ctor_Default ()
183 var client = new HttpClient ();
184 Assert.IsNull (client.BaseAddress, "#1");
185 Assert.IsNotNull (client.DefaultRequestHeaders, "#2"); // TODO: full check
186 Assert.AreEqual (int.MaxValue, client.MaxResponseContentBufferSize, "#3");
187 Assert.AreEqual (TimeSpan.FromSeconds (100), client.Timeout, "#4");
191 public void CancelPendingRequests ()
193 var mh = new HttpMessageHandlerMock ();
195 var client = new HttpClient (mh);
196 var request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
197 var mre = new ManualResetEvent (false);
199 mh.OnSendFull = (l, c) => {
201 Assert.IsTrue (c.WaitHandle.WaitOne (1000), "#20");
202 Assert.IsTrue (c.IsCancellationRequested, "#21");
204 return Task.FromResult (new HttpResponseMessage ());
207 var t = Task.Factory.StartNew (() => {
208 client.SendAsync (request).Wait (WaitTimeout);
211 Assert.IsTrue (mre.WaitOne (500), "#1");
213 client.CancelPendingRequests ();
214 Assert.IsTrue (t.Wait (500), "#2");
216 request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
217 mh.OnSendFull = (l, c) => {
218 Assert.IsFalse (c.IsCancellationRequested, "#30");
219 return Task.FromResult (new HttpResponseMessage ());
222 client.SendAsync (request).Wait (WaitTimeout);
226 public void CancelPendingRequests_BeforeSend ()
228 var ct = new CancellationTokenSource ();
230 var rr = CancellationTokenSource.CreateLinkedTokenSource (new CancellationToken (), ct.Token);
233 var mh = new HttpMessageHandlerMock ();
235 var client = new HttpClient (mh);
236 var request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
237 client.CancelPendingRequests ();
239 mh.OnSendFull = (l, c) => {
240 Assert.IsFalse (c.IsCancellationRequested, "#30");
241 return Task.FromResult (new HttpResponseMessage ());
244 client.SendAsync (request).Wait (WaitTimeout);
246 request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
247 client.SendAsync (request).Wait (WaitTimeout);
252 #if FEATURE_NO_BSD_SOCKETS
253 // Using HttpClientHandler, which indirectly requires BSD sockets.
254 [ExpectedException (typeof (PlatformNotSupportedException))]
256 public void CancelRequestViaProxy ()
258 var handler = new HttpClientHandler {
259 Proxy = new WebProxy ("192.168.10.25:8888/"), // proxy that doesn't exist
261 AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate
264 var httpClient = new HttpClient (handler) {
265 BaseAddress = new Uri ("https://google.com"),
266 Timeout = TimeSpan.FromMilliseconds (1)
270 var restRequest = new HttpRequestMessage {
271 Method = HttpMethod.Post,
272 RequestUri = new Uri("foo", UriKind.Relative),
273 Content = new StringContent("", null, "application/json")
276 httpClient.PostAsync (restRequest.RequestUri, restRequest.Content).Wait (WaitTimeout);
278 } catch (AggregateException e) {
279 Assert.IsTrue (e.InnerException is TaskCanceledException, "#2");
284 public void Properties ()
286 var client = new HttpClient ();
287 client.BaseAddress = null;
288 client.MaxResponseContentBufferSize = int.MaxValue;
289 client.Timeout = Timeout.InfiniteTimeSpan;
291 Assert.IsNull (client.BaseAddress, "#1");
292 Assert.AreEqual (int.MaxValue, client.MaxResponseContentBufferSize, "#2");
293 Assert.AreEqual (Timeout.InfiniteTimeSpan, client.Timeout, "#3");
297 public void Properties_Invalid ()
299 var client = new HttpClient ();
301 client.MaxResponseContentBufferSize = 0;
303 } catch (ArgumentOutOfRangeException) {
307 client.Timeout = TimeSpan.MinValue;
309 } catch (ArgumentOutOfRangeException) {
314 #if FEATURE_NO_BSD_SOCKETS
315 [ExpectedException (typeof (PlatformNotSupportedException))]
317 public void Proxy_Disabled ()
319 var pp = WebRequest.DefaultWebProxy;
322 WebRequest.DefaultWebProxy = new ThrowOnlyProxy ();
324 var request = new HttpClientHandler {
328 var client = new HttpClient (request);
329 Assert.IsTrue (client.GetAsync ("http://google.com").Wait (5000), "needs internet access");
331 WebRequest.DefaultWebProxy = pp;
338 var mh = new HttpMessageHandlerMock ();
340 var client = new HttpClient (mh);
341 client.BaseAddress = new Uri ("http://xamarin.com");
342 var request = new HttpRequestMessage ();
343 var response = new HttpResponseMessage ();
346 Assert.AreEqual (l, request, "#2");
347 Assert.AreEqual (client.BaseAddress, l.RequestUri, "#2");
348 return Task.FromResult (response);
351 Assert.AreEqual (response, client.SendAsync (request).Result, "#1");
355 public void Send_BaseAddress ()
357 var mh = new HttpMessageHandlerMock ();
359 var client = new HttpClient (mh);
360 client.BaseAddress = new Uri ("http://localhost/");
361 var response = new HttpResponseMessage ();
364 Assert.AreEqual ("http://localhost/relative", l.RequestUri.ToString (), "#2");
365 return Task.FromResult (response);
368 Assert.AreEqual (response, client.GetAsync ("relative").Result, "#1");
369 Assert.AreEqual (response, client.GetAsync ("/relative").Result, "#2");
373 public void Send_DefaultRequestHeaders ()
375 var mh = new HttpMessageHandlerMock ();
377 var client = new HttpClient (mh);
378 client.DefaultRequestHeaders.Referrer = new Uri ("http://google.com");
380 var request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
381 var response = new HttpResponseMessage ();
384 Assert.AreEqual (client.DefaultRequestHeaders.Referrer, l.Headers.Referrer, "#2");
385 Assert.IsNotNull (l.Headers.Referrer, "#3");
386 return Task.FromResult (response);
389 Assert.AreEqual (response, client.SendAsync (request).Result, "#1");
393 #if FEATURE_NO_BSD_SOCKETS
394 [ExpectedException (typeof (PlatformNotSupportedException))]
396 public void Send_Complete_Default ()
399 var port = NetworkHelpers.FindFreePort ();
400 var listener = CreateListener (l => {
402 var request = l.Request;
404 Assert.IsNull (request.AcceptTypes, "#1");
405 Assert.AreEqual (0, request.ContentLength64, "#2");
406 Assert.IsNull (request.ContentType, "#3");
407 Assert.AreEqual (0, request.Cookies.Count, "#4");
408 Assert.IsFalse (request.HasEntityBody, "#5");
409 Assert.AreEqual ($"localhost:{port}", request.Headers["Host"], "#6b");
410 Assert.AreEqual ("GET", request.HttpMethod, "#7");
411 Assert.IsFalse (request.IsAuthenticated, "#8");
412 Assert.IsTrue (request.IsLocal, "#9");
413 Assert.IsFalse (request.IsSecureConnection, "#10");
414 Assert.IsFalse (request.IsWebSocketRequest, "#11");
415 Assert.IsTrue (request.KeepAlive, "#12");
416 Assert.AreEqual (HttpVersion.Version11, request.ProtocolVersion, "#13");
417 Assert.IsNull (request.ServiceName, "#14");
418 Assert.IsNull (request.UrlReferrer, "#15");
419 Assert.IsNull (request.UserAgent, "#16");
420 Assert.IsNull (request.UserLanguages, "#17");
428 var client = new HttpClient ();
429 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
430 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
432 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
433 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
434 Assert.AreEqual (false, failed, "#102");
441 #if FEATURE_NO_BSD_SOCKETS
442 [ExpectedException (typeof (PlatformNotSupportedException))]
444 public void Send_Complete_Version_1_0 ()
448 var port = NetworkHelpers.FindFreePort ();
449 var listener = CreateListener (l => {
451 var request = l.Request;
453 Assert.IsNull (request.AcceptTypes, "#1");
454 Assert.AreEqual (0, request.ContentLength64, "#2");
455 Assert.IsNull (request.ContentType, "#3");
456 Assert.AreEqual (0, request.Cookies.Count, "#4");
457 Assert.IsFalse (request.HasEntityBody, "#5");
458 Assert.AreEqual (1, request.Headers.Count, "#6");
459 Assert.AreEqual ($"localhost:{port}", request.Headers["Host"], "#6a");
460 Assert.AreEqual ("GET", request.HttpMethod, "#7");
461 Assert.IsFalse (request.IsAuthenticated, "#8");
462 Assert.IsTrue (request.IsLocal, "#9");
463 Assert.IsFalse (request.IsSecureConnection, "#10");
464 Assert.IsFalse (request.IsWebSocketRequest, "#11");
465 Assert.IsFalse (request.KeepAlive, "#12");
466 Assert.AreEqual (HttpVersion.Version10, request.ProtocolVersion, "#13");
467 Assert.IsNull (request.ServiceName, "#14");
468 Assert.IsNull (request.UrlReferrer, "#15");
469 Assert.IsNull (request.UserAgent, "#16");
470 Assert.IsNull (request.UserLanguages, "#17");
478 var client = new HttpClient ();
479 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
480 request.Version = HttpVersion.Version10;
481 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
483 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
484 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
485 Assert.AreEqual (false, failed, "#102");
492 #if FEATURE_NO_BSD_SOCKETS
493 [ExpectedException (typeof (PlatformNotSupportedException))]
495 public void Send_Complete_ClientHandlerSettings ()
499 var port = NetworkHelpers.FindFreePort ();
500 var listener = CreateListener (l => {
501 var request = l.Request;
504 Assert.IsNull (request.AcceptTypes, "#1");
505 Assert.AreEqual (0, request.ContentLength64, "#2");
506 Assert.IsNull (request.ContentType, "#3");
507 Assert.AreEqual (1, request.Cookies.Count, "#4");
508 Assert.AreEqual (new Cookie ("mycookie", "vv"), request.Cookies[0], "#4a");
509 Assert.IsFalse (request.HasEntityBody, "#5");
510 Assert.AreEqual (4, request.Headers.Count, "#6");
511 Assert.AreEqual ($"localhost:{port}", request.Headers["Host"], "#6a");
512 Assert.AreEqual ("gzip", request.Headers["Accept-Encoding"], "#6b");
513 Assert.AreEqual ("mycookie=vv", request.Headers["Cookie"], "#6c");
514 Assert.AreEqual ("GET", request.HttpMethod, "#7");
515 Assert.IsFalse (request.IsAuthenticated, "#8");
516 Assert.IsTrue (request.IsLocal, "#9");
517 Assert.IsFalse (request.IsSecureConnection, "#10");
518 Assert.IsFalse (request.IsWebSocketRequest, "#11");
519 Assert.IsTrue (request.KeepAlive, "#12");
520 Assert.AreEqual (HttpVersion.Version10, request.ProtocolVersion, "#13");
521 Assert.IsNull (request.ServiceName, "#14");
522 Assert.IsNull (request.UrlReferrer, "#15");
523 Assert.IsNull (request.UserAgent, "#16");
524 Assert.IsNull (request.UserLanguages, "#17");
532 var chandler = new HttpClientHandler ();
533 chandler.AllowAutoRedirect = true;
534 chandler.AutomaticDecompression = DecompressionMethods.GZip;
535 chandler.MaxAutomaticRedirections = 33;
536 chandler.MaxRequestContentBufferSize = 5555;
537 chandler.PreAuthenticate = true;
538 chandler.CookieContainer.Add (new Uri ($"http://localhost:{port}/"), new Cookie ( "mycookie", "vv"));
539 chandler.UseCookies = true;
540 chandler.UseDefaultCredentials = true;
541 chandler.Proxy = new WebProxy ("ee");
542 chandler.UseProxy = true;
544 var client = new HttpClient (chandler);
545 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
546 request.Version = HttpVersion.Version10;
547 request.Headers.Add ("Keep-Alive", "false");
548 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
550 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
551 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
552 Assert.AreEqual (false, failed, "#102");
560 #if FEATURE_NO_BSD_SOCKETS
561 [ExpectedException (typeof (PlatformNotSupportedException))]
563 public void Send_Complete_CustomHeaders ()
567 var port = NetworkHelpers.FindFreePort ();
568 var listener = CreateListener (l => {
569 var request = l.Request;
571 Assert.AreEqual ("vv", request.Headers["aa"], "#1");
573 var response = l.Response;
574 response.Headers.Add ("rsp", "rrr");
575 response.Headers.Add ("upgrade", "vvvvaa");
576 response.Headers.Add ("Date", "aa");
577 response.Headers.Add ("cache-control", "audio");
579 response.StatusDescription = "test description";
580 response.ProtocolVersion = HttpVersion.Version10;
581 response.SendChunked = true;
582 response.RedirectLocation = "w3.org";
591 var client = new HttpClient ();
592 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
593 Assert.IsTrue (request.Headers.TryAddWithoutValidation ("aa", "vv"), "#0");
594 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
596 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
597 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
599 IEnumerable<string> values;
600 Assert.IsTrue (response.Headers.TryGetValues ("rsp", out values), "#102");
601 Assert.AreEqual ("rrr", values.First (), "#102a");
603 Assert.IsTrue (response.Headers.TryGetValues ("Transfer-Encoding", out values), "#103");
604 Assert.AreEqual ("chunked", values.First (), "#103a");
605 Assert.AreEqual (true, response.Headers.TransferEncodingChunked, "#103b");
607 Assert.IsTrue (response.Headers.TryGetValues ("Date", out values), "#104");
608 Assert.AreEqual (1, values.Count (), "#104b");
609 // .NET overwrites Date, Mono does not
610 // Assert.IsNotNull (response.Headers.Date, "#104c");
612 Assert.AreEqual (new ProductHeaderValue ("vvvvaa"), response.Headers.Upgrade.First (), "#105");
614 Assert.AreEqual ("audio", response.Headers.CacheControl.Extensions.First ().Name, "#106");
616 Assert.AreEqual ("w3.org", response.Headers.Location.OriginalString, "#107");
618 Assert.AreEqual ("test description", response.ReasonPhrase, "#110");
619 Assert.AreEqual (HttpVersion.Version11, response.Version, "#111");
621 Assert.AreEqual (false, failed, "#112");
628 #if FEATURE_NO_BSD_SOCKETS
629 [ExpectedException (typeof (PlatformNotSupportedException))]
631 public void Send_Complete_CustomHeaders_SpecialSeparators ()
635 var port = NetworkHelpers.FindFreePort ();
636 var listener = CreateListener (l => {
637 var request = l.Request;
640 Assert.AreEqual ("MLK Android Phone 1.1.9", request.UserAgent, "#1");
648 var client = new HttpClient ();
650 client.DefaultRequestHeaders.Add("User-Agent", "MLK Android Phone 1.1.9");
652 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
654 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
656 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
657 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
658 Assert.AreEqual (false, failed, "#102");
666 #if FEATURE_NO_BSD_SOCKETS
667 [ExpectedException (typeof (PlatformNotSupportedException))]
669 public void Send_Complete_CustomHeaders_Host ()
672 var port = NetworkHelpers.FindFreePort ();
673 var listener = CreateListener (l => {
674 var request = l.Request;
677 Assert.AreEqual ("customhost", request.Headers["Host"], "#1");
685 var client = new HttpClient ();
687 client.DefaultRequestHeaders.Add("Host", "customhost");
689 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
691 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
693 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
694 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
695 Assert.AreEqual (false, failed, "#102");
703 #if FEATURE_NO_BSD_SOCKETS
704 [ExpectedException (typeof (PlatformNotSupportedException))]
706 public void Send_Transfer_Encoding_Chunked ()
710 var port = NetworkHelpers.FindFreePort ();
711 var listener = CreateListener (l => {
712 var request = l.Request;
715 Assert.AreEqual (2, request.Headers.Count, "#1");
716 Assert.AreEqual ("keep-alive", request.Headers ["Connection"], "#2");
718 } catch (Exception ex){
719 Console.WriteLine (ex);
720 Console.WriteLine (String.Join ("#", l.Request.Headers.AllKeys));
726 var client = new HttpClient ();
727 client.DefaultRequestHeaders.TransferEncodingChunked = true;
729 client.GetAsync ($"http://localhost:{port}/").Wait ();
731 Assert.AreEqual (false, failed, "#102");
739 #if FEATURE_NO_BSD_SOCKETS
740 [ExpectedException (typeof (PlatformNotSupportedException))]
742 public void Send_Transfer_Encoding_Custom ()
746 var port = NetworkHelpers.FindFreePort ();
747 var listener = CreateListener (l => {
752 var client = new HttpClient ();
753 client.DefaultRequestHeaders.TransferEncoding.Add (new TransferCodingHeaderValue ("chunked2"));
755 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
758 client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Wait ();
760 } catch (AggregateException e) {
761 Assert.AreEqual (typeof (ProtocolViolationException), e.InnerException.GetType (), "#2");
763 Assert.IsNull (failed, "#102");
771 #if FEATURE_NO_BSD_SOCKETS
772 [ExpectedException (typeof (PlatformNotSupportedException))]
774 public void Send_Complete_Content ()
776 var port = NetworkHelpers.FindFreePort ();
777 var listener = CreateListener (l => {
778 var request = l.Request;
779 l.Response.OutputStream.WriteByte (55);
780 l.Response.OutputStream.WriteByte (75);
784 var client = new HttpClient ();
785 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
786 Assert.IsTrue (request.Headers.TryAddWithoutValidation ("aa", "vv"), "#0");
787 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
789 Assert.AreEqual ("7K", response.Content.ReadAsStringAsync ().Result, "#100");
790 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
792 IEnumerable<string> values;
793 Assert.IsTrue (response.Headers.TryGetValues ("Transfer-Encoding", out values), "#102");
794 Assert.AreEqual ("chunked", values.First (), "#102a");
795 Assert.AreEqual (true, response.Headers.TransferEncodingChunked, "#102b");
802 #if FEATURE_NO_BSD_SOCKETS
803 [ExpectedException (typeof (PlatformNotSupportedException))]
805 public void Send_Complete_Content_MaxResponseContentBufferSize ()
807 var port = NetworkHelpers.FindFreePort ();
808 var listener = CreateListener (l => {
809 var request = l.Request;
810 var b = new byte[4000];
811 l.Response.OutputStream.Write (b, 0, b.Length);
815 var client = new HttpClient ();
816 client.MaxResponseContentBufferSize = 1000;
817 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
818 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
820 Assert.AreEqual (4000, response.Content.ReadAsStringAsync ().Result.Length, "#100");
821 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
828 #if FEATURE_NO_BSD_SOCKETS
829 [ExpectedException (typeof (PlatformNotSupportedException))]
831 public void Send_Complete_Content_MaxResponseContentBufferSize_Error ()
833 var port = NetworkHelpers.FindFreePort ();
834 var listener = CreateListener (l => {
835 var request = l.Request;
836 var b = new byte[4000];
837 l.Response.OutputStream.Write (b, 0, b.Length);
841 var client = new HttpClient ();
842 client.MaxResponseContentBufferSize = 1000;
843 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
846 client.SendAsync (request, HttpCompletionOption.ResponseContentRead).Wait (WaitTimeout);
848 } catch (AggregateException e) {
849 Assert.IsTrue (e.InnerException is HttpRequestException, "#3");
858 #if FEATURE_NO_BSD_SOCKETS
859 [ExpectedException (typeof (PlatformNotSupportedException))]
861 public void Send_Complete_NoContent_Post ()
863 Send_Complete_NoContent (HttpMethod.Post);
867 #if FEATURE_NO_BSD_SOCKETS
868 [ExpectedException (typeof (PlatformNotSupportedException))]
870 public void Send_Complete_NoContent_Put ()
872 Send_Complete_NoContent (HttpMethod.Put);
876 #if FEATURE_NO_BSD_SOCKETS
877 [ExpectedException (typeof (PlatformNotSupportedException))]
879 public void Send_Complete_NoContent_Delete ()
881 Send_Complete_NoContent (HttpMethod.Delete);
884 void Send_Complete_NoContent (HttpMethod method)
887 var port = NetworkHelpers.FindFreePort ();
888 var listener = CreateListener (l => {
890 var request = l.Request;
892 Assert.AreEqual (3, request.Headers.Count, "#1");
893 Assert.AreEqual ("0", request.Headers ["Content-Length"], "#1b");
894 Assert.AreEqual ("keep-alive", request.Headers ["Connection"], "#1c");
895 Assert.AreEqual (method.Method, request.HttpMethod, "#2");
897 } catch (Exception ex){
898 Console.WriteLine (ex);
899 Console.WriteLine (String.Join ("#", l.Request.Headers.AllKeys));
906 var client = new HttpClient ();
907 var request = new HttpRequestMessage (method, $"http://localhost:{port}/");
908 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
910 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
911 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#101");
912 Assert.AreEqual (false, failed, "#102");
919 #if FEATURE_NO_BSD_SOCKETS
920 [ExpectedException (typeof (PlatformNotSupportedException))]
922 public void Send_Complete_Error ()
924 var port = NetworkHelpers.FindFreePort ();
925 var listener = CreateListener (l => {
926 var response = l.Response;
927 response.StatusCode = 500;
931 var client = new HttpClient ();
932 var request = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
933 var response = client.SendAsync (request, HttpCompletionOption.ResponseHeadersRead).Result;
935 Assert.AreEqual ("", response.Content.ReadAsStringAsync ().Result, "#100");
936 Assert.AreEqual (HttpStatusCode.InternalServerError, response.StatusCode, "#101");
943 #if FEATURE_NO_BSD_SOCKETS
944 [ExpectedException (typeof (PlatformNotSupportedException))]
946 public void Send_Content_Get ()
948 var port = NetworkHelpers.FindFreePort ();
949 var listener = CreateListener (l => {
950 var request = l.Request;
951 l.Response.OutputStream.WriteByte (72);
955 var client = new HttpClient ();
956 var r = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
957 var response = client.SendAsync (r).Result;
959 Assert.AreEqual ("H", response.Content.ReadAsStringAsync ().Result);
966 #if FEATURE_NO_BSD_SOCKETS
967 [ExpectedException (typeof (PlatformNotSupportedException))]
969 public void Send_Content_BomEncoding ()
971 var port = NetworkHelpers.FindFreePort ();
972 var listener = CreateListener (l => {
973 var request = l.Request;
975 var str = l.Response.OutputStream;
976 str.WriteByte (0xEF);
977 str.WriteByte (0xBB);
978 str.WriteByte (0xBF);
983 var client = new HttpClient ();
984 var r = new HttpRequestMessage (HttpMethod.Get, $"http://localhost:{port}/");
985 var response = client.SendAsync (r).Result;
987 Assert.AreEqual ("G", response.Content.ReadAsStringAsync ().Result);
994 #if FEATURE_NO_BSD_SOCKETS
995 [ExpectedException (typeof (PlatformNotSupportedException))]
997 public void Send_Content_Put ()
1000 var port = NetworkHelpers.FindFreePort ();
1001 var listener = CreateListener (l => {
1002 var request = l.Request;
1003 passed = 7 == request.ContentLength64;
1004 passed &= request.ContentType == "text/plain; charset=utf-8";
1005 passed &= request.InputStream.ReadByte () == 'm';
1009 var client = new HttpClient ();
1010 var r = new HttpRequestMessage (HttpMethod.Put, $"http://localhost:{port}/");
1011 r.Content = new StringContent ("my text");
1012 var response = client.SendAsync (r).Result;
1014 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#1");
1015 Assert.IsTrue (passed, "#2");
1023 #if FEATURE_NO_BSD_SOCKETS
1024 [ExpectedException (typeof (PlatformNotSupportedException))]
1026 public void Send_Content_Put_CustomStream ()
1028 bool passed = false;
1029 var port = NetworkHelpers.FindFreePort ();
1030 var listener = CreateListener (l => {
1031 var request = l.Request;
1032 passed = 44 == request.ContentLength64;
1033 passed &= request.ContentType == null;
1037 var client = new HttpClient ();
1038 var r = new HttpRequestMessage (HttpMethod.Put, $"http://localhost:{port}/");
1039 r.Content = new StreamContent (new CustomStream ());
1040 var response = client.SendAsync (r).Result;
1042 Assert.AreEqual (HttpStatusCode.OK, response.StatusCode, "#1");
1043 Assert.IsTrue (passed, "#2");
1052 public void Send_Timeout ()
1054 var mh = new HttpMessageHandlerMock ();
1056 var client = new HttpClient (mh);
1057 client.Timeout = TimeSpan.FromMilliseconds (100);
1058 var request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
1059 var response = new HttpResponseMessage ();
1061 mh.OnSendFull = (l, c) => {
1062 Assert.IsTrue (c.WaitHandle.WaitOne (500), "#2");
1063 return Task.FromResult (response);
1066 Assert.AreEqual (response, client.SendAsync (request).Result, "#1");
1070 public void Send_Invalid ()
1072 var client = new HttpClient ();
1074 client.SendAsync (null).Wait (WaitTimeout);
1076 } catch (ArgumentNullException) {
1080 var request = new HttpRequestMessage ();
1081 client.SendAsync (request).Wait (WaitTimeout);
1083 } catch (InvalidOperationException) {
1088 public void Send_InvalidHandler ()
1090 var mh = new HttpMessageHandlerMock ();
1092 var client = new HttpClient (mh);
1093 client.BaseAddress = new Uri ("http://xamarin.com");
1094 var request = new HttpRequestMessage ();
1097 Assert.AreEqual (l, request, "#1");
1103 client.SendAsync (request).Wait (WaitTimeout);
1105 } catch (Exception) {
1110 public void Send_SameMessage ()
1112 var mh = new HttpMessageHandlerMock ();
1114 var client = new HttpClient (mh);
1115 var request = new HttpRequestMessage (HttpMethod.Get, "http://xamarin.com");
1117 mh.OnSend = l => Task.FromResult (new HttpResponseMessage ());
1119 client.SendAsync (request).Wait (WaitTimeout);
1121 client.SendAsync (request).Wait (WaitTimeout);
1123 } catch (InvalidOperationException) {
1128 #if FEATURE_NO_BSD_SOCKETS
1129 [ExpectedException (typeof (PlatformNotSupportedException))]
1131 public void Post_TransferEncodingChunked ()
1133 bool? failed = null;
1134 var port = NetworkHelpers.FindFreePort ();
1135 var listener = CreateListener (l => {
1137 var request = l.Request;
1139 Assert.IsNull (request.AcceptTypes, "#1");
1140 Assert.AreEqual (-1, request.ContentLength64, "#2");
1141 Assert.IsNull (request.ContentType, "#3");
1142 Assert.AreEqual (0, request.Cookies.Count, "#4");
1143 Assert.IsTrue (request.HasEntityBody, "#5");
1144 Assert.AreEqual ($"localhost:{port}", request.Headers ["Host"], "#6b");
1145 Assert.AreEqual ("POST", request.HttpMethod, "#7");
1146 Assert.IsFalse (request.IsAuthenticated, "#8");
1147 Assert.IsTrue (request.IsLocal, "#9");
1148 Assert.IsFalse (request.IsSecureConnection, "#10");
1149 Assert.IsFalse (request.IsWebSocketRequest, "#11");
1150 Assert.IsTrue (request.KeepAlive, "#12");
1151 Assert.AreEqual (HttpVersion.Version11, request.ProtocolVersion, "#13");
1152 Assert.IsNull (request.ServiceName, "#14");
1153 Assert.IsNull (request.UrlReferrer, "#15");
1154 Assert.IsNull (request.UserAgent, "#16");
1155 Assert.IsNull (request.UserLanguages, "#17");
1156 Assert.AreEqual ("chunked", request.Headers ["Transfer-Encoding"], "#18");
1157 Assert.IsNull (request.Headers ["Content-Length"], "#19");
1159 } catch (Exception e) {
1161 Console.WriteLine (e);
1166 var client = new HttpClient ();
1168 client.DefaultRequestHeaders.TransferEncodingChunked = true;
1170 var imageContent = new StreamContent (new MemoryStream ());
1172 var response = client.PostAsync ($"http://localhost:{port}/", imageContent).Result;
1174 Assert.AreEqual(HttpStatusCode.OK, response.StatusCode, "#101");
1175 Assert.AreEqual(false, failed, "#102");
1182 #if FEATURE_NO_BSD_SOCKETS
1183 [ExpectedException (typeof (PlatformNotSupportedException))]
1185 public void Post_StreamCaching ()
1187 bool? failed = null;
1188 var port = NetworkHelpers.FindFreePort ();
1189 var listener = CreateListener (l => {
1191 var request = l.Request;
1193 Assert.IsNull (request.AcceptTypes, "#1");
1194 Assert.AreEqual (0, request.ContentLength64, "#2");
1195 Assert.IsNull (request.ContentType, "#3");
1196 Assert.AreEqual (0, request.Cookies.Count, "#4");
1197 Assert.IsFalse (request.HasEntityBody, "#5");
1198 Assert.AreEqual ($"localhost:{port}", request.Headers ["Host"], "#6b");
1199 Assert.AreEqual ("POST", request.HttpMethod, "#7");
1200 Assert.IsFalse (request.IsAuthenticated, "#8");
1201 Assert.IsTrue (request.IsLocal, "#9");
1202 Assert.IsFalse (request.IsSecureConnection, "#10");
1203 Assert.IsFalse (request.IsWebSocketRequest, "#11");
1204 Assert.IsTrue (request.KeepAlive, "#12");
1205 Assert.AreEqual (HttpVersion.Version11, request.ProtocolVersion, "#13");
1206 Assert.IsNull (request.ServiceName, "#14");
1207 Assert.IsNull (request.UrlReferrer, "#15");
1208 Assert.IsNull (request.UserAgent, "#16");
1209 Assert.IsNull (request.UserLanguages, "#17");
1210 Assert.IsNull (request.Headers ["Transfer-Encoding"], "#18");
1211 Assert.AreEqual ("0", request.Headers ["Content-Length"], "#19");
1213 } catch (Exception e) {
1215 Console.WriteLine (e);
1220 var client = new HttpClient ();
1222 var imageContent = new StreamContent (new MemoryStream ());
1224 var response = client.PostAsync ($"http://localhost:{port}/", imageContent).Result;
1226 Assert.AreEqual(HttpStatusCode.OK, response.StatusCode, "#101");
1227 Assert.AreEqual(false, failed, "#102");
1234 [Category ("MobileNotWorking")] // Missing encoding
1235 #if FEATURE_NO_BSD_SOCKETS
1236 [ExpectedException (typeof (PlatformNotSupportedException))]
1238 public void GetString_Many ()
1240 Action<HttpListenerContext> context = (HttpListenerContext l) => {
1241 var response = l.Response;
1242 response.StatusCode = 200;
1243 response.OutputStream.WriteByte (0x68);
1244 response.OutputStream.WriteByte (0x65);
1245 response.OutputStream.WriteByte (0x6c);
1246 response.OutputStream.WriteByte (0x6c);
1247 response.OutputStream.WriteByte (0x6f);
1250 var port = NetworkHelpers.FindFreePort ();
1251 var listener = CreateListener (context, port); // creates a default request handler
1252 AddListenerContext (listener, context); // add another request handler for the second request
1255 var client = new HttpClient ();
1256 var t1 = client.GetStringAsync ($"http://localhost:{port}/");
1257 var t2 = client.GetStringAsync ($"http://localhost:{port}/");
1258 Assert.IsTrue (Task.WaitAll (new [] { t1, t2 }, WaitTimeout));
1259 Assert.AreEqual ("hello", t1.Result, "#1");
1260 Assert.AreEqual ("hello", t2.Result, "#2");
1268 #if FEATURE_NO_BSD_SOCKETS
1269 [ExpectedException (typeof (PlatformNotSupportedException))]
1271 public void GetByteArray_ServerError ()
1273 var port = NetworkHelpers.FindFreePort ();
1274 var listener = CreateListener (l => {
1275 var response = l.Response;
1276 response.StatusCode = 500;
1277 l.Response.OutputStream.WriteByte (72);
1281 var client = new HttpClient ();
1283 client.GetByteArrayAsync ($"http://localhost:{port}/").Wait (WaitTimeout);
1285 } catch (AggregateException e) {
1286 Assert.IsTrue (e.InnerException is HttpRequestException , "#2");
1294 #if FEATURE_NO_BSD_SOCKETS
1295 [ExpectedException (typeof (PlatformNotSupportedException))]
1297 public void DisallowAutoRedirect ()
1299 var port = NetworkHelpers.FindFreePort ();
1300 var listener = CreateListener (l => {
1301 var request = l.Request;
1302 var response = l.Response;
1304 response.StatusCode = (int)HttpStatusCode.Moved;
1305 response.RedirectLocation = "http://xamarin.com/";
1309 var chandler = new HttpClientHandler ();
1310 chandler.AllowAutoRedirect = false;
1311 var client = new HttpClient (chandler);
1314 client.GetStringAsync ($"http://localhost:{port}/").Wait (WaitTimeout);
1316 } catch (AggregateException e) {
1317 Assert.IsTrue (e.InnerException is HttpRequestException, "#2");
1326 #if FEATURE_NO_BSD_SOCKETS
1327 [ExpectedException (typeof (PlatformNotSupportedException))]
1329 public void RequestUriAfterRedirect ()
1331 var port = NetworkHelpers.FindFreePort ();
1332 var redirectPort = NetworkHelpers.FindFreePort ();
1334 var listener = CreateListener (l => {
1335 var request = l.Request;
1336 var response = l.Response;
1338 response.StatusCode = (int)HttpStatusCode.Moved;
1339 response.RedirectLocation = $"http://localhost:{redirectPort}/";
1342 var listener2 = CreateListener (l => {
1343 var response = l.Response;
1345 response.StatusCode = (int)HttpStatusCode.OK;
1346 response.OutputStream.WriteByte (0x68);
1347 response.OutputStream.WriteByte (0x65);
1348 response.OutputStream.WriteByte (0x6c);
1349 response.OutputStream.WriteByte (0x6c);
1350 response.OutputStream.WriteByte (0x6f);
1354 var chandler = new HttpClientHandler ();
1355 chandler.AllowAutoRedirect = true;
1356 var client = new HttpClient (chandler);
1358 var r = client.GetAsync ($"http://localhost:{port}/");
1359 Assert.IsTrue (r.Wait (WaitTimeout), "#1");
1360 var resp = r.Result;
1361 Assert.AreEqual ($"http://localhost:{redirectPort}/", resp.RequestMessage.RequestUri.AbsoluteUri, "#2");
1362 Assert.AreEqual ("hello", resp.Content.ReadAsStringAsync ().Result, "#3");
1372 #if FEATURE_NO_BSD_SOCKETS
1373 [ExpectedException (typeof (PlatformNotSupportedException))]
1376 * Properties may only be modified before sending the first request.
1378 public void ModifyHandlerAfterFirstRequest ()
1380 var chandler = new HttpClientHandler ();
1381 chandler.AllowAutoRedirect = true;
1382 var client = new HttpClient (chandler, true);
1384 var port = NetworkHelpers.FindFreePort ();
1385 var listener = CreateListener (l => {
1386 var response = l.Response;
1387 response.StatusCode = 200;
1388 response.OutputStream.WriteByte (55);
1392 client.GetStringAsync ($"http://localhost:{port}/").Wait (WaitTimeout);
1394 chandler.AllowAutoRedirect = false;
1396 } catch (InvalidOperationException) {
1406 #if FEATURE_NO_BSD_SOCKETS
1407 // Using HttpClientHandler, which indirectly requires BSD sockets.
1408 [ExpectedException (typeof (PlatformNotSupportedException))]
1411 * However, this policy is not enforced for custom handlers and there
1412 * is also no way a derived class could tell its HttpClientHandler parent
1413 * that it just sent a request.
1416 public void ModifyHandlerAfterFirstRequest_Mock ()
1418 var ch = new HttpClientHandlerMock ();
1419 ch.AllowAutoRedirect = true;
1421 var client = new HttpClient (ch);
1423 ch.OnSend = (l) => {
1424 return Task.FromResult (new HttpResponseMessage ());
1427 client.GetAsync ("http://xamarin.com").Wait (WaitTimeout);
1428 ch.AllowAutoRedirect = false;
1431 HttpListener CreateListener (Action<HttpListenerContext> contextAssert, int port)
1433 var l = new HttpListener ();
1434 l.Prefixes.Add (string.Format ("http://+:{0}/", port));
1436 AddListenerContext(l, contextAssert);
1441 HttpListener AddListenerContext (HttpListener l, Action<HttpListenerContext> contextAssert)
1443 l.BeginGetContext (ar => {
1444 var ctx = l.EndGetContext (ar);
1447 if (contextAssert != null)
1448 contextAssert (ctx);
1450 ctx.Response.Close ();