#region License /* * RequestHandshake.cs * * The MIT License * * Copyright (c) 2012-2013 sta.blockhead * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. */ #endregion using System; using System.Collections.Specialized; using System.Linq; using System.Text; using WebSocketSharp.Net; using WebSocketSharp.Net.WebSockets; namespace WebSocketSharp { internal class RequestHandshake : Handshake { #region Private Fields private NameValueCollection _queryString; #endregion #region Private Constructors private RequestHandshake() { } #endregion #region Public Constructors public RequestHandshake(string uriString) { HttpMethod = "GET"; RequestUri = uriString.ToUri(); AddHeader("User-Agent", "websocket-sharp/1.0"); AddHeader("Upgrade", "websocket"); AddHeader("Connection", "Upgrade"); } #endregion #region Public Properties public CookieCollection Cookies { get { return Headers.GetCookies(false); } } public string HttpMethod { get; private set; } public bool IsWebSocketRequest { get { return HttpMethod != "GET" ? false : ProtocolVersion < HttpVersion.Version11 ? false : !HeaderExists("Upgrade", "websocket") ? false : !HeaderExists("Connection", "Upgrade") ? false : !HeaderExists("Host") ? false : !HeaderExists("Sec-WebSocket-Key") ? false : HeaderExists("Sec-WebSocket-Version"); } } public NameValueCollection QueryString { get { if (_queryString == null) { _queryString = new NameValueCollection(); var i = RawUrl.IndexOf('?'); if (i > 0) { var query = RawUrl.Substring(i + 1); var components = query.Split('&'); foreach (var c in components) { var nv = c.GetNameAndValue("="); if (nv.Key != null) { var name = nv.Key.UrlDecode(); var val = nv.Value.UrlDecode(); _queryString.Add(name, val); } } } } return _queryString; } } public string RawUrl { get { return RequestUri.IsAbsoluteUri ? RequestUri.PathAndQuery : RequestUri.OriginalString; } } public Uri RequestUri { get; private set; } #endregion #region Public Methods public static RequestHandshake Parse(string[] request) { var requestLine = request[0].Split(' '); if (requestLine.Length != 3) { var msg = "Invalid HTTP Request-Line: " + request[0]; throw new ArgumentException(msg, "request"); } var headers = new WebHeaderCollection(); for (int i = 1; i < request.Length; i++) headers.SetInternal(request[i], false); return new RequestHandshake { Headers = headers, HttpMethod = requestLine[0], RequestUri = requestLine[1].ToUri(), ProtocolVersion = new Version(requestLine[2].Substring(5)) }; } public static RequestHandshake Parse(WebSocketContext context) { return new RequestHandshake { Headers = context.Headers, HttpMethod = "GET", RequestUri = context.RequestUri, ProtocolVersion = HttpVersion.Version11 }; } public void SetCookies(CookieCollection cookies) { if (cookies.IsNull() || cookies.Count == 0) return; var sorted = cookies.Sorted.ToArray(); var header = new StringBuilder(sorted[0].ToString()); for (int i = 1; i < sorted.Length; i++) if (!sorted[i].Expired) header.AppendFormat("; {0}", sorted[i].ToString()); AddHeader("Cookie", header.ToString()); } public override string ToString() { var buffer = new StringBuilder(); buffer.AppendFormat("{0} {1} HTTP/{2}{3}", HttpMethod, RawUrl, ProtocolVersion, _crlf); foreach (string key in Headers.AllKeys) buffer.AppendFormat("{0}: {1}{2}", key, Headers[key], _crlf); buffer.Append(_crlf); return buffer.ToString(); } #endregion } }