HttpServer.cs 25 KB

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