2
0

HttpServer.cs 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915
  1. //==========================================================================
  2. // File: HttpServer.cs
  3. //
  4. // Summary: Implements an HttpServer to be used by the HttpServerChannel class
  5. //
  6. //
  7. // Classes: internal sealed HttpServer
  8. // internal sealed ReqMessageParser
  9. // private RequestArguments
  10. //
  11. // By :
  12. // Ahmad Tantawy [email protected]
  13. // Ahmad Kadry [email protected]
  14. // Hussein Mehanna [email protected]
  15. //
  16. //==========================================================================
  17. using System;
  18. using System.Net.Sockets;
  19. using System.Text;
  20. using System.Text.RegularExpressions;
  21. using System.Collections;
  22. using System.Runtime.Remoting.Channels;
  23. using System.IO;
  24. using System.Net;
  25. using System.Runtime.Remoting.Messaging;
  26. namespace System.Runtime.Remoting.Channels.Http
  27. {
  28. internal class RequestArguments
  29. {
  30. public RequestArguments (Socket socket, HttpServerTransportSink sink)
  31. {
  32. NetworkStream ns = new NetworkStream (socket);
  33. InputStream = ns;
  34. OutputStream = ns;
  35. Sink = sink;
  36. }
  37. public RequestArguments (Stream inputStream, Stream outputStream, HttpServerTransportSink sink)
  38. {
  39. InputStream = inputStream;
  40. OutputStream = outputStream;
  41. Sink = sink;
  42. }
  43. public Stream InputStream;
  44. public Stream OutputStream;
  45. public HttpServerTransportSink Sink;
  46. }
  47. internal sealed class HttpServer
  48. {
  49. private TcpListener listener=null;
  50. private const int nTimeOut = 1000;
  51. public HttpServer(int port)
  52. {
  53. try
  54. {
  55. listener = new TcpListener(port);
  56. }
  57. catch(NullReferenceException)
  58. {
  59. Console.WriteLine("The port is bound to another application");
  60. }
  61. }
  62. public static void ProcessRequest (object reqInfo)
  63. {
  64. if(reqInfo as RequestArguments == null)
  65. return;
  66. RequestArguments reqArg = (RequestArguments)reqInfo;
  67. //Step (1) Start Reciceve the header
  68. ArrayList Headers = RecieveHeader (reqArg);
  69. //Step (2) Start Parse the header
  70. IDictionary HeaderFields = new Hashtable();
  71. IDictionary CustomHeaders = new Hashtable();
  72. if (!ParseHeader (reqArg, Headers, HeaderFields, CustomHeaders))
  73. return;
  74. //Step (3)
  75. if (!CheckRequest (reqArg, HeaderFields, CustomHeaders))
  76. return;
  77. //Step (4) Recieve the entity body
  78. byte [] buffer =new byte[(int)HeaderFields["content-length"]];
  79. if (!RecieveEntityBody (reqArg, buffer))
  80. return ;
  81. //Step (5)
  82. SendRequestForChannel (reqArg, HeaderFields, CustomHeaders, buffer);
  83. }
  84. private static ArrayList RecieveHeader (RequestArguments reqArg)
  85. {
  86. bool bLastLine = false;
  87. bool bEndOfLine = false;
  88. byte[] buffer = new byte[1024];
  89. ArrayList Headers = new ArrayList();
  90. Stream ist = reqArg.InputStream;
  91. int index =0;
  92. while (!bLastLine)
  93. {
  94. //recieve line by line
  95. index = 0;
  96. bEndOfLine = false;
  97. //Step (1) is it an empty line?
  98. ist.Read (buffer, index, 1);
  99. if(buffer[index++]==13)
  100. {
  101. ist.Read (buffer, index, 1);
  102. bLastLine=true;
  103. bEndOfLine = true;
  104. }
  105. //Step (2) recieve line bytes
  106. while (!bEndOfLine)
  107. {
  108. ist.Read (buffer, index, 1);
  109. if(buffer [index++]==13)
  110. {
  111. bEndOfLine = true;
  112. ist.Read (buffer,index,1);
  113. }
  114. }
  115. //Step (3) convert bytes to a string
  116. if (bLastLine)
  117. continue;
  118. Headers.Add (Encoding.ASCII.GetString (buffer,0,index));
  119. }//end while loop
  120. return Headers;
  121. }
  122. private static bool ParseHeader (RequestArguments reqArg, ArrayList Headers, IDictionary HeaderFields, IDictionary CustomHeaders)
  123. {
  124. for (int i=0;i<Headers.Count;i++)
  125. {
  126. if (ReqMessageParser.ParseHeaderField ((string)Headers[i],HeaderFields))
  127. continue;
  128. if (!ReqMessageParser.IsCustomHeader((string)Headers[i],CustomHeaders ) )
  129. {
  130. SendResponse (reqArg, 400, null, null);
  131. return false;
  132. }
  133. }
  134. return true;
  135. }
  136. private static bool CheckRequest (RequestArguments reqArg, IDictionary HeaderFields, IDictionary CustomHeaders)
  137. {
  138. string temp;
  139. //Check the method
  140. temp = HeaderFields["method"].ToString();
  141. if (temp!="POST")
  142. {
  143. SendResponse (reqArg, 501, null, null);
  144. return false;
  145. }
  146. if (HeaderFields["expect"].ToString() == "100-continue")
  147. SendResponse (reqArg, 100, null, null);
  148. //Check for the content-length field
  149. if (HeaderFields["content-length"]==null)
  150. {
  151. SendResponse (reqArg, 411, null, null);
  152. return false;
  153. }
  154. return true;
  155. }
  156. private static bool RecieveEntityBody (RequestArguments reqArg, byte[] buffer)
  157. {
  158. try
  159. {
  160. int nr = 0;
  161. while (nr < buffer.Length)
  162. nr += reqArg.InputStream.Read (buffer, nr, buffer.Length - nr);
  163. }
  164. catch (SocketException e)
  165. {
  166. switch(e.ErrorCode)
  167. {
  168. case 10060 : //TimeOut
  169. SendResponse (reqArg, 408, null, null);
  170. break;
  171. default :
  172. //<Exception>
  173. break;
  174. }
  175. return false;
  176. }//end catch
  177. return true;
  178. }
  179. private static bool SendRequestForChannel (RequestArguments reqArg, IDictionary HeaderFields, IDictionary CustomHeaders, byte[] buffer)
  180. {
  181. TransportHeaders THeaders = new TransportHeaders();
  182. Stream stream = new MemoryStream(buffer);
  183. if(stream.Position !=0)
  184. stream.Seek(0,SeekOrigin.Begin);
  185. //These two headers are sent to the Soap Formatter
  186. //IF the Soap formatter on mono will need them , then uncomment them.
  187. //THeaders["__ConnectionId"] = Int64.Parse("1");
  188. //THeaders["__IPAddress"]= ((IPEndPoint)socket.RemoteEndPoint).Address;
  189. THeaders["__RequestUri"] = FixURI((string)HeaderFields["request-url"]);
  190. THeaders["Content-Type"]= HeaderFields["content-type"];
  191. THeaders["__RequestVerb"]= HeaderFields["method"];
  192. THeaders["__HttpVersion"] = HeaderFields["http-version"];
  193. THeaders["User-Agent"] = HeaderFields["user-agent"];
  194. THeaders["Host"] = HeaderFields["host"];
  195. foreach(DictionaryEntry DictEntry in CustomHeaders)
  196. {
  197. THeaders[DictEntry.Key.ToString()] = DictEntry.Value.ToString();
  198. }
  199. reqArg.Sink.ServiceRequest (reqArg, stream, THeaders);
  200. return true;
  201. }
  202. private static string FixURI(string RequestURI)
  203. {
  204. if(RequestURI.IndexOf ( '.' ) == -1)
  205. return RequestURI;
  206. else
  207. return RequestURI.Substring(1);
  208. }
  209. public static bool SendResponse (RequestArguments reqArg, int HttpStatusCode, ITransportHeaders headers , Stream responseStream)
  210. {
  211. byte [] headersBuffer = null;
  212. byte [] entityBuffer = null;
  213. StringBuilder ResponseStr;
  214. String Reason = GetReasonPhrase(HttpStatusCode);
  215. if (headers != null && headers["__HttpStatusCode"] != null) {
  216. // The formatter can override the result code
  217. HttpStatusCode = int.Parse ((string)headers["__HttpStatusCode"]);
  218. Reason = (string)headers["__HttpReasonPhrase"];
  219. }
  220. //Response Line
  221. ResponseStr = new StringBuilder( "HTTP/1.0 " + HttpStatusCode + " " + Reason + "\r\n" );
  222. if(headers!=null)
  223. foreach(DictionaryEntry entry in headers)
  224. {
  225. string key = entry.Key.ToString();
  226. if (key != "__HttpStatusCode" && key != "__HttpReasonPhrase")
  227. ResponseStr.Append(key + ": " + entry.Value.ToString() + "\r\n");
  228. }
  229. ResponseStr.Append("Server: Mono Remoting, Mono CLR " + System.Environment.Version.ToString() + "\r\n");
  230. if(responseStream != null)
  231. if(responseStream.Length!=0)
  232. {
  233. ResponseStr.Append("Content-Length: "+responseStream.Length.ToString()+"\r\n");
  234. entityBuffer = new byte[responseStream.Length];
  235. responseStream.Seek(0 , SeekOrigin.Begin);
  236. responseStream.Read(entityBuffer,0,entityBuffer.Length);
  237. }
  238. ResponseStr.Append("\r\n");
  239. headersBuffer = Encoding.ASCII.GetBytes (ResponseStr.ToString());
  240. try
  241. {
  242. //send headersBuffer
  243. reqArg.OutputStream.Write (headersBuffer, 0, headersBuffer.Length);
  244. if (entityBuffer != null)
  245. reqArg.OutputStream.Write (entityBuffer, 0, entityBuffer.Length);
  246. }
  247. catch (SocketException )
  248. {
  249. //<EXCEPTION>
  250. //may be its the client's fault so just return with false
  251. return false;
  252. }
  253. return true;
  254. }
  255. public static bool SendResponse(Socket socket , int HttpStatusCode ,string ReasonPhrase, ITransportHeaders headers , Stream responseStream )
  256. {
  257. return true;
  258. }
  259. internal static string GetReasonPhrase(int HttpStatusCode)
  260. {
  261. switch (HttpStatusCode)
  262. {
  263. case 100 : return "Continue" ;
  264. case 101 :return "Switching Protocols";
  265. case 200 :return "OK";
  266. case 201 :return "Created";
  267. case 202 :return "Accepted";
  268. case 203 :return "Non-Authoritative Information";
  269. case 204 :return "No Content";
  270. case 205 :return "Reset Content";
  271. case 206 :return "Partial Content";
  272. case 300 :return "Multiple Choices";
  273. case 301 :return "Moved Permanently";
  274. case 302 :return "Found";
  275. case 303 :return "See Other";
  276. case 304 :return "Not Modified";
  277. case 305 :return "Use Proxy";
  278. case 307 :return "Temporary Redirect";
  279. case 400 :return "Bad Request";
  280. case 401 :return "Unauthorized";
  281. case 402 :return "Payment Required";
  282. case 403 :return "Forbidden";
  283. case 404 :return "Not Found";
  284. case 405 :return "Method Not Allowed";
  285. case 406 :return "Not Acceptable";
  286. case 407 :return "Proxy Authentication Required";
  287. case 408 :return "Request Time-out";
  288. case 409 :return "Conflict";
  289. case 410 :return "Gone";
  290. case 411 :return "Length Required";
  291. case 412 :return "Precondition Failed";
  292. case 413 :return "Request Entity Too Large";
  293. case 414 :return "Request-URI Too Large";
  294. case 415 :return "Unsupported Media Type";
  295. case 416 :return "Requested range not satisfiable";
  296. case 417 :return "Expectation Failed";
  297. case 500 :return "Internal Server Error";
  298. case 501 :return "Not Implemented";
  299. case 502 :return "Bad Gateway";
  300. case 503 :return "Service Unavailable";
  301. case 504 :return "Gateway Time-out";
  302. case 505 :return "HTTP Version not supported";
  303. default: return "";
  304. }
  305. }
  306. }
  307. internal sealed class ReqMessageParser
  308. {
  309. private const int nCountReq = 14;
  310. private const int nCountEntity = 15;
  311. private static bool bInitialized = false;
  312. private static String [] ReqRegExpString = new String [nCountReq ];
  313. private static String [] EntityRegExpString = new String[nCountEntity];
  314. private static Regex [] ReqRegExp = new Regex[nCountReq];
  315. private static Regex [] EntityRegExp = new Regex[nCountEntity];
  316. public ReqMessageParser ()
  317. {
  318. }
  319. public static bool ParseHeaderField(string buffer,IDictionary headers)
  320. {
  321. try
  322. {
  323. if(!bInitialized)
  324. {
  325. Initialize();
  326. bInitialized =true;
  327. }
  328. if(IsRequestField(buffer,headers))
  329. return true;
  330. if(IsEntityField(buffer,headers))
  331. return true ;
  332. }
  333. catch(Exception )
  334. {
  335. //<Exception>
  336. }
  337. //Exception
  338. return false;
  339. }
  340. private static bool Initialize()
  341. {
  342. if(bInitialized)
  343. return true;
  344. bInitialized = true;
  345. //initialize array
  346. //Create all the Regular expressions
  347. InitializeRequestRegExp();
  348. InitiazeEntityRegExp();
  349. for(int i=0;i<nCountReq;i++)
  350. ReqRegExp[i] = new Regex(ReqRegExpString[i],RegexOptions.Compiled|RegexOptions.IgnoreCase);
  351. for(int i=0;i<nCountEntity;i++)
  352. EntityRegExp[i] = new Regex(EntityRegExpString[i],RegexOptions.Compiled|RegexOptions.IgnoreCase);
  353. return true;
  354. }
  355. private static void InitializeRequestRegExp()
  356. {
  357. //Request Header Fields
  358. //
  359. ReqRegExpString[0] = "^accept(\\s*:\\s*)(?<accept>\\S+)(\\s*|)(\\s*)$";
  360. ReqRegExpString[1] = "^accept-charset(\\s*:\\s*)(?<accept_charset>\\S+(\\s|\\S)*\\S)(\\s*)$";
  361. ReqRegExpString[2] = "^accept-encoding(\\s*:\\s*)(?<accept_Encoding>\\S+(\\s|\\S)*\\S)(\\s*)$";
  362. ReqRegExpString[3] = "^authorization(\\s*:\\s*)(?<authorization>\\S+(\\s|\\S)*\\S)(\\s*)$";
  363. ReqRegExpString[4] = "^accept-language(\\s*:\\s*)(?<accept_Language>\\S+(\\s|\\S)*\\S)(\\s*)$";
  364. ReqRegExpString[5] = "^from(\\s*:\\s*)(?<from>\\S+(\\s|\\S)*\\S)(\\s*)$";
  365. ReqRegExpString[6] = "^host(\\s*:\\s*)(?<host>\\S+(\\s|\\S)*\\S)(\\s*)$";
  366. ReqRegExpString[7] = "^if-modified-since(\\s*:\\s*)(?<if_modified>\\S+(\\s|\\S)*\\S)(\\s*)$";
  367. ReqRegExpString[8] = "^proxy-authorization(\\s*:\\s*)(?<proxy_auth>\\S+(\\s|\\S)*\\S)(\\s*)$";
  368. ReqRegExpString[9] = "^range(\\s*:\\s*)(?<range>\\S+(\\s|\\S)*\\S)(\\s*)$";
  369. ReqRegExpString[10] = "^user-agent(\\s*:\\s*)(?<user_agent>\\S+(\\s|\\S)*\\S)(\\s*)$";
  370. ReqRegExpString[11] = "^expect(\\s*:\\s*)(?<expect>\\S+(\\s|\\S)*\\S)(\\s*)$";
  371. ReqRegExpString[12] = "^connection(\\s*:\\s*)(?<connection>\\S+(\\s|\\S)*\\S)(\\s*)$";
  372. ReqRegExpString[13] = "^(?<method>\\w+)(\\s+)(?<request_url>\\S+)(\\s+)(?<http_version>\\S+)(\\s*)$";
  373. // ReqRegExpString[14] = "";
  374. }
  375. private static void InitiazeEntityRegExp()
  376. {
  377. EntityRegExpString[0] = "^allow(\\s*:\\s*)(?<allow>[0-9]+)(\\s*)$";
  378. EntityRegExpString[1] = "^content-encoding(\\s*:\\s*)(?<content_encoding>\\S+(\\s|\\S)*\\S)(\\s*)$";
  379. EntityRegExpString[2] = "^content-language(\\s*:\\s*)(?<content_language>\\S+(\\s|\\S)*\\S)(\\s*)$";
  380. EntityRegExpString[3] = "^content-length(\\s*:\\s*)(?<content_length>[0-9]+)(\\s*)$";
  381. EntityRegExpString[4] = "^content-range(\\s*:\\s*)(?<content_range>\\S+(\\s|\\S)*\\S)(\\s*)$";
  382. EntityRegExpString[5] = "^content-type(\\s*:\\s*)(?<content_type>\\S+(\\s|\\S)*\\S)(\\s*)$";
  383. EntityRegExpString[6] = "^content-version(\\s*:\\s*)(?<content_version>\\S+(\\s|\\S)*\\S)(\\s*)$";
  384. EntityRegExpString[7] = "^derived-from(\\s*:\\s*)(?<derived_from>\\S+(\\s|\\S)*\\S)(\\s*)$";
  385. EntityRegExpString[8] = "^expires(\\s*:\\s*)(?<expires>\\S+(\\s|\\S)*\\S)(\\s*)$";//date
  386. EntityRegExpString[9] = "^last-modified(\\s*:\\s*)(?<last_modified>\\S+(\\s|\\S)*\\S)(\\s*)$";//date
  387. EntityRegExpString[10] = "^link(\\s*:\\s*)(?<link>\\S+(\\s|\\S)*\\S)(\\s*)$";
  388. EntityRegExpString[11] = "^title(\\s*:\\s*)(?<title>\\S+(\\s|\\S)*\\S)(\\s*)$";
  389. EntityRegExpString[12] = "^transfere-encoding(\\s*:\\s*)(?<transfere_encoding>\\S+(\\s|\\S)*\\S)(\\s*)$";
  390. EntityRegExpString[13] = "^url-header(\\s*:\\s*)(?<url_header>\\S+(\\s|\\S)*\\S)(\\s*)$";
  391. EntityRegExpString[14] = "^extension-header(\\s*:\\s*)(?<extension_header>\\S+(\\s|\\S)*\\S)(\\s*)$";
  392. }
  393. private static void CopyGroupNames(Regex regEx , Match m , IDictionary headers)
  394. {
  395. if(!m.Success)
  396. return;
  397. string [] ar = regEx.GetGroupNames();
  398. GroupCollection gc = m.Groups;
  399. for(int i=0;i<ar.Length;i++)
  400. {
  401. if(! char.IsLetter(ar[i],0))
  402. continue;
  403. headers.Add(ar[i],gc[ar[i]].Value);
  404. }
  405. }
  406. private static bool IsRequestField(string buffer , IDictionary HeaderItems)
  407. {
  408. if(Request_accept(buffer , HeaderItems))
  409. return true;
  410. if(Request_accept_charset(buffer , HeaderItems))
  411. return true;
  412. if(Request_accept_encoding(buffer , HeaderItems))
  413. return true;
  414. if(Request_accept_language(buffer , HeaderItems))
  415. return true;
  416. if(Request_authorization(buffer , HeaderItems))
  417. return true;
  418. if(Request_connection(buffer , HeaderItems))
  419. return true;
  420. if(Request_expect(buffer , HeaderItems))
  421. return true;
  422. if(Request_from(buffer , HeaderItems))
  423. return true;
  424. if(Request_host(buffer , HeaderItems))
  425. return true;
  426. if(Request_modified(buffer , HeaderItems))
  427. return true;
  428. if(Request_proxy_authorization(buffer , HeaderItems))
  429. return true;
  430. if(Request_user_agent(buffer , HeaderItems))
  431. return true;
  432. if(Request_request_line(buffer , HeaderItems))
  433. return true;
  434. return false;
  435. }
  436. private static bool IsEntityField(string buffer , IDictionary HeaderItems)
  437. {
  438. if(Entity_allow(buffer , HeaderItems))
  439. return true;
  440. if(Entity_content_encoding(buffer , HeaderItems))
  441. return true;
  442. if(Entity_content_language(buffer , HeaderItems))
  443. return true;
  444. if(Entity_content_length(buffer , HeaderItems))
  445. return true;
  446. if(Entity_content_range(buffer , HeaderItems))
  447. return true;
  448. if(Entity_content_type(buffer , HeaderItems))
  449. return true;
  450. if(Entity_content_version(buffer , HeaderItems))
  451. return true;
  452. if(Entity_dervied_from(buffer , HeaderItems))
  453. return true;
  454. if(Entity_expires(buffer , HeaderItems))
  455. return true;
  456. if(Entity_extension_header(buffer , HeaderItems))
  457. return true;
  458. if(Entity_last_modified(buffer , HeaderItems))
  459. return true;
  460. if(Entity_link(buffer , HeaderItems))
  461. return true;
  462. if(Entity_title(buffer , HeaderItems))
  463. return true;
  464. if(Entity_transfere_encoding(buffer , HeaderItems))
  465. return true;
  466. if(Entity_url_header(buffer , HeaderItems))
  467. return true;
  468. return false;
  469. }
  470. public static bool IsCustomHeader(string buffer,IDictionary CustomHeader)
  471. {
  472. Regex CustomHeaderEx = new Regex("^(?<header>\\S+)(\\s*:\\s*)(?<field>\\S+(\\s|\\S)*\\S)(\\s*)",RegexOptions.Compiled);
  473. Match m = CustomHeaderEx.Match(buffer);
  474. if(!m.Success)
  475. return false;
  476. CustomHeader.Add(m.Groups["header"].Value,m.Groups["field"].Value);
  477. return true;
  478. }
  479. //********************************************************
  480. //REQUEST
  481. private static bool Request_accept(string buffer,IDictionary HeaderItems)
  482. {
  483. Match m = ReqRegExp[0].Match(buffer);
  484. if(!m.Success)
  485. return false;
  486. HeaderItems.Add("accept",m.Groups["accept"].Value);
  487. return true;
  488. }
  489. private static bool Request_accept_charset(string buffer,IDictionary HeaderItems)
  490. {
  491. Match m = ReqRegExp[1].Match(buffer);
  492. if(!m.Success)
  493. return false;
  494. HeaderItems.Add("accept-charset",m.Groups["accept_charset"].Value);
  495. return true;
  496. }
  497. private static bool Request_accept_encoding(string buffer,IDictionary HeaderItems)
  498. {
  499. Match m = ReqRegExp[2].Match(buffer);
  500. if(!m.Success)
  501. return false;
  502. HeaderItems.Add("accept-encoding",m.Groups["accept_encoding"].Value);
  503. return true;
  504. }
  505. private static bool Request_authorization(string buffer,IDictionary HeaderItems)
  506. {
  507. Match m = ReqRegExp[3].Match(buffer);
  508. if(!m.Success)
  509. return false;
  510. HeaderItems.Add("authorization",m.Groups["authorization"].Value);
  511. return true;
  512. }
  513. private static bool Request_accept_language(string buffer,IDictionary HeaderItems)
  514. {
  515. Match m = ReqRegExp[4].Match(buffer);
  516. if(!m.Success)
  517. return false;
  518. HeaderItems.Add("accept-language",m.Groups["accept_language"].Value);
  519. return true;
  520. }
  521. private static bool Request_from(string buffer,IDictionary HeaderItems)
  522. {
  523. Match m = ReqRegExp[5].Match(buffer);
  524. if(!m.Success)
  525. return false;
  526. HeaderItems.Add("from",m.Groups["from"].Value);
  527. return true;
  528. }
  529. private static bool Request_host(string buffer,IDictionary HeaderItems)
  530. {
  531. Match m = ReqRegExp[6].Match(buffer);
  532. if(!m.Success)
  533. return false;
  534. HeaderItems.Add("host",m.Groups["host"].Value);
  535. return true;
  536. }
  537. private static bool Request_modified(string buffer,IDictionary HeaderItems)
  538. {
  539. Match m = ReqRegExp[7].Match(buffer);
  540. if(!m.Success)
  541. return false;
  542. HeaderItems.Add("modified",m.Groups["modified"].Value);
  543. return true;
  544. }
  545. private static bool Request_proxy_authorization(string buffer,IDictionary HeaderItems)
  546. {
  547. Match m = ReqRegExp[8].Match(buffer);
  548. if(!m.Success)
  549. return false;
  550. HeaderItems.Add("proxy-authorization",m.Groups["proxy_authorization"].Value);
  551. return true;
  552. }
  553. private static bool Request_range(string buffer , IDictionary HeaderItems)
  554. {
  555. Match m = ReqRegExp[9].Match(buffer);
  556. if(!m.Success)
  557. return false;
  558. HeaderItems.Add("range",m.Groups["range"].Value);
  559. return true;
  560. }
  561. private static bool Request_user_agent(string buffer,IDictionary HeaderItems)
  562. {
  563. Match m = ReqRegExp[10].Match(buffer);
  564. if(!m.Success)
  565. return false;
  566. HeaderItems.Add("user-agent",m.Groups["user_agent"].Value);
  567. return true;
  568. }
  569. private static bool Request_expect(string buffer,IDictionary HeaderItems)
  570. {
  571. Match m = ReqRegExp[11].Match(buffer);
  572. if(!m.Success)
  573. return false;
  574. HeaderItems.Add("expect",m.Groups["expect"].Value);
  575. return true;
  576. }
  577. private static bool Request_connection(string buffer,IDictionary HeaderItems)
  578. {
  579. Match m = ReqRegExp[12].Match(buffer);
  580. if(!m.Success)
  581. return false;
  582. HeaderItems.Add("connection",m.Groups["connection"].Value);
  583. return true;
  584. }
  585. private static bool Request_request_line(string buffer, IDictionary HeaderItems)
  586. {
  587. Match m = ReqRegExp[13].Match(buffer);
  588. if(!m.Success)
  589. return false;
  590. //ReqRegExpString[13] = "(?<method>\\w+)(\\s+)(?<request_url>\\S+)(\\s+)(?<http_version>\\S+)";
  591. HeaderItems.Add("method",m.Groups["method"].Value);
  592. HeaderItems.Add("request-url",m.Groups["request_url"].Value);
  593. HeaderItems.Add("http-version",m.Groups["http_version"].Value);
  594. return true;
  595. }
  596. //********************************************************
  597. //********************************************************
  598. //ENTITY
  599. private static bool Entity_allow(string buffer,IDictionary HeaderItems)
  600. {
  601. Match m = EntityRegExp[0].Match(buffer);
  602. if(!m.Success)
  603. return false;
  604. HeaderItems.Add("allow",m.Groups["allow"].Value);
  605. return true;
  606. }
  607. private static bool Entity_content_encoding(string buffer,IDictionary HeaderItems)
  608. {
  609. Match m = EntityRegExp[1].Match(buffer);
  610. if(!m.Success)
  611. return false;
  612. HeaderItems.Add("content-encoding",m.Groups["content_encoding"].Value);
  613. return true;
  614. }
  615. private static bool Entity_content_language(string buffer,IDictionary HeaderItems)
  616. {
  617. Match m = EntityRegExp[2].Match(buffer);
  618. if(!m.Success)
  619. return false;
  620. HeaderItems.Add("content-language",m.Groups["content_language"].Value);
  621. return true;
  622. }
  623. private static bool Entity_content_length(string buffer,IDictionary HeaderItems)
  624. {
  625. Match m = EntityRegExp[3].Match(buffer);
  626. if(!m.Success)
  627. return false;
  628. int length;
  629. try
  630. {
  631. length = Int32.Parse(m.Groups["content_length"].ToString());
  632. }
  633. catch (Exception )
  634. {
  635. //<Exception>
  636. return false;
  637. }
  638. HeaderItems.Add("content-length",length);
  639. return true;
  640. }
  641. private static bool Entity_content_range(string buffer,IDictionary HeaderItems)
  642. {
  643. Match m = EntityRegExp[4].Match(buffer);
  644. if(!m.Success)
  645. return false;
  646. HeaderItems.Add("content-range",m.Groups["content_range"].Value);
  647. return true;
  648. }
  649. private static bool Entity_content_type(string buffer,IDictionary HeaderItems)
  650. {
  651. Match m = EntityRegExp[5].Match(buffer);
  652. if(!m.Success)
  653. return false;
  654. HeaderItems.Add("content-type",m.Groups["content_type"].Value);
  655. return true;
  656. }
  657. private static bool Entity_content_version(string buffer,IDictionary HeaderItems)
  658. {
  659. Match m = EntityRegExp[6].Match(buffer);
  660. if(!m.Success)
  661. return false;
  662. HeaderItems.Add("content-version",m.Groups["content_version"].Value);
  663. return true;
  664. }
  665. private static bool Entity_dervied_from(string buffer,IDictionary HeaderItems)
  666. {
  667. Match m = EntityRegExp[7].Match(buffer);
  668. if(!m.Success)
  669. return false;
  670. HeaderItems.Add("dervied-from",m.Groups["dervied_from"].Value);
  671. return true;
  672. }
  673. private static bool Entity_expires(string buffer,IDictionary HeaderItems)
  674. {
  675. Match m = EntityRegExp[8].Match(buffer);
  676. if(!m.Success)
  677. return false;
  678. HeaderItems.Add("expires",m.Groups["expires"].Value);
  679. return true;
  680. }
  681. private static bool Entity_last_modified(string buffer,IDictionary HeaderItems)
  682. {
  683. Match m = EntityRegExp[9].Match(buffer);
  684. if(!m.Success)
  685. return false;
  686. HeaderItems.Add("last-modified",m.Groups["last_modified"].Value);
  687. return true;
  688. }
  689. private static bool Entity_link(string buffer,IDictionary HeaderItems)
  690. {
  691. Match m = EntityRegExp[10].Match(buffer);
  692. if(!m.Success)
  693. return false;
  694. HeaderItems.Add("link",m.Groups["link"].Value);
  695. return true;
  696. }
  697. private static bool Entity_title(string buffer,IDictionary HeaderItems)
  698. {
  699. Match m = EntityRegExp[11].Match(buffer);
  700. if(!m.Success)
  701. return false;
  702. HeaderItems.Add("title",m.Groups["title"].Value);
  703. return true;
  704. }
  705. private static bool Entity_transfere_encoding(string buffer,IDictionary HeaderItems)
  706. {
  707. Match m = EntityRegExp[12].Match(buffer);
  708. if(!m.Success)
  709. return false;
  710. HeaderItems.Add("transfere-encoding",m.Groups["transfere_encoding"].Value);
  711. return true;
  712. }
  713. private static bool Entity_url_header(string buffer,IDictionary HeaderItems)
  714. {
  715. Match m = EntityRegExp[13].Match(buffer);
  716. if(!m.Success)
  717. return false;
  718. HeaderItems.Add("url-header",m.Groups["url_header"].Value);
  719. return true;
  720. }
  721. private static bool Entity_extension_header(string buffer,IDictionary HeaderItems)
  722. {
  723. Match m = EntityRegExp[14].Match(buffer);
  724. if(!m.Success)
  725. return false;
  726. HeaderItems.Add("extension-header",m.Groups["extension_header"].Value);
  727. return true;
  728. }
  729. //********************************************************
  730. }
  731. }