HttpWebRequestTest.cs 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482
  1. //
  2. // HttpWebRequestTest.cs - NUnit Test Cases for System.Net.HttpWebRequest
  3. //
  4. // Authors:
  5. // Lawrence Pit ([email protected])
  6. // Martin Willemoes Hansen ([email protected])
  7. // Gonzalo Paniagua Javier ([email protected])
  8. //
  9. // (C) 2003 Martin Willemoes Hansen
  10. // Copyright (c) 2005 Novell, Inc. (http://www.novell.com
  11. //
  12. using NUnit.Framework;
  13. using System;
  14. using System.Collections;
  15. using System.Collections.Specialized;
  16. using System.Globalization;
  17. using System.IO;
  18. using System.Net;
  19. using System.Net.Sockets;
  20. using System.Security.Cryptography;
  21. using System.Security.Cryptography.X509Certificates;
  22. using System.Text;
  23. using System.Threading;
  24. #if !TARGET_JVM
  25. using Mono.Security.Authenticode;
  26. using Mono.Security.Protocol.Tls;
  27. #endif
  28. namespace MonoTests.System.Net
  29. {
  30. [TestFixture]
  31. public class HttpWebRequestTest
  32. {
  33. [Test]
  34. #if TARGET_JVM
  35. [Ignore ("Ignore failures in Sys.Net")]
  36. #endif
  37. public void Proxy_Null ()
  38. {
  39. HttpWebRequest req = (HttpWebRequest) WebRequest.Create ("http://www.google.com");
  40. Assert.IsNotNull (req.Proxy, "#1");
  41. #if NET_2_0
  42. req.Proxy = null;
  43. Assert.IsNull (req.Proxy, "#2");
  44. #else
  45. try {
  46. req.Proxy = null;
  47. Assert.Fail ("#2");
  48. } catch (ArgumentNullException ex) {
  49. Assert.AreEqual (typeof (ArgumentNullException), ex.GetType (), "#3");
  50. Assert.IsNull (ex.InnerException, "#4");
  51. Assert.IsNotNull (ex.Message, "#5");
  52. Assert.IsNotNull (ex.ParamName, "#6");
  53. Assert.AreEqual ("value", ex.ParamName, "#7");
  54. }
  55. #endif
  56. }
  57. [Test]
  58. [Category("InetAccess")]
  59. #if TARGET_JVM
  60. [Ignore ("NMA - wrong cookies number returned")]
  61. #endif
  62. public void Sync ()
  63. {
  64. HttpWebRequest req = (HttpWebRequest) WebRequest.Create ("http://www.google.com");
  65. Assertion.AssertNotNull ("req:If Modified Since: ", req.IfModifiedSince);
  66. req.UserAgent = "MonoClient v1.0";
  67. Assert.AreEqual ("User-Agent", req.Headers.GetKey (0), "#A1");
  68. Assert.AreEqual ("MonoClient v1.0", req.Headers.Get (0), "#A2");
  69. HttpWebResponse res = (HttpWebResponse) req.GetResponse ();
  70. Assert.AreEqual ("OK", res.StatusCode.ToString (), "#B1");
  71. Assert.AreEqual ("OK", res.StatusDescription, "#B2");
  72. Assert.AreEqual ("text/html; charset=ISO-8859-1", res.Headers.Get ("Content-Type"), "#C1");
  73. Assert.IsNotNull (res.LastModified, "#C2");
  74. Assert.AreEqual (0, res.Cookies.Count, "#C3");
  75. res.Close ();
  76. }
  77. [Test]
  78. public void AddRange ()
  79. {
  80. HttpWebRequest req = (HttpWebRequest) WebRequest.Create ("http://www.google.com");
  81. req.AddRange (10);
  82. req.AddRange (50, 90);
  83. req.AddRange ("bytes", 100);
  84. req.AddRange ("bytes", 100, 120);
  85. Assertion.AssertEquals ("#1", "bytes=10-,50-90,100-,100-120", req.Headers ["Range"]);
  86. try {
  87. req.AddRange ("bits", 2000);
  88. Assertion.Fail ("#2");
  89. } catch (InvalidOperationException) {}
  90. }
  91. [Test] // bug #471782
  92. public void CloseRequestStreamAfterReadingResponse ()
  93. {
  94. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  95. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  96. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  97. responder.Start ();
  98. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  99. req.Method = "POST";
  100. req.Timeout = 2000;
  101. req.ReadWriteTimeout = 2000;
  102. byte [] data = new byte [128];
  103. req.ContentLength = data.Length;
  104. Stream rs = req.GetRequestStream ();
  105. rs.Write (data, 0, data.Length);
  106. rs.Flush ();
  107. HttpWebResponse response = (HttpWebResponse) req.GetResponse ();
  108. response.Close ();
  109. rs.Close ();
  110. responder.Stop ();
  111. }
  112. }
  113. [Test]
  114. [Category("InetAccess")]
  115. public void Cookies1 ()
  116. {
  117. // The purpose of this test is to ensure that the cookies we get from a request
  118. // are stored in both, the CookieCollection in HttpWebResponse and the CookieContainer
  119. // in HttpWebRequest.
  120. // If this URL stops sending *one* and only one cookie, replace it.
  121. string url = "http://www.elmundo.es";
  122. CookieContainer cookies = new CookieContainer ();
  123. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  124. req.KeepAlive = false;
  125. req.UserAgent = "Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv; 1.7.6) Gecko/20050317 Firefox/1.0.2";
  126. req.CookieContainer = cookies;
  127. Assertion.AssertEquals ("#01", 0, cookies.Count);
  128. using (HttpWebResponse res = (HttpWebResponse) req.GetResponse()) {
  129. CookieCollection coll = req.CookieContainer.GetCookies (new Uri (url));
  130. Assertion.AssertEquals ("#02", 1, coll.Count);
  131. Assertion.AssertEquals ("#03", 1, res.Cookies.Count);
  132. Cookie one = coll [0];
  133. Cookie two = res.Cookies [0];
  134. Assertion.AssertEquals ("#04", true, object.ReferenceEquals (one, two));
  135. }
  136. }
  137. #if !TARGET_JVM //NotWorking
  138. [Test]
  139. public void SslClientBlock ()
  140. {
  141. // This tests that the write request/initread/write body sequence does not hang
  142. // when using SSL.
  143. // If there's a regression for this, the test will hang.
  144. ServicePointManager.CertificatePolicy = new AcceptAllPolicy ();
  145. try {
  146. SslHttpServer server = new SslHttpServer ();
  147. server.Start ();
  148. string url = String.Format ("https://{0}:{1}/nothing.html", server.IPAddress, server.Port);
  149. HttpWebRequest request = (HttpWebRequest) WebRequest.Create (url);
  150. request.Method = "POST";
  151. Stream stream = request.GetRequestStream ();
  152. byte [] bytes = new byte [100];
  153. stream.Write (bytes, 0, bytes.Length);
  154. stream.Close ();
  155. HttpWebResponse resp = (HttpWebResponse) request.GetResponse ();
  156. Assertion.AssertEquals ("StatusCode", 200, (int) resp.StatusCode);
  157. StreamReader sr = new StreamReader (resp.GetResponseStream (), Encoding.UTF8);
  158. string x = sr.ReadToEnd ();
  159. sr.Close ();
  160. resp.Close ();
  161. server.Stop ();
  162. if (server.Error != null)
  163. throw server.Error;
  164. } finally {
  165. ServicePointManager.CertificatePolicy = null;
  166. }
  167. }
  168. #endif
  169. [Test]
  170. #if TARGET_JVM
  171. [Category("NotWorking")]
  172. #endif
  173. public void Missing_ContentEncoding ()
  174. {
  175. ServicePointManager.CertificatePolicy = new AcceptAllPolicy ();
  176. try {
  177. BadChunkedServer server = new BadChunkedServer ();
  178. server.Start ();
  179. string url = String.Format ("http://{0}:{1}/nothing.html", server.IPAddress, server.Port);
  180. HttpWebRequest request = (HttpWebRequest) WebRequest.Create (url);
  181. request.Method = "GET";
  182. HttpWebResponse resp = (HttpWebResponse) request.GetResponse ();
  183. Assert.AreEqual ("", resp.ContentEncoding);
  184. resp.Close ();
  185. server.Stop ();
  186. if (server.Error != null)
  187. throw server.Error;
  188. } finally {
  189. ServicePointManager.CertificatePolicy = null;
  190. }
  191. }
  192. [Test]
  193. #if TARGET_JVM
  194. [Category ("NotWorking")]
  195. #endif
  196. public void BadServer_ChunkedClose ()
  197. {
  198. // The server will send a chunked response without a 'last-chunked' mark
  199. // and then shutdown the socket for sending.
  200. BadChunkedServer server = new BadChunkedServer ();
  201. server.Start ();
  202. string url = String.Format ("http://{0}:{1}/nothing.html", server.IPAddress, server.Port);
  203. HttpWebRequest request = (HttpWebRequest) WebRequest.Create (url);
  204. HttpWebResponse resp = (HttpWebResponse) request.GetResponse ();
  205. string x = null;
  206. try {
  207. byte [] bytes = new byte [32];
  208. // Using StreamReader+UTF8Encoding here fails on MS runtime
  209. Stream stream = resp.GetResponseStream ();
  210. int nread = stream.Read (bytes, 0, 32);
  211. Assertion.AssertEquals ("#01", 16, nread);
  212. x = Encoding.ASCII.GetString (bytes, 0, 16);
  213. } finally {
  214. resp.Close ();
  215. server.Stop ();
  216. }
  217. if (server.Error != null)
  218. throw server.Error;
  219. Assertion.AssertEquals ("1234567890123456", x);
  220. }
  221. [Test]
  222. [Ignore ("This test asserts that our code violates RFC 2616")]
  223. public void MethodCase ()
  224. {
  225. ListDictionary methods = new ListDictionary ();
  226. #if NET_2_0
  227. methods.Add ("post", "POST");
  228. methods.Add ("puT", "PUT");
  229. #else
  230. methods.Add ("post", "post");
  231. methods.Add ("puT", "puT");
  232. #endif
  233. methods.Add ("POST", "POST");
  234. methods.Add ("whatever", "whatever");
  235. methods.Add ("PUT", "PUT");
  236. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  237. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  238. foreach (DictionaryEntry de in methods) {
  239. SocketResponder responder = new SocketResponder (new IPEndPoint (IPAddress.Loopback, 8000),
  240. new SocketRequestHandler (EchoRequestHandler));
  241. responder.Start ();
  242. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  243. req.Method = (string) de.Key;
  244. req.Timeout = 2000;
  245. req.ReadWriteTimeout = 2000;
  246. req.KeepAlive = false;
  247. Stream rs = req.GetRequestStream ();
  248. rs.Close ();
  249. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  250. StreamReader sr = new StreamReader (resp.GetResponseStream (),
  251. Encoding.UTF8);
  252. string line = sr.ReadLine ();
  253. sr.Close ();
  254. Assert.AreEqual (((string) de.Value) + " /test/ HTTP/1.1",
  255. line, req.Method);
  256. resp.Close ();
  257. }
  258. responder.Stop ();
  259. }
  260. }
  261. [Test]
  262. public void BeginGetRequestStream_Body_NotAllowed ()
  263. {
  264. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  265. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  266. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  267. responder.Start ();
  268. HttpWebRequest request;
  269. request = (HttpWebRequest) WebRequest.Create (url);
  270. request.Method = "GET";
  271. try {
  272. request.BeginGetRequestStream (null, null);
  273. Assert.Fail ("#A1");
  274. } catch (ProtocolViolationException ex) {
  275. // Cannot send a content-body with this
  276. // verb-type
  277. Assert.IsNull (ex.InnerException, "#A2");
  278. Assert.IsNotNull (ex.Message, "#A3");
  279. }
  280. request = (HttpWebRequest) WebRequest.Create (url);
  281. request.Method = "HEAD";
  282. try {
  283. request.BeginGetRequestStream (null, null);
  284. Assert.Fail ("#B1");
  285. } catch (ProtocolViolationException ex) {
  286. // Cannot send a content-body with this
  287. // verb-type
  288. Assert.IsNull (ex.InnerException, "#B2");
  289. Assert.IsNotNull (ex.Message, "#B3");
  290. }
  291. }
  292. }
  293. [Test] // bug #465613
  294. public void BeginGetRequestStream_NoBuffering ()
  295. {
  296. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8002);
  297. string url = "http://" + IPAddress.Loopback.ToString () + ":8002/test/";
  298. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  299. responder.Start ();
  300. HttpWebRequest req;
  301. Stream rs;
  302. IAsyncResult ar;
  303. req = (HttpWebRequest) WebRequest.Create (url);
  304. req.Method = "POST";
  305. req.SendChunked = false;
  306. req.KeepAlive = false;
  307. req.AllowWriteStreamBuffering = false;
  308. ar = req.BeginGetRequestStream (null, null);
  309. rs = req.EndGetRequestStream (ar);
  310. rs.Close ();
  311. req = (HttpWebRequest) WebRequest.Create (url);
  312. req.Method = "POST";
  313. req.SendChunked = false;
  314. req.KeepAlive = true;
  315. req.AllowWriteStreamBuffering = false;
  316. try {
  317. req.BeginGetRequestStream (null, null);
  318. Assert.Fail ("#A1");
  319. } catch (ProtocolViolationException ex) {
  320. // When performing a write operation with
  321. // AllowWriteStreamBuffering set to false,
  322. // you must either set ContentLength to a
  323. // non-negative number or set SendChunked
  324. // to true
  325. Assert.IsNull (ex.InnerException, "#A2");
  326. Assert.IsNotNull (ex.Message, "#A3");
  327. }
  328. req = (HttpWebRequest) WebRequest.Create (url);
  329. req.Method = "POST";
  330. req.SendChunked = false;
  331. req.KeepAlive = true;
  332. req.AllowWriteStreamBuffering = false;
  333. req.ContentLength = 0;
  334. ar = req.BeginGetRequestStream (null, null);
  335. rs = req.EndGetRequestStream (ar);
  336. rs.Close ();
  337. }
  338. }
  339. [Test] // bug #508027
  340. public void BeginGetResponse ()
  341. {
  342. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8003);
  343. string url = "http://" + IPAddress.Loopback.ToString () + ":8003/test/";
  344. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  345. responder.Start ();
  346. HttpWebRequest req;
  347. req = (HttpWebRequest) WebRequest.Create (url);
  348. req.Method = "POST";
  349. req.SendChunked = false;
  350. req.KeepAlive = false;
  351. req.AllowWriteStreamBuffering = false;
  352. req.BeginGetResponse (null, null);
  353. req.Abort ();
  354. req = (HttpWebRequest) WebRequest.Create (url);
  355. req.Method = "POST";
  356. req.SendChunked = true;
  357. req.KeepAlive = false;
  358. req.AllowWriteStreamBuffering = false;
  359. req.BeginGetResponse (null, null);
  360. req.Abort ();
  361. req = (HttpWebRequest) WebRequest.Create (url);
  362. req.Method = "POST";
  363. req.ContentLength = 5;
  364. req.SendChunked = false;
  365. req.KeepAlive = false;
  366. req.AllowWriteStreamBuffering = false;
  367. req.BeginGetResponse (null, null);
  368. req.Abort ();
  369. req = (HttpWebRequest) WebRequest.Create (url);
  370. req.Method = "POST";
  371. req.SendChunked = false;
  372. req.KeepAlive = true;
  373. req.AllowWriteStreamBuffering = false;
  374. #if NET_2_0
  375. req.BeginGetResponse (null, null);
  376. req.Abort ();
  377. #else
  378. try {
  379. req.BeginGetResponse (null, null);
  380. } catch (ProtocolViolationException ex) {
  381. // Either ContentLength must be set to a non-negative
  382. // number, or SendChunked set to true in order to perform
  383. // the write operation when AllowWriteStreamBuffering
  384. // is disabled
  385. Assert.IsNull (ex.InnerException, "#A2");
  386. Assert.IsNotNull (ex.Message, "#A3");
  387. } finally {
  388. req.Abort ();
  389. }
  390. #endif
  391. req = (HttpWebRequest) WebRequest.Create (url);
  392. req.Method = "POST";
  393. req.SendChunked = false;
  394. req.KeepAlive = false;
  395. req.AllowWriteStreamBuffering = false;
  396. req.ContentLength = 5;
  397. req.BeginGetResponse (null, null);
  398. req.Abort ();
  399. req = (HttpWebRequest) WebRequest.Create (url);
  400. req.Method = "POST";
  401. req.SendChunked = false;
  402. req.KeepAlive = true;
  403. req.AllowWriteStreamBuffering = false;
  404. req.ContentLength = 5;
  405. req.BeginGetResponse (null, null);
  406. req.Abort ();
  407. req = (HttpWebRequest) WebRequest.Create (url);
  408. req.Method = "GET";
  409. req.SendChunked = true;
  410. #if NET_2_0
  411. req.BeginGetResponse (null, null);
  412. req.Abort ();
  413. #else
  414. try {
  415. req.BeginGetResponse (null, null);
  416. Assert.Fail ("#B1");
  417. } catch (ProtocolViolationException ex) {
  418. // Content-Length cannot be set for a
  419. // non-write operation
  420. Assert.IsNull (ex.InnerException, "#B2");
  421. Assert.IsNotNull (ex.Message, "#B3");
  422. } finally {
  423. req.Abort ();
  424. }
  425. #endif
  426. req = (HttpWebRequest) WebRequest.Create (url);
  427. req.Method = "GET";
  428. req.ContentLength = 5;
  429. #if NET_2_0
  430. req.BeginGetResponse (null, null);
  431. req.Abort ();
  432. #else
  433. try {
  434. req.BeginGetResponse (null, null);
  435. Assert.Fail ("#C1");
  436. } catch (ProtocolViolationException ex) {
  437. // Content-Length cannot be set for a
  438. // non-write operation
  439. Assert.IsNull (ex.InnerException, "#C2");
  440. Assert.IsNotNull (ex.Message, "#C3");
  441. } finally {
  442. req.Abort ();
  443. }
  444. #endif
  445. req = (HttpWebRequest) WebRequest.Create (url);
  446. req.Method = "GET";
  447. req.ContentLength = 0;
  448. #if NET_2_0
  449. req.BeginGetResponse (null, null);
  450. req.Abort ();
  451. #else
  452. try {
  453. req.BeginGetResponse (null, null);
  454. Assert.Fail ("#D1");
  455. } catch (ProtocolViolationException ex) {
  456. // Content-Length cannot be set for a
  457. // non-write operation
  458. Assert.IsNull (ex.InnerException, "#D2");
  459. Assert.IsNotNull (ex.Message, "#D3");
  460. } finally {
  461. req.Abort ();
  462. }
  463. #endif
  464. }
  465. }
  466. [Test] // bug #429200
  467. public void GetRequestStream ()
  468. {
  469. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  470. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  471. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  472. responder.Start ();
  473. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  474. req.Method = "POST";
  475. req.Timeout = 2000;
  476. req.ReadWriteTimeout = 2000;
  477. Stream rs1 = req.GetRequestStream ();
  478. Stream rs2 = req.GetRequestStream ();
  479. Assert.IsNotNull (rs1, "#1");
  480. Assert.AreSame (rs1, rs2, "#2");
  481. rs1.Close ();
  482. }
  483. }
  484. [Test] // bug #510661 and #514996
  485. [Category ("NotWorking")]
  486. public void GetRequestStream_Close_NotAllBytesWritten ()
  487. {
  488. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  489. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  490. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  491. responder.Start ();
  492. HttpWebRequest req;
  493. Stream rs;
  494. req = (HttpWebRequest) WebRequest.Create (url);
  495. req.Method = "POST";
  496. req.ContentLength = 2;
  497. rs = req.GetRequestStream ();
  498. try {
  499. rs.Close ();
  500. Assert.Fail ("#A1");
  501. } catch (WebException ex) {
  502. // The request was aborted: The request was canceled
  503. Assert.AreEqual (typeof (WebException), ex.GetType (), "#A2");
  504. Assert.IsNotNull (ex.Message, "#A3");
  505. Assert.IsNull (ex.Response, "#A4");
  506. Assert.AreEqual (WebExceptionStatus.RequestCanceled, ex.Status, "#A5");
  507. // Cannot close stream until all bytes are written
  508. Exception inner = ex.InnerException;
  509. Assert.IsNotNull (inner, "#A6");
  510. Assert.AreEqual (typeof (IOException), inner.GetType (), "#A7");
  511. Assert.IsNull (inner.InnerException, "#A8");
  512. Assert.IsNotNull (inner.Message, "#A9");
  513. }
  514. req = (HttpWebRequest) WebRequest.Create (url);
  515. req.Method = "POST";
  516. req.ContentLength = 2;
  517. rs = req.GetRequestStream ();
  518. rs.WriteByte (0x0d);
  519. try {
  520. rs.Close ();
  521. Assert.Fail ("#B1");
  522. } catch (WebException ex) {
  523. // The request was aborted: The request was canceled
  524. Assert.AreEqual (typeof (WebException), ex.GetType (), "#B2");
  525. Assert.IsNotNull (ex.Message, "#B3");
  526. Assert.IsNull (ex.Response, "#B4");
  527. Assert.AreEqual (WebExceptionStatus.RequestCanceled, ex.Status, "#B5");
  528. // Cannot close stream until all bytes are written
  529. Exception inner = ex.InnerException;
  530. Assert.IsNotNull (inner, "#B6");
  531. Assert.AreEqual (typeof (IOException), inner.GetType (), "#B7");
  532. Assert.IsNull (inner.InnerException, "#B8");
  533. Assert.IsNotNull (inner.Message, "#B9");
  534. }
  535. req = (HttpWebRequest) WebRequest.Create (url);
  536. req.Method = "POST";
  537. req.ContentLength = 2;
  538. rs = req.GetRequestStream ();
  539. rs.WriteByte (0x0d);
  540. rs.WriteByte (0x0d);
  541. rs.Close ();
  542. }
  543. }
  544. [Test] // bug #510642
  545. [Category ("NotWorking")]
  546. public void GetRequestStream_Write_Overflow ()
  547. {
  548. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8001);
  549. string url = "http://" + IPAddress.Loopback.ToString () + ":8001/test/";
  550. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (EchoRequestHandler))) {
  551. responder.Start ();
  552. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  553. req.ProtocolVersion = HttpVersion.Version11;
  554. req.Method = "POST";
  555. req.Timeout = 200;
  556. req.ReadWriteTimeout = 100;
  557. req.ContentLength = 2;
  558. Stream rs = req.GetRequestStream ();
  559. byte [] buffer = new byte [] { 0x2a, 0x2c, 0x1d };
  560. try {
  561. rs.Write (buffer, 0, 3);
  562. Assert.Fail ("#1");
  563. } catch (ProtocolViolationException ex) {
  564. // Bytes to be written to the stream exceed
  565. // Content-Length bytes size specified
  566. Assert.IsNull (ex.InnerException, "#2");
  567. Assert.IsNotNull (ex.Message, "#3");
  568. } finally {
  569. req.Abort ();
  570. }
  571. }
  572. }
  573. [Test]
  574. [Ignore ("This test asserts that our code violates RFC 2616")]
  575. public void GetRequestStream_Body_NotAllowed ()
  576. {
  577. string [] methods = new string [] { "GET", "HEAD", "CONNECT",
  578. "get", "HeAd", "ConNect" };
  579. foreach (string method in methods) {
  580. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (
  581. "http://localhost:8000");
  582. req.Method = method;
  583. try {
  584. req.GetRequestStream ();
  585. Assert.Fail ("#1:" + method);
  586. } catch (ProtocolViolationException ex) {
  587. Assert.AreEqual (typeof (ProtocolViolationException), ex.GetType (), "#2:" + method);
  588. Assert.IsNull (ex.InnerException, "#3:" + method);
  589. Assert.IsNotNull (ex.Message, "#4:" + method);
  590. }
  591. }
  592. }
  593. [Test]
  594. #if TARGET_JVM
  595. [Category("NotWorking")]
  596. #endif
  597. [Ignore ("This does not timeout any more. That's how MS works when reading small responses")]
  598. public void ReadTimeout ()
  599. {
  600. IPEndPoint localEP = new IPEndPoint (IPAddress.Loopback, 8764);
  601. string url = "http://" + localEP.ToString () + "/original/";
  602. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (RedirectRequestHandler))) {
  603. responder.Start ();
  604. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  605. req.Method = "POST";
  606. req.AllowAutoRedirect = false;
  607. req.Timeout = 200;
  608. req.ReadWriteTimeout = 100;
  609. req.KeepAlive = false;
  610. Stream rs = req.GetRequestStream ();
  611. rs.Close ();
  612. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  613. try {
  614. Stream s = resp.GetResponseStream ();
  615. s.ReadByte ();
  616. Assert.Fail ("#1");
  617. } catch (WebException ex) {
  618. Assert.AreEqual (typeof (WebException), ex.GetType (), "#2");
  619. Assert.IsNull (ex.InnerException, "#3");
  620. Assert.IsNull (ex.Response, "#4");
  621. Assert.AreEqual (WebExceptionStatus.Timeout, ex.Status, "#5");
  622. }
  623. }
  624. responder.Stop ();
  625. }
  626. }
  627. [Test] // bug #324300
  628. #if TARGET_JVM
  629. [Category("NotWorking")]
  630. #endif
  631. public void AllowAutoRedirect ()
  632. {
  633. IPEndPoint localEP = new IPEndPoint (IPAddress.Loopback, 8764);
  634. string url = "http://" + localEP.ToString () + "/original/";
  635. // allow autoredirect
  636. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (RedirectRequestHandler))) {
  637. responder.Start ();
  638. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  639. req.Method = "POST";
  640. req.Timeout = 2000;
  641. req.ReadWriteTimeout = 2000;
  642. req.KeepAlive = false;
  643. Stream rs = req.GetRequestStream ();
  644. rs.Close ();
  645. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  646. StreamReader sr = new StreamReader (resp.GetResponseStream (),
  647. Encoding.UTF8);
  648. string body = sr.ReadToEnd ();
  649. Assert.AreEqual (resp.StatusCode, HttpStatusCode.OK, "#A1");
  650. Assert.AreEqual (resp.ResponseUri.ToString (), "http://" +
  651. localEP.ToString () + "/moved/", "#A2");
  652. Assert.AreEqual ("GET", resp.Method, "#A3");
  653. Assert.AreEqual ("LOOKS OK", body, "#A4");
  654. }
  655. responder.Stop ();
  656. }
  657. // do not allow autoredirect
  658. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (RedirectRequestHandler))) {
  659. responder.Start ();
  660. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  661. req.Method = "POST";
  662. req.AllowAutoRedirect = false;
  663. req.Timeout = 1000;
  664. req.ReadWriteTimeout = 1000;
  665. req.KeepAlive = false;
  666. Stream rs = req.GetRequestStream ();
  667. rs.Close ();
  668. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  669. Assert.AreEqual (resp.StatusCode, HttpStatusCode.Found, "#B1");
  670. Assert.AreEqual (url, resp.ResponseUri.ToString (), "#B2");
  671. Assert.AreEqual ("POST", resp.Method, "#B3");
  672. }
  673. responder.Stop ();
  674. }
  675. }
  676. [Test] // bug #324347
  677. [Category ("NotWorking")]
  678. public void InternalServerError ()
  679. {
  680. IPEndPoint localEP = new IPEndPoint (IPAddress.Loopback, 8764);
  681. string url = "http://" + localEP.ToString () + "/original/";
  682. // POST
  683. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (InternalErrorHandler))) {
  684. responder.Start ();
  685. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  686. req.Method = "POST";
  687. req.Timeout = 2000;
  688. req.ReadWriteTimeout = 2000;
  689. req.KeepAlive = false;
  690. Stream rs = req.GetRequestStream ();
  691. rs.Close ();
  692. try {
  693. req.GetResponse ();
  694. Assert.Fail ("#A1");
  695. } catch (WebException ex) {
  696. Assert.AreEqual (typeof (WebException), ex.GetType (), "#A2");
  697. Assert.IsNull (ex.InnerException, "#A3");
  698. Assert.IsNotNull (ex.Message, "#A4");
  699. Assert.AreEqual (WebExceptionStatus.ProtocolError, ex.Status, "#A5");
  700. HttpWebResponse webResponse = ex.Response as HttpWebResponse;
  701. Assert.IsNotNull (webResponse, "#A6");
  702. Assert.AreEqual ("POST", webResponse.Method, "#A7");
  703. webResponse.Close ();
  704. }
  705. responder.Stop ();
  706. }
  707. // GET
  708. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (InternalErrorHandler))) {
  709. responder.Start ();
  710. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  711. req.Method = "GET";
  712. req.Timeout = 2000;
  713. req.ReadWriteTimeout = 2000;
  714. req.KeepAlive = false;
  715. try {
  716. req.GetResponse ();
  717. Assert.Fail ("#B1");
  718. } catch (WebException ex) {
  719. Assert.AreEqual (typeof (WebException), ex.GetType (), "#B2");
  720. Assert.IsNull (ex.InnerException, "#B3");
  721. Assert.AreEqual (WebExceptionStatus.ProtocolError, ex.Status, "#B4");
  722. HttpWebResponse webResponse = ex.Response as HttpWebResponse;
  723. Assert.IsNotNull (webResponse, "#B5");
  724. Assert.AreEqual ("GET", webResponse.Method, "#B6");
  725. webResponse.Close ();
  726. }
  727. responder.Stop ();
  728. }
  729. }
  730. [Test]
  731. [Category ("NotWorking")] // #B3 fails; we get a SocketException: An existing connection was forcibly closed by the remote host
  732. public void NoContentLength ()
  733. {
  734. IPEndPoint localEP = new IPEndPoint (IPAddress.Loopback, 8764);
  735. string url = "http://" + localEP.ToString () + "/original/";
  736. // POST
  737. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (NoContentLengthHandler))) {
  738. responder.Start ();
  739. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  740. req.Method = "POST";
  741. req.Timeout = 2000;
  742. req.ReadWriteTimeout = 2000;
  743. req.KeepAlive = false;
  744. Stream rs = req.GetRequestStream ();
  745. rs.Close ();
  746. try {
  747. req.GetResponse ();
  748. Assert.Fail ("#A1");
  749. } catch (WebException ex) {
  750. #if NET_2_0
  751. // The underlying connection was closed:
  752. // An unexpected error occurred on a
  753. // receive
  754. Assert.AreEqual (typeof (WebException), ex.GetType (), "#A2");
  755. Assert.IsNotNull (ex.InnerException, "#A3");
  756. Assert.AreEqual (WebExceptionStatus.ReceiveFailure, ex.Status, "#A4");
  757. Assert.AreEqual (typeof (IOException), ex.InnerException.GetType (), "#A5");
  758. // Unable to read data from the transport connection:
  759. // A connection attempt failed because the connected party
  760. // did not properly respond after a period of time, or
  761. // established connection failed because connected host has
  762. // failed to respond
  763. IOException ioe = (IOException) ex.InnerException;
  764. Assert.IsNotNull (ioe.InnerException, "#A6");
  765. Assert.IsNotNull (ioe.Message, "#A7");
  766. Assert.AreEqual (typeof (SocketException), ioe.InnerException.GetType (), "#A8");
  767. // An existing connection was forcibly
  768. // closed by the remote host
  769. SocketException soe = (SocketException) ioe.InnerException;
  770. Assert.IsNull (soe.InnerException, "#A9");
  771. Assert.IsNotNull (soe.Message, "#A10");
  772. HttpWebResponse webResponse = ex.Response as HttpWebResponse;
  773. Assert.IsNull (webResponse, "#A11");
  774. #else
  775. // The remote server returned an error:
  776. // (500) Internal Server Error
  777. Assert.AreEqual (typeof (WebException), ex.GetType (), "#A2");
  778. Assert.IsNull (ex.InnerException, "#A3");
  779. Assert.AreEqual (WebExceptionStatus.ProtocolError, ex.Status, "#A4");
  780. HttpWebResponse webResponse = ex.Response as HttpWebResponse;
  781. Assert.IsNotNull (webResponse, "#A5");
  782. Assert.AreEqual ("POST", webResponse.Method, "#A6");
  783. webResponse.Close ();
  784. #endif
  785. }
  786. responder.Stop ();
  787. }
  788. // GET
  789. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (NoContentLengthHandler))) {
  790. responder.Start ();
  791. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  792. req.Method = "GET";
  793. req.Timeout = 2000;
  794. req.ReadWriteTimeout = 2000;
  795. req.KeepAlive = false;
  796. try {
  797. req.GetResponse ();
  798. Assert.Fail ("#B1");
  799. } catch (WebException ex) {
  800. // The remote server returned an error:
  801. // (500) Internal Server Error
  802. Assert.AreEqual (typeof (WebException), ex.GetType (), "#B2");
  803. Assert.IsNull (ex.InnerException, "#B3");
  804. Assert.AreEqual (WebExceptionStatus.ProtocolError, ex.Status, "#B4");
  805. HttpWebResponse webResponse = ex.Response as HttpWebResponse;
  806. Assert.IsNotNull (webResponse, "#B5");
  807. Assert.AreEqual ("GET", webResponse.Method, "#B6");
  808. webResponse.Close ();
  809. }
  810. responder.Stop ();
  811. }
  812. }
  813. [Test] // bug #513087
  814. public void NonStandardVerb ()
  815. {
  816. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  817. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/moved/";
  818. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (VerbEchoHandler))) {
  819. responder.Start ();
  820. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  821. req.Method = "WhatEver";
  822. req.KeepAlive = false;
  823. req.Timeout = 20000;
  824. req.ReadWriteTimeout = 20000;
  825. Stream rs = req.GetRequestStream ();
  826. rs.Close ();
  827. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  828. StreamReader sr = new StreamReader (resp.GetResponseStream (),
  829. Encoding.UTF8);
  830. string body = sr.ReadToEnd ();
  831. Assert.AreEqual (resp.StatusCode, HttpStatusCode.OK, "#1");
  832. Assert.AreEqual (resp.ResponseUri.ToString (), "http://" +
  833. ep.ToString () + "/moved/", "#2");
  834. Assert.AreEqual ("WhatEver", resp.Method, "#3");
  835. Assert.AreEqual ("WhatEver", body, "#4");
  836. }
  837. responder.Stop ();
  838. }
  839. }
  840. [Test]
  841. [Category ("NotWorking")] // Assert #2 fails
  842. public void NotModiedSince ()
  843. {
  844. IPEndPoint ep = new IPEndPoint (IPAddress.Loopback, 8000);
  845. string url = "http://" + IPAddress.Loopback.ToString () + ":8000/test/";
  846. using (SocketResponder responder = new SocketResponder (ep, new SocketRequestHandler (NotModifiedSinceHandler))) {
  847. responder.Start ();
  848. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  849. req.Method = "GET";
  850. req.KeepAlive = false;
  851. req.Timeout = 20000;
  852. req.ReadWriteTimeout = 20000;
  853. #if NET_2_0
  854. req.Headers.Add (HttpRequestHeader.IfNoneMatch, "898bbr2347056cc2e096afc66e104653");
  855. #else
  856. req.Headers.Add ("If-None-Match", "898bbr2347056cc2e096afc66e104653");
  857. #endif
  858. req.IfModifiedSince = new DateTime (2010, 01, 04);
  859. DateTime start = DateTime.Now;
  860. HttpWebResponse response = null;
  861. try {
  862. req.GetResponse ();
  863. Assert.Fail ("#1");
  864. } catch (WebException e) {
  865. response = (HttpWebResponse) e.Response;
  866. }
  867. Assert.IsNotNull (response, "#2");
  868. using (Stream stream = response.GetResponseStream ()) {
  869. byte [] buffer = new byte [4096];
  870. int bytesRead = stream.Read (buffer, 0, buffer.Length);
  871. Assert.AreEqual (0, bytesRead, "#3");
  872. }
  873. TimeSpan elapsed = DateTime.Now - start;
  874. Assert.IsTrue (elapsed.TotalMilliseconds < 2000, "#4");
  875. responder.Stop ();
  876. }
  877. }
  878. #if NET_2_0
  879. [Test] // bug #324182
  880. #if TARGET_JVM
  881. [Category ("NotWorking")]
  882. #endif
  883. public void Stream_CanTimeout ()
  884. {
  885. IPEndPoint localEP = new IPEndPoint (IPAddress.Loopback, 8764);
  886. string url = "http://" + localEP.ToString () + "/original/";
  887. // allow autoredirect
  888. using (SocketResponder responder = new SocketResponder (localEP, new SocketRequestHandler (RedirectRequestHandler))) {
  889. responder.Start ();
  890. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (url);
  891. req.Method = "POST";
  892. req.Timeout = 2000;
  893. req.ReadWriteTimeout = 2000;
  894. req.KeepAlive = false;
  895. Stream rs = req.GetRequestStream ();
  896. Assert.IsTrue (rs.CanTimeout, "#1");
  897. rs.Close ();
  898. using (HttpWebResponse resp = (HttpWebResponse) req.GetResponse ()) {
  899. Stream os = resp.GetResponseStream ();
  900. Assert.IsTrue (os.CanTimeout, "#2");
  901. os.Close ();
  902. }
  903. responder.Stop ();
  904. }
  905. }
  906. #endif
  907. [Test] // bug #353495
  908. [Category ("NotWorking")]
  909. public void LastModifiedKind ()
  910. {
  911. const string reqURL = "http://coffeefaq.com/site/node/25";
  912. HttpWebRequest req = (HttpWebRequest) WebRequest.Create (reqURL);
  913. HttpWebResponse resp = (HttpWebResponse) req.GetResponse ();
  914. DateTime lastMod = resp.LastModified;
  915. string rawLastMod = resp.Headers ["Last-Modified"];
  916. resp.Close ();
  917. //Assert.AreEqual ("Tue, 15 Jan 2008 08:59:59 GMT", rawLastMod, "#1");
  918. #if NET_2_0
  919. Assert.AreEqual (DateTimeKind.Local, lastMod.Kind, "#2");
  920. #endif
  921. req = (HttpWebRequest) WebRequest.Create (reqURL);
  922. req.IfModifiedSince = lastMod;
  923. try {
  924. resp = (HttpWebResponse) req.GetResponse ();
  925. resp.Close ();
  926. Assert.Fail ("Should result in 304");
  927. } catch (WebException ex) {
  928. Assert.AreEqual (WebExceptionStatus.ProtocolError, ex.Status, "#3");
  929. Assert.AreEqual (((HttpWebResponse) ex.Response).StatusCode, HttpStatusCode.NotModified, "#4");
  930. }
  931. }
  932. static byte [] EchoRequestHandler (Socket socket)
  933. {
  934. MemoryStream ms = new MemoryStream ();
  935. byte [] buffer = new byte [4096];
  936. int bytesReceived = socket.Receive (buffer);
  937. while (bytesReceived > 0) {
  938. ms.Write (buffer, 0, bytesReceived);
  939. if (socket.Available > 0) {
  940. bytesReceived = socket.Receive (buffer);
  941. } else {
  942. bytesReceived = 0;
  943. }
  944. }
  945. ms.Flush ();
  946. ms.Position = 0;
  947. StreamReader sr = new StreamReader (ms, Encoding.UTF8);
  948. string request = sr.ReadToEnd ();
  949. StringWriter sw = new StringWriter ();
  950. sw.WriteLine ("HTTP/1.1 200 OK");
  951. sw.WriteLine ("Content-Type: text/xml");
  952. sw.WriteLine ("Content-Length: " + request.Length.ToString (CultureInfo.InvariantCulture));
  953. sw.WriteLine ();
  954. sw.Write (request);
  955. sw.Flush ();
  956. return Encoding.UTF8.GetBytes (sw.ToString ());
  957. }
  958. static byte [] RedirectRequestHandler (Socket socket)
  959. {
  960. MemoryStream ms = new MemoryStream ();
  961. byte [] buffer = new byte [4096];
  962. int bytesReceived = socket.Receive (buffer);
  963. while (bytesReceived > 0) {
  964. ms.Write (buffer, 0, bytesReceived);
  965. if (socket.Available > 0) {
  966. bytesReceived = socket.Receive (buffer);
  967. } else {
  968. bytesReceived = 0;
  969. }
  970. }
  971. ms.Flush ();
  972. ms.Position = 0;
  973. string statusLine = null;
  974. using (StreamReader sr = new StreamReader (ms, Encoding.UTF8)) {
  975. statusLine = sr.ReadLine ();
  976. }
  977. StringWriter sw = new StringWriter ();
  978. if (statusLine.StartsWith ("POST /original/")) {
  979. sw.WriteLine ("HTTP/1.0 302 Found");
  980. sw.WriteLine ("Location: " + "http://" + IPAddress.Loopback.ToString () + ":8764/moved/");
  981. sw.WriteLine ();
  982. sw.Flush ();
  983. } else if (statusLine.StartsWith ("GET /moved/")) {
  984. sw.WriteLine ("HTTP/1.0 200 OK");
  985. sw.WriteLine ("Content-Type: text/plain");
  986. sw.WriteLine ("Content-Length: 8");
  987. sw.WriteLine ();
  988. sw.Write ("LOOKS OK");
  989. sw.Flush ();
  990. } else {
  991. sw.WriteLine ("HTTP/1.0 500 Too Lazy");
  992. sw.WriteLine ();
  993. sw.Flush ();
  994. }
  995. return Encoding.UTF8.GetBytes (sw.ToString ());
  996. }
  997. static byte [] InternalErrorHandler (Socket socket)
  998. {
  999. StringWriter sw = new StringWriter ();
  1000. sw.WriteLine ("HTTP/1.1 500 Too Lazy");
  1001. sw.WriteLine ("Content-Length: 0");
  1002. sw.WriteLine ();
  1003. sw.Flush ();
  1004. return Encoding.UTF8.GetBytes (sw.ToString ());
  1005. }
  1006. static byte [] NoContentLengthHandler (Socket socket)
  1007. {
  1008. StringWriter sw = new StringWriter ();
  1009. sw.WriteLine ("HTTP/1.1 500 Too Lazy");
  1010. sw.WriteLine ();
  1011. sw.Flush ();
  1012. return Encoding.UTF8.GetBytes (sw.ToString ());
  1013. }
  1014. static byte [] NotModifiedSinceHandler (Socket socket)
  1015. {
  1016. StringWriter sw = new StringWriter ();
  1017. sw.WriteLine ("HTTP/1.1 304 Not Modified");
  1018. sw.WriteLine ("Date: Fri, 06 Feb 2009 12:50:26 GMT");
  1019. sw.WriteLine ("Server: Apache/2.2.6 (Debian) PHP/5.2.6-2+b1 with Suhosin-Patch mod_ssl/2.2.6 OpenSSL/0.9.8g");
  1020. sw.WriteLine ("Not-Modified-Since: Sun, 08 Feb 2009 08:49:26 GMT");
  1021. sw.WriteLine ("ETag: 898bbr2347056cc2e096afc66e104653");
  1022. sw.WriteLine ("Connection: close");
  1023. sw.WriteLine ();
  1024. sw.Flush ();
  1025. return Encoding.UTF8.GetBytes (sw.ToString ());
  1026. }
  1027. static byte [] VerbEchoHandler (Socket socket)
  1028. {
  1029. MemoryStream ms = new MemoryStream ();
  1030. byte [] buffer = new byte [4096];
  1031. int bytesReceived = socket.Receive (buffer);
  1032. while (bytesReceived > 0) {
  1033. ms.Write (buffer, 0, bytesReceived);
  1034. if (socket.Available > 0) {
  1035. bytesReceived = socket.Receive (buffer);
  1036. } else {
  1037. bytesReceived = 0;
  1038. }
  1039. }
  1040. ms.Flush ();
  1041. ms.Position = 0;
  1042. string statusLine = null;
  1043. using (StreamReader sr = new StreamReader (ms, Encoding.UTF8)) {
  1044. statusLine = sr.ReadLine ();
  1045. }
  1046. string verb = "DEFAULT";
  1047. if (statusLine != null) {
  1048. string [] parts = statusLine.Split (' ');
  1049. if (parts.Length > 0)
  1050. verb = parts [0];
  1051. }
  1052. StringWriter sw = new StringWriter ();
  1053. sw.WriteLine ("HTTP/1.1 200 OK");
  1054. sw.WriteLine ("Content-Type: text/plain");
  1055. sw.WriteLine ("Content-Length: " + verb.Length);
  1056. sw.WriteLine ();
  1057. sw.Write (verb);
  1058. sw.Flush ();
  1059. return Encoding.UTF8.GetBytes (sw.ToString ());
  1060. }
  1061. [Test]
  1062. public void NtlmAuthentication ()
  1063. {
  1064. NtlmServer server = new NtlmServer ();
  1065. server.Start ();
  1066. string url = String.Format ("http://{0}:{1}/nothing.html", server.IPAddress, server.Port);
  1067. HttpWebRequest request = (HttpWebRequest) WebRequest.Create (url);
  1068. request.Timeout = 5000;
  1069. request.Credentials = new NetworkCredential ("user", "password", "domain");
  1070. HttpWebResponse resp = (HttpWebResponse) request.GetResponse ();
  1071. string res = null;
  1072. using (StreamReader reader = new StreamReader (resp.GetResponseStream ())) {
  1073. res = reader.ReadToEnd ();
  1074. }
  1075. resp.Close ();
  1076. server.Stop ();
  1077. Assert.AreEqual ("OK", res);
  1078. }
  1079. class NtlmServer : HttpServer {
  1080. public string Where = "";
  1081. protected override void Run ()
  1082. {
  1083. Where = "before accept";
  1084. Socket client = sock.Accept ();
  1085. NetworkStream ns = new NetworkStream (client, false);
  1086. StreamReader reader = new StreamReader (ns, Encoding.ASCII);
  1087. string line;
  1088. Where = "first read";
  1089. while ((line = reader.ReadLine ()) != null) {
  1090. if (line.Trim () == String.Empty) {
  1091. break;
  1092. }
  1093. }
  1094. Where = "first write";
  1095. StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
  1096. writer.Write ( "HTTP/1.1 401 Unauthorized\r\n" +
  1097. "WWW-Authenticate: NTLM\r\n" +
  1098. "Content-Length: 5\r\n\r\nWRONG");
  1099. writer.Flush ();
  1100. Where = "second read";
  1101. while ((line = reader.ReadLine ()) != null) {
  1102. if (line.Trim () == String.Empty) {
  1103. break;
  1104. }
  1105. }
  1106. Where = "second write";
  1107. writer.Write ( "HTTP/1.1 401 Unauthorized\r\n" +
  1108. "WWW-Authenticate: NTLM TlRMTVNTUAACAAAAAAAAADgAAAABggAC8GDhqIONH3sAAAAAAAAAAAAAAAA4AAAABQLODgAAAA8=\r\n" +
  1109. "Content-Length: 5\r\n\r\nWRONG");
  1110. writer.Flush ();
  1111. Where = "third read";
  1112. while ((line = reader.ReadLine ()) != null) {
  1113. if (line.Trim () == String.Empty) {
  1114. break;
  1115. }
  1116. }
  1117. Where = "third write";
  1118. writer.Write ( "HTTP/1.1 200 OK\r\n" +
  1119. "Keep-Alive: true\r\n" +
  1120. "Content-Length: 2\r\n\r\nOK");
  1121. writer.Flush ();
  1122. Thread.Sleep (1000);
  1123. writer.Close ();
  1124. reader.Close ();
  1125. client.Close ();
  1126. }
  1127. }
  1128. class BadChunkedServer : HttpServer {
  1129. protected override void Run ()
  1130. {
  1131. Socket client = sock.Accept ();
  1132. NetworkStream ns = new NetworkStream (client, true);
  1133. StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
  1134. writer.Write ( "HTTP/1.1 200 OK\r\n" +
  1135. "Transfer-Encoding: chunked\r\n" +
  1136. "Connection: close\r\n" +
  1137. "Content-Type: text/plain; charset=UTF-8\r\n\r\n");
  1138. // This body lacks a 'last-chunk' (see RFC 2616)
  1139. writer.Write ("10\r\n1234567890123456\r\n");
  1140. writer.Flush ();
  1141. client.Shutdown (SocketShutdown.Send);
  1142. Thread.Sleep (1000);
  1143. writer.Close ();
  1144. }
  1145. }
  1146. class AcceptAllPolicy : ICertificatePolicy {
  1147. public bool CheckValidationResult (ServicePoint sp, X509Certificate certificate, WebRequest request, int error)
  1148. {
  1149. return true;
  1150. }
  1151. }
  1152. abstract class HttpServer
  1153. {
  1154. protected Socket sock;
  1155. protected Exception error;
  1156. protected ManualResetEvent evt;
  1157. public HttpServer ()
  1158. {
  1159. sock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  1160. sock.Bind (new IPEndPoint (IPAddress.Loopback, 0));
  1161. sock.Listen (1);
  1162. }
  1163. public void Start ()
  1164. {
  1165. evt = new ManualResetEvent (false);
  1166. Thread th = new Thread (new ThreadStart (Run));
  1167. th.Start ();
  1168. }
  1169. public void Stop ()
  1170. {
  1171. evt.Set ();
  1172. sock.Close ();
  1173. }
  1174. public IPAddress IPAddress {
  1175. get { return ((IPEndPoint) sock.LocalEndPoint).Address; }
  1176. }
  1177. public int Port {
  1178. get { return ((IPEndPoint) sock.LocalEndPoint).Port; }
  1179. }
  1180. public Exception Error {
  1181. get { return error; }
  1182. }
  1183. protected abstract void Run ();
  1184. }
  1185. #if !TARGET_JVM
  1186. class SslHttpServer : HttpServer {
  1187. X509Certificate _certificate;
  1188. protected override void Run ()
  1189. {
  1190. try {
  1191. Socket client = sock.Accept ();
  1192. NetworkStream ns = new NetworkStream (client, true);
  1193. SslServerStream s = new SslServerStream (ns, Certificate, false, false);
  1194. s.PrivateKeyCertSelectionDelegate += new PrivateKeySelectionCallback (GetPrivateKey);
  1195. StreamReader reader = new StreamReader (s);
  1196. StreamWriter writer = new StreamWriter (s, Encoding.ASCII);
  1197. string line;
  1198. string hello = "<html><body><h1>Hello World!</h1></body></html>";
  1199. string answer = "HTTP/1.0 200\r\n" +
  1200. "Connection: close\r\n" +
  1201. "Content-Type: text/html\r\n" +
  1202. "Content-Encoding: " + Encoding.ASCII.WebName + "\r\n" +
  1203. "Content-Length: " + hello.Length + "\r\n" +
  1204. "\r\n" + hello;
  1205. // Read the headers
  1206. do {
  1207. line = reader.ReadLine ();
  1208. } while (line != "" && line != null && line.Length > 0);
  1209. // Now the content. We know it's 100 bytes.
  1210. // This makes BeginRead in sslclientstream block.
  1211. char [] cs = new char [100];
  1212. reader.Read (cs, 0, 100);
  1213. writer.Write (answer);
  1214. writer.Flush ();
  1215. evt.WaitOne (50000, false);
  1216. } catch (Exception e) {
  1217. error = e;
  1218. }
  1219. }
  1220. X509Certificate Certificate {
  1221. get {
  1222. if (_certificate == null)
  1223. _certificate = new X509Certificate (CertData.Certificate);
  1224. return _certificate;
  1225. }
  1226. }
  1227. AsymmetricAlgorithm GetPrivateKey (X509Certificate certificate, string targetHost)
  1228. {
  1229. PrivateKey key = new PrivateKey (CertData.PrivateKey, null);
  1230. return key.RSA;
  1231. }
  1232. }
  1233. class CertData {
  1234. public readonly static byte [] Certificate = {
  1235. 48, 130, 1, 191, 48, 130, 1, 40, 160, 3, 2, 1, 2, 2, 16, 36,
  1236. 14, 97, 190, 146, 132, 208, 71, 175, 6, 87, 168, 185, 175, 55, 43, 48,
  1237. 13, 6, 9, 42, 134, 72, 134, 247, 13, 1, 1, 4, 5, 0, 48, 18,
  1238. 49, 16, 48, 14, 6, 3, 85, 4, 3, 19, 7, 103, 111, 110, 122, 97,
  1239. 108, 111, 48, 30, 23, 13, 48, 53, 48, 54, 50, 50, 49, 57, 51, 48,
  1240. 52, 54, 90, 23, 13, 51, 57, 49, 50, 51, 49, 50, 51, 53, 57, 53,
  1241. 57, 90, 48, 18, 49, 16, 48, 14, 6, 3, 85, 4, 3, 19, 7, 103,
  1242. 111, 110, 122, 97, 108, 111, 48, 129, 158, 48, 13, 6, 9, 42, 134, 72,
  1243. 134, 247, 13, 1, 1, 1, 5, 0, 3, 129, 140, 0, 48, 129, 136, 2,
  1244. 129, 129, 0, 138, 9, 38, 25, 166, 252, 59, 26, 39, 184, 128, 216, 38,
  1245. 73, 41, 86, 30, 228, 160, 205, 41, 135, 115, 223, 44, 62, 42, 198, 178,
  1246. 190, 81, 11, 25, 21, 216, 49, 179, 130, 246, 52, 97, 175, 212, 94, 157,
  1247. 231, 162, 66, 161, 103, 63, 204, 83, 141, 172, 119, 97, 225, 206, 98, 101,
  1248. 210, 106, 2, 206, 81, 90, 173, 47, 41, 199, 209, 241, 177, 177, 96, 207,
  1249. 254, 220, 190, 66, 180, 153, 0, 209, 14, 178, 69, 194, 3, 37, 116, 239,
  1250. 49, 23, 185, 245, 255, 126, 35, 85, 246, 56, 244, 107, 117, 24, 14, 57,
  1251. 9, 111, 147, 189, 220, 142, 57, 104, 153, 193, 205, 19, 14, 22, 157, 16,
  1252. 24, 80, 201, 2, 2, 0, 17, 163, 23, 48, 21, 48, 19, 6, 3, 85,
  1253. 29, 37, 4, 12, 48, 10, 6, 8, 43, 6, 1, 5, 5, 7, 3, 1,
  1254. 48, 13, 6, 9, 42, 134, 72, 134, 247, 13, 1, 1, 4, 5, 0, 3,
  1255. 129, 129, 0, 64, 49, 57, 253, 218, 198, 229, 51, 189, 12, 154, 225, 183,
  1256. 160, 147, 90, 113, 172, 69, 122, 28, 77, 97, 215, 231, 194, 150, 29, 196,
  1257. 65, 95, 218, 99, 142, 111, 79, 205, 109, 76, 32, 92, 220, 76, 88, 53,
  1258. 237, 80, 11, 85, 44, 91, 21, 210, 12, 34, 223, 234, 18, 187, 136, 62,
  1259. 26, 240, 103, 180, 12, 226, 221, 250, 247, 129, 51, 23, 129, 165, 56, 67,
  1260. 43, 83, 244, 110, 207, 24, 253, 195, 16, 46, 80, 113, 80, 18, 2, 254,
  1261. 120, 147, 151, 164, 23, 210, 230, 100, 19, 197, 179, 28, 194, 48, 106, 159,
  1262. 155, 144, 37, 82, 44, 160, 40, 52, 146, 174, 77, 188, 160, 230, 75, 172,
  1263. 123, 3, 254,
  1264. };
  1265. public readonly static byte [] PrivateKey = {
  1266. 30, 241, 181, 176, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0,
  1267. 0, 0, 0, 0, 84, 2, 0, 0, 7, 2, 0, 0, 0, 36, 0, 0,
  1268. 82, 83, 65, 50, 0, 4, 0, 0, 17, 0, 0, 0, 201, 80, 24, 16,
  1269. 157, 22, 14, 19, 205, 193, 153, 104, 57, 142, 220, 189, 147, 111, 9, 57,
  1270. 14, 24, 117, 107, 244, 56, 246, 85, 35, 126, 255, 245, 185, 23, 49, 239,
  1271. 116, 37, 3, 194, 69, 178, 14, 209, 0, 153, 180, 66, 190, 220, 254, 207,
  1272. 96, 177, 177, 241, 209, 199, 41, 47, 173, 90, 81, 206, 2, 106, 210, 101,
  1273. 98, 206, 225, 97, 119, 172, 141, 83, 204, 63, 103, 161, 66, 162, 231, 157,
  1274. 94, 212, 175, 97, 52, 246, 130, 179, 49, 216, 21, 25, 11, 81, 190, 178,
  1275. 198, 42, 62, 44, 223, 115, 135, 41, 205, 160, 228, 30, 86, 41, 73, 38,
  1276. 216, 128, 184, 39, 26, 59, 252, 166, 25, 38, 9, 138, 175, 88, 190, 223,
  1277. 27, 24, 224, 123, 190, 69, 164, 234, 129, 59, 108, 229, 248, 62, 187, 15,
  1278. 235, 147, 162, 83, 47, 123, 170, 190, 224, 31, 215, 110, 143, 31, 227, 216,
  1279. 85, 88, 154, 83, 207, 229, 41, 28, 237, 116, 181, 17, 37, 141, 224, 185,
  1280. 164, 144, 141, 233, 164, 138, 177, 241, 115, 181, 230, 150, 7, 92, 139, 141,
  1281. 113, 95, 57, 191, 211, 165, 217, 250, 197, 68, 164, 184, 168, 43, 48, 65,
  1282. 177, 237, 173, 144, 148, 221, 62, 189, 147, 63, 216, 188, 206, 103, 226, 171,
  1283. 32, 20, 230, 116, 144, 192, 1, 39, 202, 87, 74, 250, 6, 142, 188, 23,
  1284. 45, 4, 112, 191, 253, 67, 69, 70, 128, 143, 44, 234, 41, 96, 195, 82,
  1285. 202, 35, 158, 149, 240, 151, 23, 25, 166, 179, 85, 144, 58, 120, 149, 229,
  1286. 205, 34, 8, 110, 86, 119, 130, 210, 37, 173, 65, 71, 169, 67, 8, 51,
  1287. 20, 96, 51, 155, 3, 39, 85, 187, 40, 193, 57, 19, 99, 78, 173, 28,
  1288. 129, 154, 108, 175, 8, 138, 237, 71, 27, 148, 129, 35, 47, 57, 101, 237,
  1289. 168, 178, 227, 221, 212, 63, 124, 254, 253, 215, 183, 159, 49, 103, 74, 49,
  1290. 67, 160, 171, 72, 194, 215, 108, 251, 178, 18, 184, 100, 211, 105, 21, 186,
  1291. 39, 66, 218, 154, 72, 222, 90, 237, 179, 251, 51, 224, 212, 56, 251, 6,
  1292. 209, 151, 198, 176, 89, 110, 35, 141, 248, 237, 223, 68, 135, 206, 207, 169,
  1293. 254, 219, 243, 130, 71, 11, 94, 113, 233, 92, 63, 156, 169, 72, 215, 110,
  1294. 95, 94, 191, 50, 59, 89, 187, 59, 183, 99, 161, 146, 233, 245, 219, 80,
  1295. 87, 113, 251, 50, 144, 195, 158, 46, 189, 232, 119, 91, 75, 22, 6, 176,
  1296. 39, 206, 25, 196, 213, 195, 219, 24, 28, 103, 104, 36, 137, 128, 4, 119,
  1297. 163, 40, 126, 87, 18, 86, 128, 243, 213, 101, 2, 237, 78, 64, 160, 55,
  1298. 199, 93, 90, 126, 175, 199, 55, 89, 234, 190, 5, 16, 196, 88, 28, 208,
  1299. 28, 92, 32, 115, 204, 9, 202, 101, 15, 123, 43, 75, 90, 144, 95, 179,
  1300. 102, 249, 57, 150, 204, 99, 147, 203, 16, 63, 81, 244, 226, 237, 82, 204,
  1301. 20, 200, 140, 65, 83, 217, 161, 23, 123, 37, 115, 12, 100, 73, 70, 190,
  1302. 32, 235, 174, 140, 148, 157, 47, 238, 40, 208, 228, 80, 54, 187, 156, 252,
  1303. 253, 230, 231, 156, 138, 125, 96, 79, 3, 27, 143, 55, 146, 169, 165, 61,
  1304. 238, 60, 227, 77, 217, 93, 117, 122, 111, 46, 173, 113,
  1305. };
  1306. }
  1307. #endif
  1308. }
  1309. }