jellyfin-server/Emby.Server.Implementations/Session/WebSocketController.cs

109 lines
3.1 KiB
C#
Raw Normal View History

2020-01-13 19:03:49 +00:00
#pragma warning disable CS1591
#pragma warning disable SA1600
#nullable enable
using System;
2013-10-03 01:22:50 +00:00
using System.Collections.Generic;
using System.Linq;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Controller.Net;
using MediaBrowser.Controller.Session;
using MediaBrowser.Model.Net;
using Microsoft.Extensions.Logging;
2016-11-03 23:35:19 +00:00
namespace Emby.Server.Implementations.Session
{
2019-12-17 22:15:02 +00:00
public sealed class WebSocketController : ISessionController, IDisposable
{
2014-05-17 04:24:10 +00:00
private readonly ILogger _logger;
2014-05-17 18:37:40 +00:00
private readonly ISessionManager _sessionManager;
2019-12-17 22:15:02 +00:00
private readonly SessionInfo _session;
2014-05-17 18:37:40 +00:00
2020-05-01 23:30:04 +00:00
private readonly List<IWebSocketConnection> _sockets;
2019-12-17 22:15:02 +00:00
private bool _disposed = false;
public WebSocketController(
ILogger<WebSocketController> logger,
SessionInfo session,
ISessionManager sessionManager)
{
2014-05-17 04:24:10 +00:00
_logger = logger;
2019-12-17 22:15:02 +00:00
_session = session;
2014-05-17 18:37:40 +00:00
_sessionManager = sessionManager;
2019-12-17 22:15:02 +00:00
_sockets = new List<IWebSocketConnection>();
}
private bool HasOpenSockets => GetActiveSockets().Any();
2015-03-21 16:10:02 +00:00
2019-12-17 22:15:02 +00:00
/// <inheritdoc />
public bool SupportsMediaControl => HasOpenSockets;
2015-03-21 16:10:02 +00:00
2019-12-17 22:15:02 +00:00
/// <inheritdoc />
public bool IsSessionActive => HasOpenSockets;
2013-10-03 01:22:50 +00:00
2014-05-17 04:24:10 +00:00
private IEnumerable<IWebSocketConnection> GetActiveSockets()
2019-12-17 22:15:02 +00:00
=> _sockets.Where(i => i.State == WebSocketState.Open);
2014-05-17 04:24:10 +00:00
2014-05-17 18:37:40 +00:00
public void AddWebSocket(IWebSocketConnection connection)
{
2019-12-17 22:15:02 +00:00
_logger.LogDebug("Adding websocket to session {Session}", _session.Id);
_sockets.Add(connection);
2014-05-17 18:37:40 +00:00
2019-12-17 22:15:02 +00:00
connection.Closed += OnConnectionClosed;
2014-05-17 18:37:40 +00:00
}
2019-12-17 22:15:02 +00:00
private void OnConnectionClosed(object sender, EventArgs e)
2014-05-17 18:37:40 +00:00
{
2018-09-12 17:26:21 +00:00
var connection = (IWebSocketConnection)sender;
_logger.LogDebug("Removing websocket from session {Session}", _session.Id);
2019-12-17 22:15:02 +00:00
_sockets.Remove(connection);
connection.Closed -= OnConnectionClosed;
_sessionManager.CloseIfNeeded(_session);
2014-05-17 18:37:40 +00:00
}
2019-12-17 22:15:02 +00:00
/// <inheritdoc />
public Task SendMessage<T>(
string name,
Guid messageId,
T data,
CancellationToken cancellationToken)
2014-05-17 04:24:10 +00:00
{
var socket = GetActiveSockets()
2019-12-17 22:15:02 +00:00
.OrderByDescending(i => i.LastActivityDate)
2014-05-17 04:24:10 +00:00
.FirstOrDefault();
if (socket == null)
{
2018-09-12 17:26:21 +00:00
return Task.CompletedTask;
}
2020-01-13 19:03:49 +00:00
return socket.SendAsync(
new WebSocketMessage<T>
{
Data = data,
MessageType = name,
MessageId = messageId
},
cancellationToken);
}
2019-12-17 22:15:02 +00:00
/// <inheritdoc />
2014-05-17 21:23:48 +00:00
public void Dispose()
{
2019-12-17 22:15:02 +00:00
if (_disposed)
2014-05-17 21:23:48 +00:00
{
2019-12-17 22:15:02 +00:00
return;
2014-05-17 21:23:48 +00:00
}
2019-12-17 22:15:02 +00:00
foreach (var socket in _sockets)
{
socket.Closed -= OnConnectionClosed;
}
_disposed = true;
2014-05-17 21:23:48 +00:00
}
}
}