aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Session/WebSocketController.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-11-03 19:35:19 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-11-03 19:35:19 -0400
commitd5ea8ca3ad378fc7e0a18ad314e1dfce07003ab6 (patch)
tree4742a665e3455389a9795ff8b6c292263b3876e8 /Emby.Server.Implementations/Session/WebSocketController.cs
parentd0babf322dad6624ee15622d11db52e58db5197f (diff)
move classes to portable
Diffstat (limited to 'Emby.Server.Implementations/Session/WebSocketController.cs')
-rw-r--r--Emby.Server.Implementations/Session/WebSocketController.cs288
1 files changed, 288 insertions, 0 deletions
diff --git a/Emby.Server.Implementations/Session/WebSocketController.cs b/Emby.Server.Implementations/Session/WebSocketController.cs
new file mode 100644
index 000000000..f0ff0b5dd
--- /dev/null
+++ b/Emby.Server.Implementations/Session/WebSocketController.cs
@@ -0,0 +1,288 @@
+using MediaBrowser.Controller.Net;
+using MediaBrowser.Controller.Session;
+using MediaBrowser.Model.Entities;
+using MediaBrowser.Model.Logging;
+using MediaBrowser.Model.Net;
+using MediaBrowser.Model.Session;
+using MediaBrowser.Model.System;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Emby.Server.Implementations.Session
+{
+ public class WebSocketController : ISessionController, IDisposable
+ {
+ public SessionInfo Session { get; private set; }
+ public IReadOnlyList<IWebSocketConnection> Sockets { get; private set; }
+
+ private readonly ILogger _logger;
+
+ private readonly ISessionManager _sessionManager;
+
+ public WebSocketController(SessionInfo session, ILogger logger, ISessionManager sessionManager)
+ {
+ Session = session;
+ _logger = logger;
+ _sessionManager = sessionManager;
+ Sockets = new List<IWebSocketConnection>();
+ }
+
+ private bool HasOpenSockets
+ {
+ get { return GetActiveSockets().Any(); }
+ }
+
+ public bool SupportsMediaControl
+ {
+ get { return HasOpenSockets; }
+ }
+
+ private bool _isActive;
+ private DateTime _lastActivityDate;
+ public bool IsSessionActive
+ {
+ get
+ {
+ if (HasOpenSockets)
+ {
+ return true;
+ }
+
+ //return false;
+ return _isActive && (DateTime.UtcNow - _lastActivityDate).TotalMinutes <= 10;
+ }
+ }
+
+ public void OnActivity()
+ {
+ _isActive = true;
+ _lastActivityDate = DateTime.UtcNow;
+ }
+
+ private IEnumerable<IWebSocketConnection> GetActiveSockets()
+ {
+ return Sockets
+ .OrderByDescending(i => i.LastActivityDate)
+ .Where(i => i.State == WebSocketState.Open);
+ }
+
+ 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)
+ {
+ if (!GetActiveSockets().Any())
+ {
+ _isActive = false;
+
+ try
+ {
+ _sessionManager.ReportSessionEnded(Session.Id);
+ }
+ catch (Exception ex)
+ {
+ _logger.ErrorException("Error reporting session ended.", ex);
+ }
+ }
+ }
+
+ 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;
+ }
+
+ public Task SendPlayCommand(PlayRequest command, CancellationToken cancellationToken)
+ {
+ return SendMessageInternal(new WebSocketMessage<PlayRequest>
+ {
+ MessageType = "Play",
+ Data = command
+
+ }, cancellationToken);
+ }
+
+ public Task SendPlaystateCommand(PlaystateRequest command, CancellationToken cancellationToken)
+ {
+ return SendMessageInternal(new WebSocketMessage<PlaystateRequest>
+ {
+ MessageType = "Playstate",
+ Data = command
+
+ }, cancellationToken);
+ }
+
+ public Task SendLibraryUpdateInfo(LibraryUpdateInfo info, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<LibraryUpdateInfo>
+ {
+ MessageType = "LibraryChanged",
+ Data = info
+
+ }, cancellationToken);
+ }
+
+ /// <summary>
+ /// Sends the restart required message.
+ /// </summary>
+ /// <param name="info">The information.</param>
+ /// <param name="cancellationToken">The cancellation token.</param>
+ /// <returns>Task.</returns>
+ public Task SendRestartRequiredNotification(SystemInfo info, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<SystemInfo>
+ {
+ MessageType = "RestartRequired",
+ Data = info
+
+ }, 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)
+ {
+ return SendMessagesInternal(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)
+ {
+ return SendMessagesInternal(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)
+ {
+ return SendMessagesInternal(new WebSocketMessage<string>
+ {
+ MessageType = "ServerRestarting",
+ Data = string.Empty
+
+ }, cancellationToken);
+ }
+
+ public Task SendGeneralCommand(GeneralCommand command, CancellationToken cancellationToken)
+ {
+ return SendMessageInternal(new WebSocketMessage<GeneralCommand>
+ {
+ MessageType = "GeneralCommand",
+ Data = command
+
+ }, cancellationToken);
+ }
+
+ public Task SendSessionEndedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<SessionInfoDto>
+ {
+ MessageType = "SessionEnded",
+ Data = sessionInfo
+
+ }, cancellationToken);
+ }
+
+ public Task SendPlaybackStartNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<SessionInfoDto>
+ {
+ MessageType = "PlaybackStart",
+ Data = sessionInfo
+
+ }, cancellationToken);
+ }
+
+ public Task SendPlaybackStoppedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<SessionInfoDto>
+ {
+ MessageType = "PlaybackStopped",
+ Data = sessionInfo
+
+ }, cancellationToken);
+ }
+
+ public Task SendMessage<T>(string name, T data, CancellationToken cancellationToken)
+ {
+ return SendMessagesInternal(new WebSocketMessage<T>
+ {
+ Data = data,
+ MessageType = name
+
+ }, cancellationToken);
+ }
+
+ private Task SendMessageInternal<T>(WebSocketMessage<T> message, CancellationToken cancellationToken)
+ {
+ var socket = GetActiveSocket();
+
+ return socket.SendAsync(message, cancellationToken);
+ }
+
+ private Task SendMessagesInternal<T>(WebSocketMessage<T> message, CancellationToken cancellationToken)
+ {
+ 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);
+ }
+
+ public void Dispose()
+ {
+ foreach (var socket in Sockets.ToList())
+ {
+ socket.Closed -= connection_Closed;
+ }
+ }
+ }
+}