2013-09-24 15:54:42 -04:00
|
|
|
|
using MediaBrowser.Common.Net;
|
2013-10-02 21:22:50 -04:00
|
|
|
|
using MediaBrowser.Controller;
|
2013-09-24 15:54:42 -04:00
|
|
|
|
using MediaBrowser.Controller.Session;
|
2013-10-02 21:22:50 -04:00
|
|
|
|
using MediaBrowser.Model.Entities;
|
2013-09-24 11:42:30 -04:00
|
|
|
|
using MediaBrowser.Model.Net;
|
|
|
|
|
using MediaBrowser.Model.Session;
|
2013-10-02 21:22:50 -04:00
|
|
|
|
using MediaBrowser.Model.System;
|
2013-09-24 11:42:30 -04:00
|
|
|
|
using System;
|
2013-10-02 21:22:50 -04:00
|
|
|
|
using System.Collections.Generic;
|
2013-09-24 11:42:30 -04:00
|
|
|
|
using System.Linq;
|
|
|
|
|
using System.Threading;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
|
|
|
|
|
namespace MediaBrowser.Server.Implementations.Session
|
|
|
|
|
{
|
2013-10-02 15:08:58 -04:00
|
|
|
|
public class WebSocketController : ISessionController
|
2013-09-24 11:42:30 -04:00
|
|
|
|
{
|
2013-10-02 21:22:50 -04:00
|
|
|
|
public SessionInfo Session { get; private set; }
|
|
|
|
|
public List<IWebSocketConnection> Sockets { get; private set; }
|
|
|
|
|
|
|
|
|
|
private readonly IServerApplicationHost _appHost;
|
|
|
|
|
|
|
|
|
|
public WebSocketController(SessionInfo session, IServerApplicationHost appHost)
|
2013-09-24 11:42:30 -04:00
|
|
|
|
{
|
2013-10-02 21:22:50 -04:00
|
|
|
|
Session = session;
|
|
|
|
|
_appHost = appHost;
|
|
|
|
|
Sockets = new List<IWebSocketConnection>();
|
2013-09-24 11:42:30 -04:00
|
|
|
|
}
|
|
|
|
|
|
2013-10-02 21:22:50 -04:00
|
|
|
|
public bool IsSessionActive
|
|
|
|
|
{
|
|
|
|
|
get
|
|
|
|
|
{
|
|
|
|
|
return Sockets.Any(i => i.State == WebSocketState.Open);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private IWebSocketConnection GetActiveSocket()
|
|
|
|
|
{
|
|
|
|
|
var socket = Sockets
|
|
|
|
|
.OrderByDescending(i => i.LastActivityDate)
|
|
|
|
|
.FirstOrDefault(i => i.State == WebSocketState.Open);
|
2013-09-24 15:54:42 -04:00
|
|
|
|
|
|
|
|
|
if (socket == null)
|
2013-09-24 11:42:30 -04:00
|
|
|
|
{
|
|
|
|
|
throw new InvalidOperationException("The requested session does not have an open web socket.");
|
|
|
|
|
}
|
2013-09-24 15:54:42 -04:00
|
|
|
|
|
|
|
|
|
return socket;
|
|
|
|
|
}
|
|
|
|
|
|
2013-10-02 21:22:50 -04:00
|
|
|
|
public Task SendPlayCommand(PlayRequest command, CancellationToken cancellationToken)
|
2013-09-24 15:54:42 -04:00
|
|
|
|
{
|
2013-10-02 21:22:50 -04:00
|
|
|
|
var socket = GetActiveSocket();
|
2013-09-24 15:54:42 -04:00
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<PlayRequest>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "Play",
|
|
|
|
|
Data = command
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
|
2013-10-02 21:22:50 -04:00
|
|
|
|
public Task SendPlaystateCommand(PlaystateRequest command, CancellationToken cancellationToken)
|
2013-09-24 15:54:42 -04:00
|
|
|
|
{
|
2013-10-02 21:22:50 -04:00
|
|
|
|
var socket = GetActiveSocket();
|
2013-09-24 15:54:42 -04:00
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<PlaystateRequest>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "Playstate",
|
|
|
|
|
Data = command
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
2013-09-24 11:42:30 -04:00
|
|
|
|
}
|
2013-10-02 21:22:50 -04:00
|
|
|
|
|
|
|
|
|
public Task SendLibraryUpdateInfo(LibraryUpdateInfo info, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<LibraryUpdateInfo>
|
|
|
|
|
{
|
2013-10-06 14:48:04 -04:00
|
|
|
|
MessageType = "LibraryChanged",
|
2013-10-02 21:22:50 -04:00
|
|
|
|
Data = info
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Sends the restart required message.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
|
|
|
/// <returns>Task.</returns>
|
2013-10-03 14:02:23 -04:00
|
|
|
|
public Task SendRestartRequiredNotification(CancellationToken cancellationToken)
|
2013-10-02 21:22:50 -04:00
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<SystemInfo>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "RestartRequired",
|
|
|
|
|
Data = _appHost.GetSystemInfo()
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
2013-10-03 14:02:23 -04:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// <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)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(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)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(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)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<string>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "ServerRestarting",
|
|
|
|
|
Data = string.Empty
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
2014-03-28 15:58:18 -04:00
|
|
|
|
|
2014-03-31 17:04:22 -04:00
|
|
|
|
public Task SendGeneralCommand(GeneralCommand command, CancellationToken cancellationToken)
|
2014-03-28 15:58:18 -04:00
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
2014-03-31 17:04:22 -04:00
|
|
|
|
return socket.SendAsync(new WebSocketMessage<GeneralCommand>
|
2014-03-28 15:58:18 -04:00
|
|
|
|
{
|
2014-03-31 17:04:22 -04:00
|
|
|
|
MessageType = "GeneralCommand",
|
2014-03-28 15:58:18 -04:00
|
|
|
|
Data = command
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
2014-04-06 13:53:23 -04:00
|
|
|
|
|
|
|
|
|
public Task SendSessionEndedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<SessionInfoDto>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "SessionEnded",
|
|
|
|
|
Data = sessionInfo
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
2014-04-12 13:27:53 -04:00
|
|
|
|
|
|
|
|
|
public Task SendPlaybackStartNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<SessionInfoDto>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "PlaybackStart",
|
|
|
|
|
Data = sessionInfo
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Task SendPlaybackStoppedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var socket = GetActiveSocket();
|
|
|
|
|
|
|
|
|
|
return socket.SendAsync(new WebSocketMessage<SessionInfoDto>
|
|
|
|
|
{
|
|
|
|
|
MessageType = "PlaybackStopped",
|
|
|
|
|
Data = sessionInfo
|
|
|
|
|
|
|
|
|
|
}, cancellationToken);
|
|
|
|
|
}
|
2013-09-24 11:42:30 -04:00
|
|
|
|
}
|
|
|
|
|
}
|