mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-07-09 15:20:34 +02:00
65cd3ed597
This makes resolving dependencies from the container much easier as you cannot resolve with primitives parameters in a way that is any more readable. The aim of this commit is to change as little as possible with the end result, loggers that were newed up for the parent object were given the same name. Objects that used the base or app loggers, were given a new logger with an appropriate name. Also removed some unused dependencies.
1896 lines
64 KiB
C#
1896 lines
64 KiB
C#
using System;
|
|
using System.Collections.Concurrent;
|
|
using System.Collections.Generic;
|
|
using System.Globalization;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Common.Events;
|
|
using MediaBrowser.Common.Extensions;
|
|
using MediaBrowser.Common.Net;
|
|
using MediaBrowser.Controller;
|
|
using MediaBrowser.Controller.Authentication;
|
|
using MediaBrowser.Controller.Devices;
|
|
using MediaBrowser.Controller.Drawing;
|
|
using MediaBrowser.Controller.Dto;
|
|
using MediaBrowser.Controller.Entities;
|
|
using MediaBrowser.Controller.Entities.TV;
|
|
using MediaBrowser.Controller.Library;
|
|
using MediaBrowser.Controller.Net;
|
|
using MediaBrowser.Controller.Security;
|
|
using MediaBrowser.Controller.Session;
|
|
using MediaBrowser.Model.Devices;
|
|
using MediaBrowser.Model.Dto;
|
|
using MediaBrowser.Model.Entities;
|
|
using MediaBrowser.Model.Events;
|
|
using MediaBrowser.Model.Library;
|
|
using MediaBrowser.Model.Querying;
|
|
using MediaBrowser.Model.Serialization;
|
|
using MediaBrowser.Model.Session;
|
|
using MediaBrowser.Model.Threading;
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
namespace Emby.Server.Implementations.Session
|
|
{
|
|
/// <summary>
|
|
/// Class SessionManager
|
|
/// </summary>
|
|
public class SessionManager : ISessionManager, IDisposable
|
|
{
|
|
/// <summary>
|
|
/// The _user data repository
|
|
/// </summary>
|
|
private readonly IUserDataManager _userDataManager;
|
|
|
|
/// <summary>
|
|
/// The _logger
|
|
/// </summary>
|
|
private readonly ILogger _logger;
|
|
|
|
private readonly ILibraryManager _libraryManager;
|
|
private readonly IUserManager _userManager;
|
|
private readonly IMusicManager _musicManager;
|
|
private readonly IDtoService _dtoService;
|
|
private readonly IImageProcessor _imageProcessor;
|
|
private readonly IMediaSourceManager _mediaSourceManager;
|
|
|
|
private readonly IHttpClient _httpClient;
|
|
private readonly IJsonSerializer _jsonSerializer;
|
|
private readonly IServerApplicationHost _appHost;
|
|
|
|
private readonly IAuthenticationRepository _authRepo;
|
|
private readonly IDeviceManager _deviceManager;
|
|
private readonly ITimerFactory _timerFactory;
|
|
|
|
/// <summary>
|
|
/// The _active connections
|
|
/// </summary>
|
|
private readonly ConcurrentDictionary<string, SessionInfo> _activeConnections =
|
|
new ConcurrentDictionary<string, SessionInfo>(StringComparer.OrdinalIgnoreCase);
|
|
|
|
public event EventHandler<GenericEventArgs<AuthenticationRequest>> AuthenticationFailed;
|
|
|
|
public event EventHandler<GenericEventArgs<AuthenticationResult>> AuthenticationSucceeded;
|
|
|
|
/// <summary>
|
|
/// Occurs when [playback start].
|
|
/// </summary>
|
|
public event EventHandler<PlaybackProgressEventArgs> PlaybackStart;
|
|
/// <summary>
|
|
/// Occurs when [playback progress].
|
|
/// </summary>
|
|
public event EventHandler<PlaybackProgressEventArgs> PlaybackProgress;
|
|
/// <summary>
|
|
/// Occurs when [playback stopped].
|
|
/// </summary>
|
|
public event EventHandler<PlaybackStopEventArgs> PlaybackStopped;
|
|
|
|
public event EventHandler<SessionEventArgs> SessionStarted;
|
|
public event EventHandler<SessionEventArgs> CapabilitiesChanged;
|
|
public event EventHandler<SessionEventArgs> SessionEnded;
|
|
public event EventHandler<SessionEventArgs> SessionActivity;
|
|
|
|
public SessionManager(
|
|
IUserDataManager userDataManager,
|
|
ILoggerFactory loggerFactory,
|
|
ILibraryManager libraryManager,
|
|
IUserManager userManager,
|
|
IMusicManager musicManager,
|
|
IDtoService dtoService,
|
|
IImageProcessor imageProcessor,
|
|
IJsonSerializer jsonSerializer,
|
|
IServerApplicationHost appHost,
|
|
IHttpClient httpClient,
|
|
IAuthenticationRepository authRepo,
|
|
IDeviceManager deviceManager,
|
|
IMediaSourceManager mediaSourceManager,
|
|
ITimerFactory timerFactory)
|
|
{
|
|
_userDataManager = userDataManager;
|
|
_logger = loggerFactory.CreateLogger(nameof(SessionManager));
|
|
_libraryManager = libraryManager;
|
|
_userManager = userManager;
|
|
_musicManager = musicManager;
|
|
_dtoService = dtoService;
|
|
_imageProcessor = imageProcessor;
|
|
_jsonSerializer = jsonSerializer;
|
|
_appHost = appHost;
|
|
_httpClient = httpClient;
|
|
_authRepo = authRepo;
|
|
_deviceManager = deviceManager;
|
|
_mediaSourceManager = mediaSourceManager;
|
|
_timerFactory = timerFactory;
|
|
_deviceManager.DeviceOptionsUpdated += _deviceManager_DeviceOptionsUpdated;
|
|
}
|
|
|
|
private void _deviceManager_DeviceOptionsUpdated(object sender, GenericEventArgs<Tuple<string, DeviceOptions>> e)
|
|
{
|
|
foreach (var session in Sessions)
|
|
{
|
|
if (string.Equals(session.DeviceId, e.Argument.Item1))
|
|
{
|
|
if (!string.IsNullOrWhiteSpace(e.Argument.Item2.CustomName))
|
|
{
|
|
session.HasCustomDeviceName = true;
|
|
session.DeviceName = e.Argument.Item2.CustomName;
|
|
}
|
|
else
|
|
{
|
|
session.HasCustomDeviceName = false;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private bool _disposed;
|
|
public void Dispose()
|
|
{
|
|
_disposed = true;
|
|
_deviceManager.DeviceOptionsUpdated -= _deviceManager_DeviceOptionsUpdated;
|
|
}
|
|
|
|
public void CheckDisposed()
|
|
{
|
|
if (_disposed)
|
|
{
|
|
throw new ObjectDisposedException(GetType().Name);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets all connections.
|
|
/// </summary>
|
|
/// <value>All connections.</value>
|
|
public IEnumerable<SessionInfo> Sessions => _activeConnections.Values.OrderByDescending(c => c.LastActivityDate).ToList();
|
|
|
|
private void OnSessionStarted(SessionInfo info)
|
|
{
|
|
if (!string.IsNullOrEmpty(info.DeviceId))
|
|
{
|
|
var capabilities = GetSavedCapabilities(info.DeviceId);
|
|
|
|
if (capabilities != null)
|
|
{
|
|
ReportCapabilities(info, capabilities, false);
|
|
}
|
|
}
|
|
|
|
EventHelper.QueueEventIfNotNull(SessionStarted, this, new SessionEventArgs
|
|
{
|
|
SessionInfo = info
|
|
|
|
}, _logger);
|
|
}
|
|
|
|
private void OnSessionEnded(SessionInfo info)
|
|
{
|
|
EventHelper.QueueEventIfNotNull(SessionEnded, this, new SessionEventArgs
|
|
{
|
|
SessionInfo = info
|
|
|
|
}, _logger);
|
|
|
|
info.Dispose();
|
|
}
|
|
|
|
public void UpdateDeviceName(string sessionId, string deviceName)
|
|
{
|
|
var session = GetSession(sessionId);
|
|
|
|
var key = GetSessionKey(session.Client, session.DeviceId);
|
|
|
|
if (session != null)
|
|
{
|
|
session.DeviceName = deviceName;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Logs the user activity.
|
|
/// </summary>
|
|
/// <param name="appName">Type of the client.</param>
|
|
/// <param name="appVersion">The app version.</param>
|
|
/// <param name="deviceId">The device id.</param>
|
|
/// <param name="deviceName">Name of the device.</param>
|
|
/// <param name="remoteEndPoint">The remote end point.</param>
|
|
/// <param name="user">The user.</param>
|
|
/// <returns>Task.</returns>
|
|
/// <exception cref="ArgumentNullException">user</exception>
|
|
/// <exception cref="UnauthorizedAccessException"></exception>
|
|
public SessionInfo LogSessionActivity(string appName,
|
|
string appVersion,
|
|
string deviceId,
|
|
string deviceName,
|
|
string remoteEndPoint,
|
|
User user)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (string.IsNullOrEmpty(appName))
|
|
{
|
|
throw new ArgumentNullException(nameof(appName));
|
|
}
|
|
if (string.IsNullOrEmpty(appVersion))
|
|
{
|
|
throw new ArgumentNullException(nameof(appVersion));
|
|
}
|
|
if (string.IsNullOrEmpty(deviceId))
|
|
{
|
|
throw new ArgumentNullException(nameof(deviceId));
|
|
}
|
|
|
|
var activityDate = DateTime.UtcNow;
|
|
var session = GetSessionInfo(appName, appVersion, deviceId, deviceName, remoteEndPoint, user);
|
|
var lastActivityDate = session.LastActivityDate;
|
|
session.LastActivityDate = activityDate;
|
|
|
|
if (user != null)
|
|
{
|
|
var userLastActivityDate = user.LastActivityDate ?? DateTime.MinValue;
|
|
user.LastActivityDate = activityDate;
|
|
|
|
if ((activityDate - userLastActivityDate).TotalSeconds > 60)
|
|
{
|
|
try
|
|
{
|
|
_userManager.UpdateUser(user);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error updating user", ex);
|
|
}
|
|
}
|
|
}
|
|
|
|
if ((activityDate - lastActivityDate).TotalSeconds > 10)
|
|
{
|
|
SessionActivity?.Invoke(this, new SessionEventArgs
|
|
{
|
|
SessionInfo = session
|
|
});
|
|
}
|
|
|
|
return session;
|
|
}
|
|
|
|
public void CloseIfNeeded(SessionInfo session)
|
|
{
|
|
if (!session.SessionControllers.Any(i => i.IsSessionActive))
|
|
{
|
|
var key = GetSessionKey(session.Client, session.DeviceId);
|
|
|
|
_activeConnections.TryRemove(key, out var removed);
|
|
|
|
OnSessionEnded(session);
|
|
}
|
|
}
|
|
|
|
public void ReportSessionEnded(string sessionId)
|
|
{
|
|
CheckDisposed();
|
|
var session = GetSession(sessionId, false);
|
|
|
|
if (session != null)
|
|
{
|
|
var key = GetSessionKey(session.Client, session.DeviceId);
|
|
|
|
_activeConnections.TryRemove(key, out var removed);
|
|
|
|
OnSessionEnded(session);
|
|
}
|
|
}
|
|
|
|
private Task<MediaSourceInfo> GetMediaSource(BaseItem item, string mediaSourceId, string liveStreamId)
|
|
{
|
|
return _mediaSourceManager.GetMediaSource(item, mediaSourceId, liveStreamId, false, CancellationToken.None);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Updates the now playing item id.
|
|
/// </summary>
|
|
private async Task UpdateNowPlayingItem(SessionInfo session, PlaybackProgressInfo info, BaseItem libraryItem, bool updateLastCheckInTime)
|
|
{
|
|
if (string.IsNullOrEmpty(info.MediaSourceId))
|
|
{
|
|
info.MediaSourceId = info.ItemId.ToString("N");
|
|
}
|
|
|
|
if (!info.ItemId.Equals(Guid.Empty) && info.Item == null && libraryItem != null)
|
|
{
|
|
var current = session.NowPlayingItem;
|
|
|
|
if (current == null || !info.ItemId.Equals(current.Id))
|
|
{
|
|
var runtimeTicks = libraryItem.RunTimeTicks;
|
|
|
|
MediaSourceInfo mediaSource = null;
|
|
var hasMediaSources = libraryItem as IHasMediaSources;
|
|
if (hasMediaSources != null)
|
|
{
|
|
mediaSource = await GetMediaSource(libraryItem, info.MediaSourceId, info.LiveStreamId).ConfigureAwait(false);
|
|
|
|
if (mediaSource != null)
|
|
{
|
|
runtimeTicks = mediaSource.RunTimeTicks;
|
|
}
|
|
}
|
|
|
|
info.Item = GetItemInfo(libraryItem, mediaSource);
|
|
|
|
info.Item.RunTimeTicks = runtimeTicks;
|
|
}
|
|
else
|
|
{
|
|
info.Item = current;
|
|
}
|
|
}
|
|
|
|
session.NowPlayingItem = info.Item;
|
|
session.LastActivityDate = DateTime.UtcNow;
|
|
|
|
if (updateLastCheckInTime)
|
|
{
|
|
session.LastPlaybackCheckIn = DateTime.UtcNow;
|
|
}
|
|
|
|
session.PlayState.IsPaused = info.IsPaused;
|
|
session.PlayState.PositionTicks = info.PositionTicks;
|
|
session.PlayState.MediaSourceId = info.MediaSourceId;
|
|
session.PlayState.CanSeek = info.CanSeek;
|
|
session.PlayState.IsMuted = info.IsMuted;
|
|
session.PlayState.VolumeLevel = info.VolumeLevel;
|
|
session.PlayState.AudioStreamIndex = info.AudioStreamIndex;
|
|
session.PlayState.SubtitleStreamIndex = info.SubtitleStreamIndex;
|
|
session.PlayState.PlayMethod = info.PlayMethod;
|
|
session.PlayState.RepeatMode = info.RepeatMode;
|
|
session.PlaylistItemId = info.PlaylistItemId;
|
|
|
|
var nowPlayingQueue = info.NowPlayingQueue;
|
|
|
|
if (nowPlayingQueue != null)
|
|
{
|
|
session.NowPlayingQueue = nowPlayingQueue;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Removes the now playing item id.
|
|
/// </summary>
|
|
/// <param name="session">The session.</param>
|
|
/// <exception cref="ArgumentNullException">item</exception>
|
|
private void RemoveNowPlayingItem(SessionInfo session)
|
|
{
|
|
session.NowPlayingItem = null;
|
|
session.PlayState = new PlayerStateInfo();
|
|
|
|
if (!string.IsNullOrEmpty(session.DeviceId))
|
|
{
|
|
ClearTranscodingInfo(session.DeviceId);
|
|
}
|
|
}
|
|
|
|
private static string GetSessionKey(string appName, string deviceId)
|
|
{
|
|
return appName + deviceId;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets the connection.
|
|
/// </summary>
|
|
/// <param name="appName">Type of the client.</param>
|
|
/// <param name="appVersion">The app version.</param>
|
|
/// <param name="deviceId">The device id.</param>
|
|
/// <param name="deviceName">Name of the device.</param>
|
|
/// <param name="remoteEndPoint">The remote end point.</param>
|
|
/// <param name="user">The user.</param>
|
|
/// <returns>SessionInfo.</returns>
|
|
private SessionInfo GetSessionInfo(string appName, string appVersion, string deviceId, string deviceName, string remoteEndPoint, User user)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (string.IsNullOrEmpty(deviceId))
|
|
{
|
|
throw new ArgumentNullException(nameof(deviceId));
|
|
}
|
|
var key = GetSessionKey(appName, deviceId);
|
|
|
|
CheckDisposed();
|
|
|
|
var sessionInfo = _activeConnections.GetOrAdd(key, k =>
|
|
{
|
|
return CreateSession(k, appName, appVersion, deviceId, deviceName, remoteEndPoint, user);
|
|
});
|
|
|
|
sessionInfo.UserId = user == null ? Guid.Empty : user.Id;
|
|
sessionInfo.UserName = user == null ? null : user.Name;
|
|
sessionInfo.UserPrimaryImageTag = user == null ? null : GetImageCacheTag(user, ImageType.Primary);
|
|
sessionInfo.RemoteEndPoint = remoteEndPoint;
|
|
sessionInfo.Client = appName;
|
|
|
|
if (!sessionInfo.HasCustomDeviceName || string.IsNullOrEmpty(sessionInfo.DeviceName))
|
|
{
|
|
sessionInfo.DeviceName = deviceName;
|
|
}
|
|
|
|
sessionInfo.ApplicationVersion = appVersion;
|
|
|
|
if (user == null)
|
|
{
|
|
sessionInfo.AdditionalUsers = new SessionUserInfo[] { };
|
|
}
|
|
|
|
return sessionInfo;
|
|
}
|
|
|
|
private SessionInfo CreateSession(string key, string appName, string appVersion, string deviceId, string deviceName, string remoteEndPoint, User user)
|
|
{
|
|
var sessionInfo = new SessionInfo(this, _logger)
|
|
{
|
|
Client = appName,
|
|
DeviceId = deviceId,
|
|
ApplicationVersion = appVersion,
|
|
Id = key.GetMD5().ToString("N"),
|
|
ServerId = _appHost.SystemId
|
|
};
|
|
|
|
var username = user == null ? null : user.Name;
|
|
|
|
sessionInfo.UserId = user == null ? Guid.Empty : user.Id;
|
|
sessionInfo.UserName = username;
|
|
sessionInfo.UserPrimaryImageTag = user == null ? null : GetImageCacheTag(user, ImageType.Primary);
|
|
sessionInfo.RemoteEndPoint = remoteEndPoint;
|
|
|
|
if (string.IsNullOrEmpty(deviceName))
|
|
{
|
|
deviceName = "Network Device";
|
|
}
|
|
|
|
var deviceOptions = _deviceManager.GetDeviceOptions(deviceId);
|
|
if (string.IsNullOrEmpty(deviceOptions.CustomName))
|
|
{
|
|
sessionInfo.DeviceName = deviceName;
|
|
}
|
|
else
|
|
{
|
|
sessionInfo.DeviceName = deviceOptions.CustomName;
|
|
sessionInfo.HasCustomDeviceName = true;
|
|
}
|
|
|
|
OnSessionStarted(sessionInfo);
|
|
return sessionInfo;
|
|
}
|
|
|
|
private List<User> GetUsers(SessionInfo session)
|
|
{
|
|
var users = new List<User>();
|
|
|
|
if (!session.UserId.Equals(Guid.Empty))
|
|
{
|
|
var user = _userManager.GetUserById(session.UserId);
|
|
|
|
if (user == null)
|
|
{
|
|
throw new InvalidOperationException("User not found");
|
|
}
|
|
|
|
users.Add(user);
|
|
|
|
users.AddRange(session.AdditionalUsers
|
|
.Select(i => _userManager.GetUserById(i.UserId))
|
|
.Where(i => i != null));
|
|
}
|
|
|
|
return users;
|
|
}
|
|
|
|
private ITimer _idleTimer;
|
|
|
|
private void StartIdleCheckTimer()
|
|
{
|
|
if (_idleTimer == null)
|
|
{
|
|
_idleTimer = _timerFactory.Create(CheckForIdlePlayback, null, TimeSpan.FromMinutes(5), TimeSpan.FromMinutes(5));
|
|
}
|
|
}
|
|
private void StopIdleCheckTimer()
|
|
{
|
|
if (_idleTimer != null)
|
|
{
|
|
_idleTimer.Dispose();
|
|
_idleTimer = null;
|
|
}
|
|
}
|
|
|
|
private async void CheckForIdlePlayback(object state)
|
|
{
|
|
var playingSessions = Sessions.Where(i => i.NowPlayingItem != null)
|
|
.ToList();
|
|
|
|
if (playingSessions.Count > 0)
|
|
{
|
|
var idle = playingSessions
|
|
.Where(i => (DateTime.UtcNow - i.LastPlaybackCheckIn).TotalMinutes > 5)
|
|
.ToList();
|
|
|
|
foreach (var session in idle)
|
|
{
|
|
_logger.LogDebug("Session {0} has gone idle while playing", session.Id);
|
|
|
|
try
|
|
{
|
|
await OnPlaybackStopped(new PlaybackStopInfo
|
|
{
|
|
Item = session.NowPlayingItem,
|
|
ItemId = session.NowPlayingItem == null ? Guid.Empty : session.NowPlayingItem.Id,
|
|
SessionId = session.Id,
|
|
MediaSourceId = session.PlayState == null ? null : session.PlayState.MediaSourceId,
|
|
PositionTicks = session.PlayState == null ? null : session.PlayState.PositionTicks
|
|
});
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogDebug("Error calling OnPlaybackStopped", ex);
|
|
}
|
|
}
|
|
|
|
playingSessions = Sessions.Where(i => i.NowPlayingItem != null)
|
|
.ToList();
|
|
}
|
|
|
|
if (playingSessions.Count == 0)
|
|
{
|
|
StopIdleCheckTimer();
|
|
}
|
|
}
|
|
|
|
private BaseItem GetNowPlayingItem(SessionInfo session, Guid itemId)
|
|
{
|
|
var item = session.FullNowPlayingItem;
|
|
if (item != null && item.Id.Equals(itemId))
|
|
{
|
|
return item;
|
|
}
|
|
|
|
item = _libraryManager.GetItemById(itemId);
|
|
|
|
session.FullNowPlayingItem = item;
|
|
|
|
return item;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Used to report that playback has started for an item
|
|
/// </summary>
|
|
/// <param name="info">The info.</param>
|
|
/// <returns>Task.</returns>
|
|
/// <exception cref="ArgumentNullException">info</exception>
|
|
public async Task OnPlaybackStart(PlaybackStartInfo info)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (info == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(info));
|
|
}
|
|
|
|
var session = GetSession(info.SessionId);
|
|
|
|
var libraryItem = info.ItemId.Equals(Guid.Empty)
|
|
? null
|
|
: GetNowPlayingItem(session, info.ItemId);
|
|
|
|
await UpdateNowPlayingItem(session, info, libraryItem, true).ConfigureAwait(false);
|
|
|
|
if (!string.IsNullOrEmpty(session.DeviceId) && info.PlayMethod != PlayMethod.Transcode)
|
|
{
|
|
ClearTranscodingInfo(session.DeviceId);
|
|
}
|
|
|
|
session.StartAutomaticProgress(_timerFactory, info);
|
|
|
|
var users = GetUsers(session);
|
|
|
|
if (libraryItem != null)
|
|
{
|
|
foreach (var user in users)
|
|
{
|
|
OnPlaybackStart(user, libraryItem);
|
|
}
|
|
}
|
|
|
|
// Nothing to save here
|
|
// Fire events to inform plugins
|
|
EventHelper.QueueEventIfNotNull(PlaybackStart, this, new PlaybackProgressEventArgs
|
|
{
|
|
Item = libraryItem,
|
|
Users = users,
|
|
MediaSourceId = info.MediaSourceId,
|
|
MediaInfo = info.Item,
|
|
DeviceName = session.DeviceName,
|
|
ClientName = session.Client,
|
|
DeviceId = session.DeviceId,
|
|
Session = session
|
|
|
|
}, _logger);
|
|
|
|
StartIdleCheckTimer();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Called when [playback start].
|
|
/// </summary>
|
|
/// <param name="user">The user object.</param>
|
|
/// <param name="item">The item.</param>
|
|
private void OnPlaybackStart(User user, BaseItem item)
|
|
{
|
|
var data = _userDataManager.GetUserData(user, item);
|
|
|
|
data.PlayCount++;
|
|
data.LastPlayedDate = DateTime.UtcNow;
|
|
|
|
if (item.SupportsPlayedStatus)
|
|
{
|
|
if (!(item is Video))
|
|
{
|
|
data.Played = true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
data.Played = false;
|
|
}
|
|
|
|
_userDataManager.SaveUserData(user, item, data, UserDataSaveReason.PlaybackStart, CancellationToken.None);
|
|
}
|
|
|
|
public Task OnPlaybackProgress(PlaybackProgressInfo info)
|
|
{
|
|
return OnPlaybackProgress(info, false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Used to report playback progress for an item
|
|
/// </summary>
|
|
public async Task OnPlaybackProgress(PlaybackProgressInfo info, bool isAutomated)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (info == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(info));
|
|
}
|
|
|
|
var session = GetSession(info.SessionId);
|
|
|
|
var libraryItem = info.ItemId.Equals(Guid.Empty)
|
|
? null
|
|
: GetNowPlayingItem(session, info.ItemId);
|
|
|
|
await UpdateNowPlayingItem(session, info, libraryItem, !isAutomated).ConfigureAwait(false);
|
|
|
|
var users = GetUsers(session);
|
|
|
|
// only update saved user data on actual check-ins, not automated ones
|
|
if (libraryItem != null && !isAutomated)
|
|
{
|
|
foreach (var user in users)
|
|
{
|
|
OnPlaybackProgress(user, libraryItem, info);
|
|
}
|
|
}
|
|
|
|
PlaybackProgress?.Invoke(this, new PlaybackProgressEventArgs
|
|
{
|
|
Item = libraryItem,
|
|
Users = users,
|
|
PlaybackPositionTicks = session.PlayState.PositionTicks,
|
|
MediaSourceId = session.PlayState.MediaSourceId,
|
|
MediaInfo = info.Item,
|
|
DeviceName = session.DeviceName,
|
|
ClientName = session.Client,
|
|
DeviceId = session.DeviceId,
|
|
IsPaused = info.IsPaused,
|
|
PlaySessionId = info.PlaySessionId,
|
|
IsAutomated = isAutomated,
|
|
Session = session
|
|
});
|
|
|
|
if (!isAutomated)
|
|
{
|
|
session.StartAutomaticProgress(_timerFactory, info);
|
|
}
|
|
|
|
StartIdleCheckTimer();
|
|
}
|
|
|
|
private void OnPlaybackProgress(User user, BaseItem item, PlaybackProgressInfo info)
|
|
{
|
|
var data = _userDataManager.GetUserData(user, item);
|
|
|
|
var positionTicks = info.PositionTicks;
|
|
|
|
var changed = false;
|
|
|
|
if (positionTicks.HasValue)
|
|
{
|
|
_userDataManager.UpdatePlayState(item, data, positionTicks.Value);
|
|
changed = true;
|
|
}
|
|
|
|
var tracksChanged = UpdatePlaybackSettings(user, info, data);
|
|
if (!tracksChanged)
|
|
{
|
|
changed = true;
|
|
}
|
|
|
|
if (changed)
|
|
{
|
|
_userDataManager.SaveUserData(user, item, data, UserDataSaveReason.PlaybackProgress, CancellationToken.None);
|
|
}
|
|
|
|
}
|
|
|
|
private static bool UpdatePlaybackSettings(User user, PlaybackProgressInfo info, UserItemData data)
|
|
{
|
|
var changed = false;
|
|
|
|
if (user.Configuration.RememberAudioSelections)
|
|
{
|
|
if (data.AudioStreamIndex != info.AudioStreamIndex)
|
|
{
|
|
data.AudioStreamIndex = info.AudioStreamIndex;
|
|
changed = true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (data.AudioStreamIndex.HasValue)
|
|
{
|
|
data.AudioStreamIndex = null;
|
|
changed = true;
|
|
}
|
|
}
|
|
|
|
if (user.Configuration.RememberSubtitleSelections)
|
|
{
|
|
if (data.SubtitleStreamIndex != info.SubtitleStreamIndex)
|
|
{
|
|
data.SubtitleStreamIndex = info.SubtitleStreamIndex;
|
|
changed = true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (data.SubtitleStreamIndex.HasValue)
|
|
{
|
|
data.SubtitleStreamIndex = null;
|
|
changed = true;
|
|
}
|
|
}
|
|
|
|
return changed;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Used to report that playback has ended for an item
|
|
/// </summary>
|
|
/// <param name="info">The info.</param>
|
|
/// <returns>Task.</returns>
|
|
/// <exception cref="ArgumentNullException">info</exception>
|
|
/// <exception cref="ArgumentOutOfRangeException">positionTicks</exception>
|
|
public async Task OnPlaybackStopped(PlaybackStopInfo info)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (info == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(info));
|
|
}
|
|
|
|
if (info.PositionTicks.HasValue && info.PositionTicks.Value < 0)
|
|
{
|
|
throw new ArgumentOutOfRangeException(nameof(info), "The PlaybackStopInfo's PositionTicks was negative.");
|
|
}
|
|
|
|
var session = GetSession(info.SessionId);
|
|
|
|
session.StopAutomaticProgress();
|
|
|
|
var libraryItem = info.ItemId.Equals(Guid.Empty)
|
|
? null
|
|
: GetNowPlayingItem(session, info.ItemId);
|
|
|
|
// Normalize
|
|
if (string.IsNullOrEmpty(info.MediaSourceId))
|
|
{
|
|
info.MediaSourceId = info.ItemId.ToString("N");
|
|
}
|
|
|
|
if (!info.ItemId.Equals(Guid.Empty) && info.Item == null && libraryItem != null)
|
|
{
|
|
var current = session.NowPlayingItem;
|
|
|
|
if (current == null || !info.ItemId.Equals(current.Id))
|
|
{
|
|
MediaSourceInfo mediaSource = null;
|
|
|
|
var hasMediaSources = libraryItem as IHasMediaSources;
|
|
if (hasMediaSources != null)
|
|
{
|
|
mediaSource = await GetMediaSource(libraryItem, info.MediaSourceId, info.LiveStreamId).ConfigureAwait(false);
|
|
}
|
|
|
|
info.Item = GetItemInfo(libraryItem, mediaSource);
|
|
}
|
|
else
|
|
{
|
|
info.Item = current;
|
|
}
|
|
}
|
|
|
|
if (info.Item != null)
|
|
{
|
|
var msString = info.PositionTicks.HasValue ? (info.PositionTicks.Value / 10000).ToString(CultureInfo.InvariantCulture) : "unknown";
|
|
|
|
_logger.LogInformation("Playback stopped reported by app {0} {1} playing {2}. Stopped at {3} ms",
|
|
session.Client,
|
|
session.ApplicationVersion,
|
|
info.Item.Name,
|
|
msString);
|
|
}
|
|
|
|
if (info.NowPlayingQueue != null)
|
|
{
|
|
session.NowPlayingQueue = info.NowPlayingQueue;
|
|
}
|
|
|
|
session.PlaylistItemId = info.PlaylistItemId;
|
|
|
|
RemoveNowPlayingItem(session);
|
|
|
|
var users = GetUsers(session);
|
|
var playedToCompletion = false;
|
|
|
|
if (libraryItem != null)
|
|
{
|
|
foreach (var user in users)
|
|
{
|
|
playedToCompletion = OnPlaybackStopped(user, libraryItem, info.PositionTicks, info.Failed);
|
|
}
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(info.LiveStreamId))
|
|
{
|
|
try
|
|
{
|
|
await _mediaSourceManager.CloseLiveStream(info.LiveStreamId).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error closing live stream", ex);
|
|
}
|
|
}
|
|
|
|
EventHelper.QueueEventIfNotNull(PlaybackStopped, this, new PlaybackStopEventArgs
|
|
{
|
|
Item = libraryItem,
|
|
Users = users,
|
|
PlaybackPositionTicks = info.PositionTicks,
|
|
PlayedToCompletion = playedToCompletion,
|
|
MediaSourceId = info.MediaSourceId,
|
|
MediaInfo = info.Item,
|
|
DeviceName = session.DeviceName,
|
|
ClientName = session.Client,
|
|
DeviceId = session.DeviceId,
|
|
Session = session
|
|
|
|
}, _logger);
|
|
}
|
|
|
|
private bool OnPlaybackStopped(User user, BaseItem item, long? positionTicks, bool playbackFailed)
|
|
{
|
|
bool playedToCompletion = false;
|
|
|
|
if (!playbackFailed)
|
|
{
|
|
var data = _userDataManager.GetUserData(user, item);
|
|
|
|
if (positionTicks.HasValue)
|
|
{
|
|
playedToCompletion = _userDataManager.UpdatePlayState(item, data, positionTicks.Value);
|
|
}
|
|
else
|
|
{
|
|
// If the client isn't able to report this, then we'll just have to make an assumption
|
|
data.PlayCount++;
|
|
data.Played = item.SupportsPlayedStatus;
|
|
data.PlaybackPositionTicks = 0;
|
|
playedToCompletion = true;
|
|
}
|
|
|
|
_userDataManager.SaveUserData(user, item, data, UserDataSaveReason.PlaybackFinished, CancellationToken.None);
|
|
}
|
|
|
|
return playedToCompletion;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets the session.
|
|
/// </summary>
|
|
/// <param name="sessionId">The session identifier.</param>
|
|
/// <param name="throwOnMissing">if set to <c>true</c> [throw on missing].</param>
|
|
/// <returns>SessionInfo.</returns>
|
|
/// <exception cref="ResourceNotFoundException"></exception>
|
|
private SessionInfo GetSession(string sessionId, bool throwOnMissing = true)
|
|
{
|
|
var session = Sessions.FirstOrDefault(i => string.Equals(i.Id, sessionId));
|
|
|
|
if (session == null && throwOnMissing)
|
|
{
|
|
throw new ResourceNotFoundException(string.Format("Session {0} not found.", sessionId));
|
|
}
|
|
|
|
return session;
|
|
}
|
|
|
|
private SessionInfo GetSessionToRemoteControl(string sessionId)
|
|
{
|
|
// Accept either device id or session id
|
|
var session = Sessions.FirstOrDefault(i => string.Equals(i.Id, sessionId));
|
|
|
|
if (session == null)
|
|
{
|
|
throw new ResourceNotFoundException(string.Format("Session {0} not found.", sessionId));
|
|
}
|
|
|
|
return session;
|
|
}
|
|
|
|
public Task SendMessageCommand(string controllingSessionId, string sessionId, MessageCommand command, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var generalCommand = new GeneralCommand
|
|
{
|
|
Name = GeneralCommandType.DisplayMessage.ToString()
|
|
};
|
|
|
|
generalCommand.Arguments["Header"] = command.Header;
|
|
generalCommand.Arguments["Text"] = command.Text;
|
|
|
|
if (command.TimeoutMs.HasValue)
|
|
{
|
|
generalCommand.Arguments["TimeoutMs"] = command.TimeoutMs.Value.ToString(CultureInfo.InvariantCulture);
|
|
}
|
|
|
|
return SendGeneralCommand(controllingSessionId, sessionId, generalCommand, cancellationToken);
|
|
}
|
|
|
|
public Task SendGeneralCommand(string controllingSessionId, string sessionId, GeneralCommand command, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSessionToRemoteControl(sessionId);
|
|
|
|
if (!string.IsNullOrEmpty(controllingSessionId))
|
|
{
|
|
var controllingSession = GetSession(controllingSessionId);
|
|
AssertCanControl(session, controllingSession);
|
|
}
|
|
|
|
return SendMessageToSession(session, "GeneralCommand", command, cancellationToken);
|
|
}
|
|
|
|
private static async Task SendMessageToSession<T>(SessionInfo session, string name, T data, CancellationToken cancellationToken)
|
|
{
|
|
var controllers = session.SessionControllers.ToArray();
|
|
var messageId = Guid.NewGuid().ToString("N");
|
|
|
|
foreach (var controller in controllers)
|
|
{
|
|
await controller.SendMessage(name, messageId, data, controllers, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
public async Task SendPlayCommand(string controllingSessionId, string sessionId, PlayRequest command, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSessionToRemoteControl(sessionId);
|
|
|
|
var user = !session.UserId.Equals(Guid.Empty) ? _userManager.GetUserById(session.UserId) : null;
|
|
|
|
List<BaseItem> items;
|
|
|
|
if (command.PlayCommand == PlayCommand.PlayInstantMix)
|
|
{
|
|
items = command.ItemIds.SelectMany(i => TranslateItemForInstantMix(i, user))
|
|
.ToList();
|
|
|
|
command.PlayCommand = PlayCommand.PlayNow;
|
|
}
|
|
else
|
|
{
|
|
var list = new List<BaseItem>();
|
|
foreach (var itemId in command.ItemIds)
|
|
{
|
|
var subItems = TranslateItemForPlayback(itemId, user);
|
|
list.AddRange(subItems);
|
|
}
|
|
|
|
items = list;
|
|
}
|
|
|
|
if (command.PlayCommand == PlayCommand.PlayShuffle)
|
|
{
|
|
items = items.OrderBy(i => Guid.NewGuid()).ToList();
|
|
command.PlayCommand = PlayCommand.PlayNow;
|
|
}
|
|
|
|
command.ItemIds = items.Select(i => i.Id).ToArray();
|
|
|
|
if (user != null)
|
|
{
|
|
if (items.Any(i => i.GetPlayAccess(user) != PlayAccess.Full))
|
|
{
|
|
throw new ArgumentException(string.Format("{0} is not allowed to play media.", user.Name));
|
|
}
|
|
}
|
|
|
|
if (user != null && command.ItemIds.Length == 1 && user.Configuration.EnableNextEpisodeAutoPlay)
|
|
{
|
|
var episode = _libraryManager.GetItemById(command.ItemIds[0]) as Episode;
|
|
if (episode != null)
|
|
{
|
|
var series = episode.Series;
|
|
if (series != null)
|
|
{
|
|
var episodes = series.GetEpisodes(user, new DtoOptions(false)
|
|
{
|
|
EnableImages = false
|
|
})
|
|
.Where(i => !i.IsVirtualItem)
|
|
.SkipWhile(i => i.Id != episode.Id)
|
|
.ToList();
|
|
|
|
if (episodes.Count > 0)
|
|
{
|
|
command.ItemIds = episodes.Select(i => i.Id).ToArray();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(controllingSessionId))
|
|
{
|
|
var controllingSession = GetSession(controllingSessionId);
|
|
AssertCanControl(session, controllingSession);
|
|
if (!controllingSession.UserId.Equals(Guid.Empty))
|
|
{
|
|
command.ControllingUserId = controllingSession.UserId;
|
|
}
|
|
}
|
|
|
|
await SendMessageToSession(session, "Play", command, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
private IList<BaseItem> TranslateItemForPlayback(Guid id, User user)
|
|
{
|
|
var item = _libraryManager.GetItemById(id);
|
|
|
|
if (item == null)
|
|
{
|
|
_logger.LogError("A non-existant item Id {0} was passed into TranslateItemForPlayback", id);
|
|
return new List<BaseItem>();
|
|
}
|
|
|
|
var byName = item as IItemByName;
|
|
|
|
if (byName != null)
|
|
{
|
|
return byName.GetTaggedItems(new InternalItemsQuery(user)
|
|
{
|
|
IsFolder = false,
|
|
Recursive = true,
|
|
DtoOptions = new DtoOptions(false)
|
|
{
|
|
EnableImages = false,
|
|
Fields = new ItemFields[]
|
|
{
|
|
ItemFields.SortName
|
|
}
|
|
},
|
|
IsVirtualItem = false,
|
|
OrderBy = new ValueTuple<string, SortOrder>[] { new ValueTuple<string, SortOrder>(ItemSortBy.SortName, SortOrder.Ascending) }
|
|
});
|
|
}
|
|
|
|
if (item.IsFolder)
|
|
{
|
|
var folder = (Folder)item;
|
|
|
|
return folder.GetItemList(new InternalItemsQuery(user)
|
|
{
|
|
Recursive = true,
|
|
IsFolder = false,
|
|
DtoOptions = new DtoOptions(false)
|
|
{
|
|
EnableImages = false,
|
|
Fields = new ItemFields[]
|
|
{
|
|
ItemFields.SortName
|
|
}
|
|
},
|
|
IsVirtualItem = false,
|
|
OrderBy = new ValueTuple<string, SortOrder>[] { new ValueTuple<string, SortOrder>(ItemSortBy.SortName, SortOrder.Ascending) }
|
|
|
|
});
|
|
}
|
|
|
|
return new List<BaseItem> { item };
|
|
}
|
|
|
|
private IEnumerable<BaseItem> TranslateItemForInstantMix(Guid id, User user)
|
|
{
|
|
var item = _libraryManager.GetItemById(id);
|
|
|
|
if (item == null)
|
|
{
|
|
_logger.LogError("A non-existant item Id {0} was passed into TranslateItemForInstantMix", id);
|
|
return new List<BaseItem>();
|
|
}
|
|
|
|
return _musicManager.GetInstantMixFromItem(item, user, new DtoOptions(false) { EnableImages = false });
|
|
}
|
|
|
|
public Task SendBrowseCommand(string controllingSessionId, string sessionId, BrowseRequest command, CancellationToken cancellationToken)
|
|
{
|
|
var generalCommand = new GeneralCommand
|
|
{
|
|
Name = GeneralCommandType.DisplayContent.ToString()
|
|
};
|
|
|
|
generalCommand.Arguments["ItemId"] = command.ItemId;
|
|
generalCommand.Arguments["ItemName"] = command.ItemName;
|
|
generalCommand.Arguments["ItemType"] = command.ItemType;
|
|
|
|
return SendGeneralCommand(controllingSessionId, sessionId, generalCommand, cancellationToken);
|
|
}
|
|
|
|
public Task SendPlaystateCommand(string controllingSessionId, string sessionId, PlaystateRequest command, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSessionToRemoteControl(sessionId);
|
|
|
|
if (!string.IsNullOrEmpty(controllingSessionId))
|
|
{
|
|
var controllingSession = GetSession(controllingSessionId);
|
|
AssertCanControl(session, controllingSession);
|
|
if (!controllingSession.UserId.Equals(Guid.Empty))
|
|
{
|
|
command.ControllingUserId = controllingSession.UserId.ToString("N");
|
|
}
|
|
}
|
|
|
|
return SendMessageToSession(session, "Playstate", command, cancellationToken);
|
|
}
|
|
|
|
private void AssertCanControl(SessionInfo session, SessionInfo controllingSession)
|
|
{
|
|
if (session == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(session));
|
|
}
|
|
if (controllingSession == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(controllingSession));
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Sends the restart required message.
|
|
/// </summary>
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
/// <returns>Task.</returns>
|
|
public async Task SendRestartRequiredNotification(CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions.ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, "RestartRequired", string.Empty, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error in SendRestartRequiredNotification.", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
await Task.WhenAll(tasks).ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Sends the server shutdown notification.
|
|
/// </summary>
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
/// <returns>Task.</returns>
|
|
public Task SendServerShutdownNotification(CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions.ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, "ServerShuttingDown", string.Empty, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error in SendServerShutdownNotification.", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Sends the server restart notification.
|
|
/// </summary>
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
/// <returns>Task.</returns>
|
|
public Task SendServerRestartNotification(CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
_logger.LogDebug("Beginning SendServerRestartNotification");
|
|
|
|
var sessions = Sessions.ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, "ServerRestarting", string.Empty, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error in SendServerRestartNotification.", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds the additional user.
|
|
/// </summary>
|
|
/// <param name="sessionId">The session identifier.</param>
|
|
/// <param name="userId">The user identifier.</param>
|
|
/// <exception cref="UnauthorizedAccessException">Cannot modify additional users without authenticating first.</exception>
|
|
/// <exception cref="ArgumentException">The requested user is already the primary user of the session.</exception>
|
|
public void AddAdditionalUser(string sessionId, Guid userId)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSession(sessionId);
|
|
|
|
if (session.UserId.Equals(userId))
|
|
{
|
|
throw new ArgumentException("The requested user is already the primary user of the session.");
|
|
}
|
|
|
|
if (session.AdditionalUsers.All(i => !i.UserId.Equals(userId)))
|
|
{
|
|
var user = _userManager.GetUserById(userId);
|
|
|
|
var list = session.AdditionalUsers.ToList();
|
|
|
|
list.Add(new SessionUserInfo
|
|
{
|
|
UserId = userId,
|
|
UserName = user.Name
|
|
});
|
|
|
|
session.AdditionalUsers = list.ToArray();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Removes the additional user.
|
|
/// </summary>
|
|
/// <param name="sessionId">The session identifier.</param>
|
|
/// <param name="userId">The user identifier.</param>
|
|
/// <exception cref="UnauthorizedAccessException">Cannot modify additional users without authenticating first.</exception>
|
|
/// <exception cref="ArgumentException">The requested user is already the primary user of the session.</exception>
|
|
public void RemoveAdditionalUser(string sessionId, Guid userId)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSession(sessionId);
|
|
|
|
if (session.UserId.Equals(userId))
|
|
{
|
|
throw new ArgumentException("The requested user is already the primary user of the session.");
|
|
}
|
|
|
|
var user = session.AdditionalUsers.FirstOrDefault(i => i.UserId.Equals(userId));
|
|
|
|
if (user != null)
|
|
{
|
|
var list = session.AdditionalUsers.ToList();
|
|
list.Remove(user);
|
|
|
|
session.AdditionalUsers = list.ToArray();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Authenticates the new session.
|
|
/// </summary>
|
|
/// <param name="request">The request.</param>
|
|
/// <returns>Task{SessionInfo}.</returns>
|
|
public Task<AuthenticationResult> AuthenticateNewSession(AuthenticationRequest request)
|
|
{
|
|
return AuthenticateNewSessionInternal(request, true);
|
|
}
|
|
|
|
public Task<AuthenticationResult> CreateNewSession(AuthenticationRequest request)
|
|
{
|
|
return AuthenticateNewSessionInternal(request, false);
|
|
}
|
|
|
|
private async Task<AuthenticationResult> AuthenticateNewSessionInternal(AuthenticationRequest request, bool enforcePassword)
|
|
{
|
|
CheckDisposed();
|
|
|
|
User user = null;
|
|
if (!request.UserId.Equals(Guid.Empty))
|
|
{
|
|
user = _userManager.Users
|
|
.FirstOrDefault(i => i.Id == request.UserId);
|
|
}
|
|
|
|
if (user == null)
|
|
{
|
|
user = _userManager.Users
|
|
.FirstOrDefault(i => string.Equals(request.Username, i.Name, StringComparison.OrdinalIgnoreCase));
|
|
}
|
|
|
|
if (user != null)
|
|
{
|
|
// TODO: Move this to userManager?
|
|
if (!string.IsNullOrEmpty(request.DeviceId))
|
|
{
|
|
if (!_deviceManager.CanAccessDevice(user, request.DeviceId))
|
|
{
|
|
throw new SecurityException("User is not allowed access from this device.");
|
|
}
|
|
}
|
|
}
|
|
|
|
if (enforcePassword)
|
|
{
|
|
var result = await _userManager.AuthenticateUser(request.Username, request.Password, request.PasswordSha1, request.RemoteEndPoint, true).ConfigureAwait(false);
|
|
|
|
if (result == null)
|
|
{
|
|
AuthenticationFailed?.Invoke(this, new GenericEventArgs<AuthenticationRequest>(request));
|
|
|
|
throw new SecurityException("Invalid user or password entered.");
|
|
}
|
|
|
|
user = result;
|
|
}
|
|
|
|
var token = GetAuthorizationToken(user, request.DeviceId, request.App, request.AppVersion, request.DeviceName);
|
|
|
|
var session = LogSessionActivity(request.App,
|
|
request.AppVersion,
|
|
request.DeviceId,
|
|
request.DeviceName,
|
|
request.RemoteEndPoint,
|
|
user);
|
|
|
|
var returnResult = new AuthenticationResult
|
|
{
|
|
User = _userManager.GetUserDto(user, request.RemoteEndPoint),
|
|
SessionInfo = session,
|
|
AccessToken = token,
|
|
ServerId = _appHost.SystemId
|
|
};
|
|
|
|
AuthenticationSucceeded?.Invoke(this, new GenericEventArgs<AuthenticationResult>(returnResult));
|
|
|
|
return returnResult;
|
|
}
|
|
|
|
private string GetAuthorizationToken(User user, string deviceId, string app, string appVersion, string deviceName)
|
|
{
|
|
var existing = _authRepo.Get(new AuthenticationInfoQuery
|
|
{
|
|
DeviceId = deviceId,
|
|
UserId = user.Id,
|
|
Limit = 1
|
|
|
|
}).Items.FirstOrDefault();
|
|
|
|
var allExistingForDevice = _authRepo.Get(new AuthenticationInfoQuery
|
|
{
|
|
DeviceId = deviceId
|
|
|
|
}).Items;
|
|
|
|
foreach (var auth in allExistingForDevice)
|
|
{
|
|
if (existing == null || !string.Equals(auth.AccessToken, existing.AccessToken, StringComparison.Ordinal))
|
|
{
|
|
try
|
|
{
|
|
Logout(auth);
|
|
}
|
|
catch
|
|
{
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
if (existing != null)
|
|
{
|
|
_logger.LogInformation("Reissuing access token: " + existing.AccessToken);
|
|
return existing.AccessToken;
|
|
}
|
|
|
|
var now = DateTime.UtcNow;
|
|
|
|
var newToken = new AuthenticationInfo
|
|
{
|
|
AppName = app,
|
|
AppVersion = appVersion,
|
|
DateCreated = now,
|
|
DateLastActivity = now,
|
|
DeviceId = deviceId,
|
|
DeviceName = deviceName,
|
|
UserId = user.Id,
|
|
AccessToken = Guid.NewGuid().ToString("N"),
|
|
UserName = user.Name
|
|
};
|
|
|
|
_logger.LogInformation("Creating new access token for user {0}", user.Id);
|
|
_authRepo.Create(newToken);
|
|
|
|
return newToken.AccessToken;
|
|
}
|
|
|
|
public void Logout(string accessToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
if (string.IsNullOrEmpty(accessToken))
|
|
{
|
|
throw new ArgumentNullException(nameof(accessToken));
|
|
}
|
|
|
|
var existing = _authRepo.Get(new AuthenticationInfoQuery
|
|
{
|
|
Limit = 1,
|
|
AccessToken = accessToken
|
|
|
|
}).Items.FirstOrDefault();
|
|
|
|
if (existing != null)
|
|
{
|
|
Logout(existing);
|
|
}
|
|
}
|
|
|
|
public void Logout(AuthenticationInfo existing)
|
|
{
|
|
CheckDisposed();
|
|
|
|
_logger.LogInformation("Logging out access token {0}", existing.AccessToken);
|
|
|
|
_authRepo.Delete(existing);
|
|
|
|
var sessions = Sessions
|
|
.Where(i => string.Equals(i.DeviceId, existing.DeviceId, StringComparison.OrdinalIgnoreCase))
|
|
.ToList();
|
|
|
|
foreach (var session in sessions)
|
|
{
|
|
try
|
|
{
|
|
ReportSessionEnded(session.Id);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error reporting session ended", ex);
|
|
}
|
|
}
|
|
}
|
|
|
|
public void RevokeUserTokens(Guid userId, string currentAccessToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var existing = _authRepo.Get(new AuthenticationInfoQuery
|
|
{
|
|
UserId = userId
|
|
});
|
|
|
|
foreach (var info in existing.Items)
|
|
{
|
|
if (!string.Equals(currentAccessToken, info.AccessToken, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
Logout(info);
|
|
}
|
|
}
|
|
}
|
|
|
|
public void RevokeToken(string token)
|
|
{
|
|
Logout(token);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Reports the capabilities.
|
|
/// </summary>
|
|
/// <param name="sessionId">The session identifier.</param>
|
|
/// <param name="capabilities">The capabilities.</param>
|
|
public void ReportCapabilities(string sessionId, ClientCapabilities capabilities)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var session = GetSession(sessionId);
|
|
|
|
ReportCapabilities(session, capabilities, true);
|
|
}
|
|
|
|
private void ReportCapabilities(SessionInfo session,
|
|
ClientCapabilities capabilities,
|
|
bool saveCapabilities)
|
|
{
|
|
session.Capabilities = capabilities;
|
|
|
|
if (saveCapabilities)
|
|
{
|
|
CapabilitiesChanged?.Invoke(this, new SessionEventArgs
|
|
{
|
|
SessionInfo = session
|
|
});
|
|
|
|
try
|
|
{
|
|
SaveCapabilities(session.DeviceId, capabilities);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error saving device capabilities", ex);
|
|
}
|
|
}
|
|
}
|
|
|
|
private ClientCapabilities GetSavedCapabilities(string deviceId)
|
|
{
|
|
return _deviceManager.GetCapabilities(deviceId);
|
|
}
|
|
|
|
private void SaveCapabilities(string deviceId, ClientCapabilities capabilities)
|
|
{
|
|
_deviceManager.SaveCapabilities(deviceId, capabilities);
|
|
}
|
|
|
|
private DtoOptions _itemInfoDtoOptions;
|
|
|
|
/// <summary>
|
|
/// Converts a BaseItem to a BaseItemInfo
|
|
/// </summary>
|
|
private BaseItemDto GetItemInfo(BaseItem item, MediaSourceInfo mediaSource)
|
|
{
|
|
if (item == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(item));
|
|
}
|
|
|
|
var dtoOptions = _itemInfoDtoOptions;
|
|
|
|
if (_itemInfoDtoOptions == null)
|
|
{
|
|
dtoOptions = new DtoOptions
|
|
{
|
|
AddProgramRecordingInfo = false
|
|
};
|
|
|
|
var fields = dtoOptions.Fields.ToList();
|
|
|
|
fields.Remove(ItemFields.BasicSyncInfo);
|
|
fields.Remove(ItemFields.CanDelete);
|
|
fields.Remove(ItemFields.CanDownload);
|
|
fields.Remove(ItemFields.ChildCount);
|
|
fields.Remove(ItemFields.CustomRating);
|
|
fields.Remove(ItemFields.DateLastMediaAdded);
|
|
fields.Remove(ItemFields.DateLastRefreshed);
|
|
fields.Remove(ItemFields.DateLastSaved);
|
|
fields.Remove(ItemFields.DisplayPreferencesId);
|
|
fields.Remove(ItemFields.Etag);
|
|
fields.Remove(ItemFields.InheritedParentalRatingValue);
|
|
fields.Remove(ItemFields.ItemCounts);
|
|
fields.Remove(ItemFields.MediaSourceCount);
|
|
fields.Remove(ItemFields.MediaStreams);
|
|
fields.Remove(ItemFields.MediaSources);
|
|
fields.Remove(ItemFields.People);
|
|
fields.Remove(ItemFields.PlayAccess);
|
|
fields.Remove(ItemFields.People);
|
|
fields.Remove(ItemFields.ProductionLocations);
|
|
fields.Remove(ItemFields.RecursiveItemCount);
|
|
fields.Remove(ItemFields.RemoteTrailers);
|
|
fields.Remove(ItemFields.SeasonUserData);
|
|
fields.Remove(ItemFields.Settings);
|
|
fields.Remove(ItemFields.SortName);
|
|
fields.Remove(ItemFields.Tags);
|
|
fields.Remove(ItemFields.ExtraIds);
|
|
|
|
dtoOptions.Fields = fields.ToArray();
|
|
|
|
_itemInfoDtoOptions = dtoOptions;
|
|
}
|
|
|
|
var info = _dtoService.GetBaseItemDto(item, dtoOptions);
|
|
|
|
if (mediaSource != null)
|
|
{
|
|
info.MediaStreams = mediaSource.MediaStreams.ToArray();
|
|
}
|
|
|
|
return info;
|
|
}
|
|
|
|
private string GetImageCacheTag(BaseItem item, ImageType type)
|
|
{
|
|
try
|
|
{
|
|
return _imageProcessor.GetImageCacheTag(item, type);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error getting {0} image info", ex, type);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
public void ReportNowViewingItem(string sessionId, string itemId)
|
|
{
|
|
if (string.IsNullOrEmpty(itemId))
|
|
{
|
|
throw new ArgumentNullException(nameof(itemId));
|
|
}
|
|
|
|
//var item = _libraryManager.GetItemById(new Guid(itemId));
|
|
|
|
//var info = GetItemInfo(item, null, null);
|
|
|
|
//ReportNowViewingItem(sessionId, info);
|
|
}
|
|
|
|
public void ReportNowViewingItem(string sessionId, BaseItemDto item)
|
|
{
|
|
//var session = GetSession(sessionId);
|
|
|
|
//session.NowViewingItem = item;
|
|
}
|
|
|
|
public void ReportTranscodingInfo(string deviceId, TranscodingInfo info)
|
|
{
|
|
var session = Sessions.FirstOrDefault(i => string.Equals(i.DeviceId, deviceId));
|
|
|
|
if (session != null)
|
|
{
|
|
session.TranscodingInfo = info;
|
|
}
|
|
}
|
|
|
|
public void ClearTranscodingInfo(string deviceId)
|
|
{
|
|
ReportTranscodingInfo(deviceId, null);
|
|
}
|
|
|
|
public SessionInfo GetSession(string deviceId, string client, string version)
|
|
{
|
|
return Sessions.FirstOrDefault(i => string.Equals(i.DeviceId, deviceId) &&
|
|
string.Equals(i.Client, client));
|
|
}
|
|
|
|
public SessionInfo GetSessionByAuthenticationToken(AuthenticationInfo info, string deviceId, string remoteEndpoint, string appVersion)
|
|
{
|
|
if (info == null)
|
|
{
|
|
throw new ArgumentNullException(nameof(info));
|
|
}
|
|
|
|
var user = info.UserId.Equals(Guid.Empty)
|
|
? null
|
|
: _userManager.GetUserById(info.UserId);
|
|
|
|
appVersion = string.IsNullOrEmpty(appVersion)
|
|
? info.AppVersion
|
|
: appVersion;
|
|
|
|
var deviceName = info.DeviceName;
|
|
var appName = info.AppName;
|
|
|
|
if (string.IsNullOrEmpty(deviceId))
|
|
{
|
|
deviceId = info.DeviceId;
|
|
}
|
|
|
|
// Prevent argument exception
|
|
if (string.IsNullOrEmpty(appVersion))
|
|
{
|
|
appVersion = "1";
|
|
}
|
|
|
|
return LogSessionActivity(appName, appVersion, deviceId, deviceName, remoteEndpoint, user);
|
|
}
|
|
|
|
public SessionInfo GetSessionByAuthenticationToken(string token, string deviceId, string remoteEndpoint)
|
|
{
|
|
var result = _authRepo.Get(new AuthenticationInfoQuery
|
|
{
|
|
AccessToken = token
|
|
});
|
|
|
|
var info = result.Items.FirstOrDefault();
|
|
|
|
if (info == null)
|
|
{
|
|
return null;
|
|
}
|
|
|
|
return GetSessionByAuthenticationToken(info, deviceId, remoteEndpoint, null);
|
|
}
|
|
|
|
public Task SendMessageToAdminSessions<T>(string name, T data, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var adminUserIds = _userManager.Users.Where(i => i.Policy.IsAdministrator).Select(i => i.Id).ToList();
|
|
|
|
return SendMessageToUserSessions(adminUserIds, name, data, cancellationToken);
|
|
}
|
|
|
|
public Task SendMessageToUserSessions<T>(List<Guid> userIds, string name, Func<T> dataFn, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions.Where(i => userIds.Any(i.ContainsUser)).ToList();
|
|
|
|
if (sessions.Count == 0)
|
|
{
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
var data = dataFn();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, name, data, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error sending message", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
public Task SendMessageToUserSessions<T>(List<Guid> userIds, string name, T data, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions.Where(i => userIds.Any(i.ContainsUser)).ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, name, data, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error sending message", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
public Task SendMessageToUserDeviceSessions<T>(string deviceId, string name, T data, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions.Where(i => string.Equals(i.DeviceId, deviceId, StringComparison.OrdinalIgnoreCase)).ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, name, data, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error sending message", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
public Task SendMessageToUserDeviceAndAdminSessions<T>(string deviceId, string name, T data, CancellationToken cancellationToken)
|
|
{
|
|
CheckDisposed();
|
|
|
|
var sessions = Sessions
|
|
.Where(i => string.Equals(i.DeviceId, deviceId, StringComparison.OrdinalIgnoreCase) || IsAdminSession(i))
|
|
.ToList();
|
|
|
|
var tasks = sessions.Select(session => Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
await SendMessageToSession(session, name, data, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError("Error sending message", ex);
|
|
}
|
|
|
|
}, cancellationToken)).ToArray();
|
|
|
|
return Task.WhenAll(tasks);
|
|
}
|
|
|
|
private bool IsAdminSession(SessionInfo s)
|
|
{
|
|
var user = _userManager.GetUserById(s.UserId);
|
|
|
|
return user != null && user.Policy.IsAdministrator;
|
|
}
|
|
}
|
|
}
|