jellyfin/MediaBrowser.Server.Implementations/Session/SessionWebSocketListener.cs

166 lines
6.3 KiB
C#
Raw Normal View History

2013-05-10 12:18:07 +00:00
using System.Globalization;
using MediaBrowser.Common.Net;
using MediaBrowser.Controller.Dto;
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Session;
2013-05-10 12:18:07 +00:00
using MediaBrowser.Model.Logging;
using System;
2013-05-09 17:45:46 +00:00
using System.Linq;
using System.Threading.Tasks;
2013-05-11 16:41:50 +00:00
using MediaBrowser.Model.Net;
namespace MediaBrowser.Server.Implementations.Session
{
/// <summary>
/// Class SessionWebSocketListener
/// </summary>
public class SessionWebSocketListener : IWebSocketListener
{
/// <summary>
/// The _true task result
/// </summary>
private readonly Task _trueTaskResult = Task.FromResult(true);
/// <summary>
/// The _session manager
/// </summary>
private readonly ISessionManager _sessionManager;
/// <summary>
2013-05-10 12:18:07 +00:00
/// The _logger
/// </summary>
private readonly ILogger _logger;
private readonly IUserManager _userManager;
private readonly ILibraryManager _libraryManager;
/// <summary>
/// Initializes a new instance of the <see cref="SessionWebSocketListener" /> class.
/// </summary>
/// <param name="sessionManager">The session manager.</param>
2013-05-10 12:18:07 +00:00
/// <param name="logger">The logger.</param>
/// <param name="libraryManager">The library manager.</param>
/// <param name="userManager">The user manager.</param>
public SessionWebSocketListener(ISessionManager sessionManager, ILogger logger, ILibraryManager libraryManager, IUserManager userManager)
{
_sessionManager = sessionManager;
2013-05-10 12:18:07 +00:00
_logger = logger;
_libraryManager = libraryManager;
_userManager = userManager;
}
/// <summary>
/// Processes the message.
/// </summary>
/// <param name="message">The message.</param>
/// <returns>Task.</returns>
public Task ProcessMessage(WebSocketMessageInfo message)
{
2013-05-09 21:05:07 +00:00
if (string.Equals(message.MessageType, "Identity", StringComparison.OrdinalIgnoreCase))
{
var vals = message.Data.Split('|');
2013-05-09 21:05:07 +00:00
var client = vals[0];
var deviceId = vals[1];
2013-05-10 12:18:07 +00:00
var session = _sessionManager.Sessions.FirstOrDefault(i => string.Equals(i.DeviceId, deviceId) && string.Equals(i.Client, client));
if (session != null)
{
2013-05-11 16:41:50 +00:00
var sockets = session.WebSockets.Where(i => i.State == WebSocketState.Open).ToList();
sockets.Add(message.Connection);
session.WebSockets = sockets;
2013-05-10 12:18:07 +00:00
}
2013-05-22 20:36:00 +00:00
else
{
_logger.Warn("Unable to determine session based on identity message: {0}", message.Data);
}
2013-05-10 12:18:07 +00:00
}
else if (string.Equals(message.MessageType, "Context", StringComparison.OrdinalIgnoreCase))
{
2013-05-11 16:41:50 +00:00
var session = _sessionManager.Sessions.FirstOrDefault(i => i.WebSockets.Contains(message.Connection));
if (session != null)
{
2013-05-10 12:18:07 +00:00
var vals = message.Data.Split('|');
session.NowViewingItemType = vals[0];
2013-05-22 03:59:55 +00:00
session.NowViewingItemId = vals[1];
session.NowViewingItemName = vals[2];
session.NowViewingContext = vals.Length > 3 ? vals[3] : null;
2013-05-10 12:18:07 +00:00
}
2013-05-22 20:36:00 +00:00
else
{
_logger.Warn("Unable to determine session based on context message: {0}", message.Data);
}
2013-05-10 12:18:07 +00:00
}
else if (string.Equals(message.MessageType, "PlaybackStart", StringComparison.OrdinalIgnoreCase))
{
2013-05-11 16:41:50 +00:00
var session = _sessionManager.Sessions.FirstOrDefault(i => i.WebSockets.Contains(message.Connection));
2013-05-10 12:18:07 +00:00
if (session != null && session.User != null)
2013-05-10 12:18:07 +00:00
{
var item = DtoBuilder.GetItemByClientId(message.Data, _userManager, _libraryManager);
_sessionManager.OnPlaybackStart(_userManager.GetUserById(session.User.Id), item, session.Client, session.DeviceId, session.DeviceName);
2013-05-10 12:18:07 +00:00
}
}
else if (string.Equals(message.MessageType, "PlaybackProgress", StringComparison.OrdinalIgnoreCase))
{
2013-05-11 16:41:50 +00:00
var session = _sessionManager.Sessions.FirstOrDefault(i => i.WebSockets.Contains(message.Connection));
2013-05-10 12:18:07 +00:00
if (session != null && session.User != null)
2013-05-10 12:18:07 +00:00
{
var vals = message.Data.Split('|');
var item = DtoBuilder.GetItemByClientId(vals[0], _userManager, _libraryManager);
long? positionTicks = null;
if (vals.Length > 1)
{
long pos;
if (long.TryParse(vals[1], out pos))
{
positionTicks = pos;
}
}
var isPaused = vals.Length > 2 && string.Equals(vals[2], "true", StringComparison.OrdinalIgnoreCase);
_sessionManager.OnPlaybackProgress(_userManager.GetUserById(session.User.Id), item, positionTicks, isPaused, session.Client, session.DeviceId, session.DeviceName);
2013-05-10 12:18:07 +00:00
}
}
else if (string.Equals(message.MessageType, "PlaybackStopped", StringComparison.OrdinalIgnoreCase))
{
2013-05-11 16:41:50 +00:00
var session = _sessionManager.Sessions.FirstOrDefault(i => i.WebSockets.Contains(message.Connection));
2013-05-10 12:18:07 +00:00
if (session != null && session.User != null)
2013-05-10 12:18:07 +00:00
{
var vals = message.Data.Split('|');
var item = DtoBuilder.GetItemByClientId(vals[0], _userManager, _libraryManager);
long? positionTicks = null;
if (vals.Length > 1)
{
long pos;
if (long.TryParse(vals[1], out pos))
{
positionTicks = pos;
}
}
_sessionManager.OnPlaybackStopped(_userManager.GetUserById(session.User.Id), item, positionTicks, session.Client, session.DeviceId, session.DeviceName);
}
}
return _trueTaskResult;
}
}
}