consolidate web socket onto one port

1 files changed, 144 insertions, 0 deletions

diff --git a/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/WebSocketSharpResponse.cs b/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/WebSocketSharpResponse.cs
new file mode 100644
index 000000000..2e3828512
--- /dev/null
+++ b/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/WebSocketSharpResponse.cs
@@ -0,0 +1,144 @@
+using System;
+using System.IO;
+using System.Net;
+using MediaBrowser.Model.Logging;
+using ServiceStack;
+using ServiceStack.Host;
+using ServiceStack.Web;
+using HttpListenerResponse = WebSocketSharp.Net.HttpListenerResponse;
+
+namespace MediaBrowser.Server.Implementations.HttpServer.SocketSharp
+{
+    public class WebSocketSharpResponse : IHttpResponse
+    {
+        private readonly ILogger _logger;
+        private readonly HttpListenerResponse response;
+
+        public WebSocketSharpResponse(ILogger logger, HttpListenerResponse response)
+        {
+            _logger = logger;
+            this.response = response;
+        }
+
+        public bool UseBufferedStream { get; set; }
+
+        public object OriginalResponse
+        {
+            get { return response; }
+        }
+
+        public int StatusCode
+        {
+            get { return this.response.StatusCode; }
+            set { this.response.StatusCode = value; }
+        }
+
+        public string StatusDescription
+        {
+            get { return this.response.StatusDescription; }
+            set { this.response.StatusDescription = value; }
+        }
+
+        public string ContentType
+        {
+            get { return response.ContentType; }
+            set { response.ContentType = value; }
+        }
+
+        public ICookies Cookies { get; set; }
+
+        public void AddHeader(string name, string value)
+        {
+            if (string.Equals(name, "Content-Type", StringComparison.OrdinalIgnoreCase))
+            {
+                ContentType = value;
+                return;
+            }
+
+            response.AddHeader(name, value);
+        }
+
+        public void Redirect(string url)
+        {
+            response.Redirect(url);
+        }
+
+        public Stream OutputStream
+        {
+            get { return response.OutputStream; }
+        }
+
+        public object Dto { get; set; }
+
+        public void Write(string text)
+        {
+            try
+            {
+                var bOutput = System.Text.Encoding.UTF8.GetBytes(text);
+                response.ContentLength64 = bOutput.Length;
+
+                var outputStream = response.OutputStream;
+                outputStream.Write(bOutput, 0, bOutput.Length);
+                Close();
+            }
+            catch (Exception ex)
+            {
+                _logger.ErrorException("Could not WriteTextToResponse: " + ex.Message, ex);
+                throw;
+            }
+        }
+
+        public void Close()
+        {
+            if (!this.IsClosed)
+            {
+                this.IsClosed = true;
+
+                try
+                {
+                    this.response.CloseOutputStream(_logger);
+                }
+                catch (Exception ex)
+                {
+                    _logger.ErrorException("Error closing HttpListener output stream", ex);
+                }
+            }
+        }
+
+        public void End()
+        {
+            Close();
+        }
+
+        public void Flush()
+        {
+            response.OutputStream.Flush();
+        }
+
+        public bool IsClosed
+        {
+            get;
+            private set;
+        }
+
+        public void SetContentLength(long contentLength)
+        {
+            //you can happily set the Content-Length header in Asp.Net
+            //but HttpListener will complain if you do - you have to set ContentLength64 on the response.
+            //workaround: HttpListener throws "The parameter is incorrect" exceptions when we try to set the Content-Length header
+            response.ContentLength64 = contentLength;
+        }
+
+        public void SetCookie(Cookie cookie)
+        {
+            var cookieStr = cookie.AsHeaderValue();
+            response.Headers.Add(HttpHeaders.SetCookie, cookieStr);
+        }
+
+        public bool SendChunked
+        {
+            get { return response.SendChunked; }
+            set { response.SendChunked = value; }
+        }
+    }
+}