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

294 lines
9.2 KiB
C#
Raw Normal View History

using MediaBrowser.Common.Net;
using MediaBrowser.Controller.Session;
2013-10-03 01:22:50 +00:00
using MediaBrowser.Model.Entities;
2014-05-17 04:24:10 +00:00
using MediaBrowser.Model.Logging;
using MediaBrowser.Model.Net;
using MediaBrowser.Model.Session;
2013-10-03 01:22:50 +00:00
using MediaBrowser.Model.System;
using System;
2013-10-03 01:22:50 +00:00
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
namespace MediaBrowser.Server.Implementations.Session
{
2014-05-17 21:23:48 +00:00
public class WebSocketController : ISessionController, IDisposable
{
2013-10-03 01:22:50 +00:00
public SessionInfo Session { get; private set; }
2014-05-17 18:37:40 +00:00
public IReadOnlyList<IWebSocketConnection> Sockets { get; private set; }
2013-10-03 01:22:50 +00:00
2014-05-17 04:24:10 +00:00
private readonly ILogger _logger;
2013-10-03 01:22:50 +00:00
2014-05-17 18:37:40 +00:00
private readonly ISessionManager _sessionManager;
2014-05-18 19:58:42 +00:00
public WebSocketController(SessionInfo session, ILogger logger, ISessionManager sessionManager)
{
2013-10-03 01:22:50 +00:00
Session = session;
2014-05-17 04:24:10 +00:00
_logger = logger;
2014-05-17 18:37:40 +00:00
_sessionManager = sessionManager;
2013-10-03 01:22:50 +00:00
Sockets = new List<IWebSocketConnection>();
}
2013-10-03 01:22:50 +00:00
public bool IsSessionActive
{
get
{
return Sockets.Any(i => i.State == WebSocketState.Open);
}
}
2014-05-17 18:37:40 +00:00
public bool SupportsMediaControl
{
get { return GetActiveSockets().Any(); }
}
2014-05-17 04:24:10 +00:00
private IEnumerable<IWebSocketConnection> GetActiveSockets()
2013-10-03 01:22:50 +00:00
{
2014-05-17 04:24:10 +00:00
return Sockets
2013-10-03 01:22:50 +00:00
.OrderByDescending(i => i.LastActivityDate)
2014-05-17 04:24:10 +00:00
.Where(i => i.State == WebSocketState.Open);
}
2014-05-17 18:37:40 +00:00
public void AddWebSocket(IWebSocketConnection connection)
{
var sockets = Sockets.ToList();
sockets.Add(connection);
Sockets = sockets;
connection.Closed += connection_Closed;
}
void connection_Closed(object sender, EventArgs e)
{
2014-07-12 02:31:08 +00:00
if (!GetActiveSockets().Any())
2014-05-17 18:37:40 +00:00
{
2014-07-12 02:31:08 +00:00
try
{
_sessionManager.ReportSessionEnded(Session.Id);
}
catch (Exception ex)
{
_logger.ErrorException("Error reporting session ended.", ex);
}
}
else
{
var capabilities = new SessionCapabilities
{
PlayableMediaTypes = Session.PlayableMediaTypes,
SupportedCommands = Session.SupportedCommands,
SupportsMediaControl = SupportsMediaControl
};
_sessionManager.ReportCapabilities(Session.Id, capabilities);
}
2014-05-17 18:37:40 +00:00
}
2014-05-17 04:24:10 +00:00
private IWebSocketConnection GetActiveSocket()
{
var socket = GetActiveSockets()
.FirstOrDefault();
if (socket == null)
{
throw new InvalidOperationException("The requested session does not have an open web socket.");
}
return socket;
}
2013-10-03 01:22:50 +00:00
public Task SendPlayCommand(PlayRequest command, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessage(new WebSocketMessage<PlayRequest>
{
MessageType = "Play",
Data = command
}, cancellationToken);
}
2013-10-03 01:22:50 +00:00
public Task SendPlaystateCommand(PlaystateRequest command, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessage(new WebSocketMessage<PlaystateRequest>
{
MessageType = "Playstate",
Data = command
}, cancellationToken);
}
2013-10-03 01:22:50 +00:00
public Task SendLibraryUpdateInfo(LibraryUpdateInfo info, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<LibraryUpdateInfo>
2013-10-03 01:22:50 +00:00
{
MessageType = "LibraryChanged",
2013-10-03 01:22:50 +00:00
Data = info
}, cancellationToken);
}
/// <summary>
/// Sends the restart required message.
/// </summary>
2014-05-18 19:58:42 +00:00
/// <param name="info">The information.</param>
2013-10-03 01:22:50 +00:00
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns>Task.</returns>
2014-05-18 19:58:42 +00:00
public Task SendRestartRequiredNotification(SystemInfo info, CancellationToken cancellationToken)
2013-10-03 01:22:50 +00:00
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<SystemInfo>
2013-10-03 01:22:50 +00:00
{
MessageType = "RestartRequired",
2014-05-18 19:58:42 +00:00
Data = info
2013-10-03 01:22:50 +00:00
}, cancellationToken);
}
/// <summary>
/// Sends the user data change info.
/// </summary>
/// <param name="info">The info.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns>Task.</returns>
public Task SendUserDataChangeInfo(UserDataChangeInfo info, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<UserDataChangeInfo>
{
MessageType = "UserDataChanged",
Data = info
}, cancellationToken);
}
/// <summary>
/// Sends the server shutdown notification.
/// </summary>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns>Task.</returns>
public Task SendServerShutdownNotification(CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<string>
{
MessageType = "ServerShuttingDown",
Data = string.Empty
}, cancellationToken);
}
/// <summary>
/// Sends the server restart notification.
/// </summary>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns>Task.</returns>
public Task SendServerRestartNotification(CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<string>
{
MessageType = "ServerRestarting",
Data = string.Empty
}, cancellationToken);
}
2014-03-28 19:58:18 +00:00
2014-03-31 21:04:22 +00:00
public Task SendGeneralCommand(GeneralCommand command, CancellationToken cancellationToken)
2014-03-28 19:58:18 +00:00
{
2014-05-17 04:24:10 +00:00
return SendMessage(new WebSocketMessage<GeneralCommand>
2014-03-28 19:58:18 +00:00
{
2014-03-31 21:04:22 +00:00
MessageType = "GeneralCommand",
2014-03-28 19:58:18 +00:00
Data = command
}, cancellationToken);
}
2014-04-06 17:53:23 +00:00
public Task SendSessionEndedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<SessionInfoDto>
2014-04-06 17:53:23 +00:00
{
MessageType = "SessionEnded",
Data = sessionInfo
}, cancellationToken);
}
public Task SendPlaybackStartNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<SessionInfoDto>
{
MessageType = "PlaybackStart",
Data = sessionInfo
}, cancellationToken);
}
public Task SendPlaybackStoppedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
2014-05-17 04:24:10 +00:00
return SendMessages(new WebSocketMessage<SessionInfoDto>
{
MessageType = "PlaybackStopped",
Data = sessionInfo
}, cancellationToken);
}
2014-05-17 04:24:10 +00:00
private Task SendMessage<T>(WebSocketMessage<T> message, CancellationToken cancellationToken)
{
2014-07-30 03:31:35 +00:00
if (SkipSending()) return Task.FromResult(true);
2014-05-17 04:24:10 +00:00
var socket = GetActiveSocket();
return socket.SendAsync(message, cancellationToken);
}
private Task SendMessages<T>(WebSocketMessage<T> message, CancellationToken cancellationToken)
{
2014-07-30 03:31:35 +00:00
if (SkipSending()) return Task.FromResult(true);
2014-05-17 04:24:10 +00:00
var tasks = GetActiveSockets().Select(i => Task.Run(async () =>
{
try
{
await i.SendAsync(message, cancellationToken).ConfigureAwait(false);
}
catch (Exception ex)
{
_logger.ErrorException("Error sending web socket message", ex);
}
}, cancellationToken));
return Task.WhenAll(tasks);
}
2014-05-17 21:23:48 +00:00
2014-07-30 03:31:35 +00:00
private bool SkipSending()
{
if (Session != null)
{
if (string.Equals(Session.Client, "mb-classic", StringComparison.OrdinalIgnoreCase))
{
Version version;
if (!string.IsNullOrWhiteSpace(Session.ApplicationVersion) && Version.TryParse(Session.ApplicationVersion, out version))
{
if (version < new Version(3, 0, 196))
{
_logger.Debug("Skipping web socket message to MBC version {0}.", version);
return true;
}
}
}
}
return false;
}
2014-05-17 21:23:48 +00:00
public void Dispose()
{
foreach (var socket in Sockets.ToList())
{
socket.Closed -= connection_Closed;
}
}
}
}