parent
15634a1913
commit
04f826e50c
@ -1,39 +0,0 @@
|
|||||||
#pragma warning disable CS1591
|
|
||||||
|
|
||||||
using System;
|
|
||||||
using System.Threading;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using Emby.Server.Implementations.Net;
|
|
||||||
using MediaBrowser.Model.Services;
|
|
||||||
using Microsoft.AspNetCore.Http;
|
|
||||||
|
|
||||||
namespace Emby.Server.Implementations.HttpServer
|
|
||||||
{
|
|
||||||
public interface IHttpListener : IDisposable
|
|
||||||
{
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the error handler.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The error handler.</value>
|
|
||||||
Func<Exception, IRequest, bool, bool, Task> ErrorHandler { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the request handler.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The request handler.</value>
|
|
||||||
Func<IHttpRequest, string, string, string, CancellationToken, Task> RequestHandler { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the web socket handler.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The web socket handler.</value>
|
|
||||||
Action<WebSocketConnectEventArgs> WebSocketConnected { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Stops this instance.
|
|
||||||
/// </summary>
|
|
||||||
Task Stop();
|
|
||||||
|
|
||||||
Task ProcessWebSocketRequest(HttpContext ctx);
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,29 +0,0 @@
|
|||||||
using System;
|
|
||||||
using Microsoft.AspNetCore.Http;
|
|
||||||
|
|
||||||
namespace Emby.Server.Implementations.Net
|
|
||||||
{
|
|
||||||
public class WebSocketConnectEventArgs : EventArgs
|
|
||||||
{
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the URL.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The URL.</value>
|
|
||||||
public string Url { get; set; }
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the query string.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The query string.</value>
|
|
||||||
public IQueryCollection QueryString { get; set; }
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the web socket.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The web socket.</value>
|
|
||||||
public IWebSocket WebSocket { get; set; }
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the endpoint.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The endpoint.</value>
|
|
||||||
public string Endpoint { get; set; }
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,135 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Net.WebSockets;
|
|
||||||
using System.Threading;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using Emby.Server.Implementations.HttpServer;
|
|
||||||
using Emby.Server.Implementations.Net;
|
|
||||||
using MediaBrowser.Model.Services;
|
|
||||||
using Microsoft.AspNetCore.Http;
|
|
||||||
using Microsoft.AspNetCore.Http.Extensions;
|
|
||||||
using Microsoft.Extensions.Logging;
|
|
||||||
using Microsoft.Net.Http.Headers;
|
|
||||||
|
|
||||||
namespace Emby.Server.Implementations.SocketSharp
|
|
||||||
{
|
|
||||||
public class WebSocketSharpListener : IHttpListener
|
|
||||||
{
|
|
||||||
private readonly ILogger _logger;
|
|
||||||
|
|
||||||
private CancellationTokenSource _disposeCancellationTokenSource = new CancellationTokenSource();
|
|
||||||
private CancellationToken _disposeCancellationToken;
|
|
||||||
|
|
||||||
public WebSocketSharpListener(ILogger<WebSocketSharpListener> logger)
|
|
||||||
{
|
|
||||||
_logger = logger;
|
|
||||||
_disposeCancellationToken = _disposeCancellationTokenSource.Token;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Func<Exception, IRequest, bool, bool, Task> ErrorHandler { get; set; }
|
|
||||||
|
|
||||||
public Func<IHttpRequest, string, string, string, CancellationToken, Task> RequestHandler { get; set; }
|
|
||||||
|
|
||||||
public Action<WebSocketConnectEventArgs> WebSocketConnected { get; set; }
|
|
||||||
|
|
||||||
private static void LogRequest(ILogger logger, HttpRequest request)
|
|
||||||
{
|
|
||||||
var url = request.GetDisplayUrl();
|
|
||||||
|
|
||||||
logger.LogInformation("WS {Url}. UserAgent: {UserAgent}", url, request.Headers[HeaderNames.UserAgent].ToString());
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task ProcessWebSocketRequest(HttpContext ctx)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
LogRequest(_logger, ctx.Request);
|
|
||||||
var endpoint = ctx.Connection.RemoteIpAddress.ToString();
|
|
||||||
var url = ctx.Request.GetDisplayUrl();
|
|
||||||
|
|
||||||
var webSocketContext = await ctx.WebSockets.AcceptWebSocketAsync(null).ConfigureAwait(false);
|
|
||||||
var socket = new SharpWebSocket(webSocketContext, _logger);
|
|
||||||
|
|
||||||
WebSocketConnected(new WebSocketConnectEventArgs
|
|
||||||
{
|
|
||||||
Url = url,
|
|
||||||
QueryString = ctx.Request.Query,
|
|
||||||
WebSocket = socket,
|
|
||||||
Endpoint = endpoint
|
|
||||||
});
|
|
||||||
|
|
||||||
WebSocketReceiveResult result;
|
|
||||||
var message = new List<byte>();
|
|
||||||
|
|
||||||
do
|
|
||||||
{
|
|
||||||
var buffer = WebSocket.CreateServerBuffer(4096);
|
|
||||||
result = await webSocketContext.ReceiveAsync(buffer, _disposeCancellationToken);
|
|
||||||
message.AddRange(buffer.Array.Take(result.Count));
|
|
||||||
|
|
||||||
if (result.EndOfMessage)
|
|
||||||
{
|
|
||||||
socket.OnReceiveBytes(message.ToArray());
|
|
||||||
message.Clear();
|
|
||||||
}
|
|
||||||
} while (socket.State == WebSocketState.Open && result.MessageType != WebSocketMessageType.Close);
|
|
||||||
|
|
||||||
|
|
||||||
if (webSocketContext.State == WebSocketState.Open)
|
|
||||||
{
|
|
||||||
await webSocketContext.CloseAsync(
|
|
||||||
result.CloseStatus ?? WebSocketCloseStatus.NormalClosure,
|
|
||||||
result.CloseStatusDescription,
|
|
||||||
_disposeCancellationToken).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
socket.Dispose();
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
_logger.LogError(ex, "AcceptWebSocketAsync error");
|
|
||||||
if (!ctx.Response.HasStarted)
|
|
||||||
{
|
|
||||||
ctx.Response.StatusCode = 500;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public Task Stop()
|
|
||||||
{
|
|
||||||
_disposeCancellationTokenSource.Cancel();
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Releases the unmanaged resources and disposes of the managed resources used.
|
|
||||||
/// </summary>
|
|
||||||
public void Dispose()
|
|
||||||
{
|
|
||||||
Dispose(true);
|
|
||||||
GC.SuppressFinalize(this);
|
|
||||||
}
|
|
||||||
|
|
||||||
private bool _disposed;
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Releases the unmanaged resources and disposes of the managed resources used.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="disposing">Whether or not the managed resources should be disposed.</param>
|
|
||||||
protected virtual void Dispose(bool disposing)
|
|
||||||
{
|
|
||||||
if (_disposed)
|
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (disposing)
|
|
||||||
{
|
|
||||||
Stop().GetAwaiter().GetResult();
|
|
||||||
}
|
|
||||||
|
|
||||||
_disposed = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,102 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Net.WebSockets;
|
|
||||||
using System.Text;
|
|
||||||
using System.Threading;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using MediaBrowser.Model.Net;
|
|
||||||
using MediaBrowser.Model.Serialization;
|
|
||||||
using Microsoft.Extensions.Logging;
|
|
||||||
using UtfUnknown;
|
|
||||||
|
|
||||||
namespace Emby.Server.Implementations.WebSockets
|
|
||||||
{
|
|
||||||
public class WebSocketManager
|
|
||||||
{
|
|
||||||
private readonly IWebSocketHandler[] _webSocketHandlers;
|
|
||||||
private readonly IJsonSerializer _jsonSerializer;
|
|
||||||
private readonly ILogger<WebSocketManager> _logger;
|
|
||||||
private const int BufferSize = 4096;
|
|
||||||
|
|
||||||
public WebSocketManager(IWebSocketHandler[] webSocketHandlers, IJsonSerializer jsonSerializer, ILogger<WebSocketManager> logger)
|
|
||||||
{
|
|
||||||
_webSocketHandlers = webSocketHandlers;
|
|
||||||
_jsonSerializer = jsonSerializer;
|
|
||||||
_logger = logger;
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task OnWebSocketConnected(WebSocket webSocket)
|
|
||||||
{
|
|
||||||
var taskCompletionSource = new TaskCompletionSource<bool>();
|
|
||||||
var cancellationToken = new CancellationTokenSource().Token;
|
|
||||||
WebSocketReceiveResult result;
|
|
||||||
var message = new List<byte>();
|
|
||||||
|
|
||||||
// Keep listening for incoming messages, otherwise the socket closes automatically
|
|
||||||
do
|
|
||||||
{
|
|
||||||
var buffer = WebSocket.CreateServerBuffer(BufferSize);
|
|
||||||
result = await webSocket.ReceiveAsync(buffer, cancellationToken).ConfigureAwait(false);
|
|
||||||
message.AddRange(buffer.Array.Take(result.Count));
|
|
||||||
|
|
||||||
if (result.EndOfMessage)
|
|
||||||
{
|
|
||||||
await ProcessMessage(message.ToArray(), taskCompletionSource).ConfigureAwait(false);
|
|
||||||
message.Clear();
|
|
||||||
}
|
|
||||||
} while (!taskCompletionSource.Task.IsCompleted &&
|
|
||||||
webSocket.State == WebSocketState.Open &&
|
|
||||||
result.MessageType != WebSocketMessageType.Close);
|
|
||||||
|
|
||||||
if (webSocket.State == WebSocketState.Open)
|
|
||||||
{
|
|
||||||
await webSocket.CloseAsync(
|
|
||||||
result.CloseStatus ?? WebSocketCloseStatus.NormalClosure,
|
|
||||||
result.CloseStatusDescription,
|
|
||||||
cancellationToken).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task ProcessMessage(byte[] messageBytes, TaskCompletionSource<bool> taskCompletionSource)
|
|
||||||
{
|
|
||||||
var charset = CharsetDetector.DetectFromBytes(messageBytes).Detected?.EncodingName;
|
|
||||||
var message = string.Equals(charset, "utf-8", StringComparison.OrdinalIgnoreCase)
|
|
||||||
? Encoding.UTF8.GetString(messageBytes, 0, messageBytes.Length)
|
|
||||||
: Encoding.ASCII.GetString(messageBytes, 0, messageBytes.Length);
|
|
||||||
|
|
||||||
// All messages are expected to be valid JSON objects
|
|
||||||
if (!message.StartsWith("{", StringComparison.OrdinalIgnoreCase))
|
|
||||||
{
|
|
||||||
_logger.LogDebug("Received web socket message that is not a json structure: {Message}", message);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var info = _jsonSerializer.DeserializeFromString<WebSocketMessage<object>>(message);
|
|
||||||
|
|
||||||
_logger.LogDebug("Websocket message received: {0}", info.MessageType);
|
|
||||||
|
|
||||||
var tasks = _webSocketHandlers.Select(handler => Task.Run(() =>
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
handler.ProcessMessage(info, taskCompletionSource).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
_logger.LogError(ex, "{HandlerType} failed processing WebSocket message {MessageType}",
|
|
||||||
handler.GetType().Name, info.MessageType ?? string.Empty);
|
|
||||||
}
|
|
||||||
}));
|
|
||||||
|
|
||||||
await Task.WhenAll(tasks);
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
_logger.LogError(ex, "Error processing web socket message");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in new issue