Fix websockets array index out of bounds and some cleanup

1 files changed, 16 insertions, 150 deletions

diff --git a/Emby.Server.Implementations/SocketSharp/WebSocketSharpListener.cs b/Emby.Server.Implementations/SocketSharp/WebSocketSharpListener.cs
index 05f159b4e..6e5190efd 100644
--- a/Emby.Server.Implementations/SocketSharp/WebSocketSharpListener.cs
+++ b/Emby.Server.Implementations/SocketSharp/WebSocketSharpListener.cs
@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
- using System.Net;
+using System.Linq;
+using System.Net;
 using System.Net.WebSockets;
 using System.Threading;
 using System.Threading.Tasks;
@@ -38,94 +39,18 @@ using Microsoft.Extensions.Logging;
 
         public Action<WebSocketConnectEventArgs> WebSocketConnected { get; set; }
 
-//        public void Start(IEnumerable<string> urlPrefixes)
-//        {
-//            // TODO
-//            //if (_listener == null)
-//            //{
-//            //    _listener = new HttpListener(_logger, _cryptoProvider, _socketFactory, _streamHelper, _fileSystem, _environment);
-//            //}
-//
-//            //_listener.EnableDualMode = _enableDualMode;
-//
-//            //if (_certificate != null)
-//            //{
-//            //    _listener.LoadCert(_certificate);
-//            //}
-//
-//            //_logger.LogInformation("Adding HttpListener prefixes {Prefixes}", urlPrefixes);
-//            //_listener.Prefixes.AddRange(urlPrefixes);
-//
-//            //_listener.OnContext = async c => await InitTask(c, _disposeCancellationToken).ConfigureAwait(false);
-//
-//            //_listener.Start();
-//
-//            if (_listener == null)
-//            {
-//                _listener = new HttpListener();
-//            }
-//
-//            _logger.LogInformation("Adding HttpListener prefixes {Prefixes}", urlPrefixes);
-//
-//            //foreach (var urlPrefix in urlPrefixes)
-//            //{
-//            //    _listener.Prefixes.Add(urlPrefix);
-//            //}
-//            _listener.Prefixes.Add("http://localhost:8096/");
-//
-//            _listener.Start();
-//
-//            // TODO how to do this in netcore?
-//            _listener.BeginGetContext(async c => await InitTask(c, _disposeCancellationToken).ConfigureAwait(false),
-//                null);
-//        }
-
-        private static void LogRequest(ILogger logger, HttpListenerRequest request)
+        private static void LogRequest(ILogger logger, HttpRequest request)
         {
-            var url = request.Url.ToString();
+            var url = request.GetDisplayUrl();
 
-            logger.LogInformation(
-                "{0} {1}. UserAgent: {2}",
-                request.IsWebSocketRequest ? "WS" : "HTTP " + request.HttpMethod,
-                url,
-                request.UserAgent ?? string.Empty);
+            logger.LogInformation("{0} {1}. UserAgent: {2}", "WS", url, request.Headers["User-Agent"].ToString());
         }
-//
-//        private Task InitTask(IAsyncResult asyncResult, CancellationToken cancellationToken)
-//        {
-//            var context = _listener.EndGetContext(asyncResult);
-//            _listener.BeginGetContext(async c => await InitTask(c, _disposeCancellationToken).ConfigureAwait(false), null);
-//            IHttpRequest httpReq = null;
-//            var request = context.Request;
-//
-//            try
-//            {
-//                if (request.IsWebSocketRequest)
-//                {
-//                    LogRequest(_logger, request);
-//
-//                    return ProcessWebSocketRequest(context);
-//                }
-//
-//                httpReq = GetRequest(context);
-//            }
-//            catch (Exception ex)
-//            {
-//                _logger.LogError(ex, "Error processing request");
-//
-//                httpReq = httpReq ?? GetRequest(context);
-//                return ErrorHandler(ex, httpReq, true, true);
-//            }
-//
-//            var uri = request.Url;
-//
-//            return RequestHandler(httpReq, uri.OriginalString, uri.Host, uri.LocalPath, cancellationToken);
-//        }
 
         public async Task ProcessWebSocketRequest(HttpContext ctx)
         {
             try
             {
+                LogRequest(_logger, ctx.Request);
                 var endpoint = ctx.Connection.RemoteIpAddress.ToString();
                 var url = ctx.Request.GetDisplayUrl();
 
@@ -156,94 +81,35 @@ using Microsoft.Extensions.Logging;
                         Endpoint = endpoint
                     });
 
-                    //await ReceiveWebSocketAsync(ctx, socket).ConfigureAwait(false);
-                    var buffer = WebSocket.CreateClientBuffer(1024 * 4, 1024 * 4);
-                    WebSocketReceiveResult result = await webSocketContext.ReceiveAsync(buffer, CancellationToken.None);
-                    socket.OnReceiveBytes(buffer.Array);
+                    var buffer = WebSocket.CreateClientBuffer(4096, 4096);
+                    WebSocketReceiveResult result;
+                    var message = new List<byte>();
 
-                    while (result.MessageType != WebSocketMessageType.Close)
+                    do
                     {
                         result = await webSocketContext.ReceiveAsync(buffer, CancellationToken.None);
                         socket.OnReceiveBytes(buffer.Array);
-                    }
-                    await webSocketContext.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
-                    socket.Dispose();
-
-                    //while (!result.CloseStatus.HasValue)
-                    //{
-                    //    await webSocketContext.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);
-
-                    //    result = await webSocketContext.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
-                    //}
-                    //WebSocketConnected?.Invoke(new WebSocketConnectEventArgs
-                    //{
-                    //    Url = url,
-                    //    QueryString = queryString,
-                    //    WebSocket = webSocketContext,
-                    //    Endpoint = endpoint
-                    //});
-                    //await webSocketContext.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
-                    //SharpWebSocket socket = new SharpWebSocket(webSocketContext, _logger);
-                    //await socket.ConnectAsServerAsync().ConfigureAwait(false);
+                        message.AddRange(buffer.Array.Take(result.Count));
+                    } while (!result.EndOfMessage && result.MessageType != WebSocketMessageType.Close);
 
-
-
-                    //await ReceiveWebSocketAsync(ctx, socket).ConfigureAwait(false);
+                    socket.OnReceiveBytes(message.ToArray());
+                    await webSocketContext.CloseAsync(result.CloseStatus ?? WebSocketCloseStatus.NormalClosure,
+                        result.CloseStatusDescription, CancellationToken.None);
+                    socket.Dispose();
                 }
                 else
                 {
                     _logger.LogWarning("Web socket connection not allowed");
                     ctx.Response.StatusCode = 401;
-                    //ctx.Response.Close();
                 }
             }
             catch (Exception ex)
             {
                 _logger.LogError(ex, "AcceptWebSocketAsync error");
                 ctx.Response.StatusCode = 500;
-                //ctx.Response.Close();
-            }
-        }
-
-        private async Task ReceiveWebSocketAsync(HttpContext ctx, SharpWebSocket socket)
-        {
-            try
-            {
-                await socket.StartReceive().ConfigureAwait(false);
-            }
-            finally
-            {
-                TryClose(ctx, 200);
-            }
-        }
-
-        private void TryClose(HttpContext ctx, int statusCode)
-        {
-            try
-            {
-                ctx.Response.StatusCode = statusCode;
-            }
-            catch (ObjectDisposedException)
-            {
-                // TODO: Investigate and properly fix.
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, "Error closing web socket response");
             }
         }
 
-        private IHttpRequest GetRequest(HttpRequest httpContext)
-        {
-            var urlSegments = httpContext.Path;
-
-            var operationName = urlSegments;
-
-            var req = new WebSocketSharpRequest(httpContext, httpContext.HttpContext.Response, operationName, _logger);
-
-            return req;
-        }
-
         public void Start(IEnumerable<string> urlPrefixes)
         {
             throw new NotImplementedException();