2014-07-05 07:21:13 +02:00
using MediaBrowser.Controller.Entities ;
using MediaBrowser.Controller.Library ;
using MediaBrowser.Controller.Net ;
using MediaBrowser.Controller.Session ;
using MediaBrowser.Model.Dto ;
using MediaBrowser.Model.Session ;
using ServiceStack ;
using System ;
using System.Globalization ;
using System.Linq ;
using System.Threading.Tasks ;
namespace MediaBrowser.Api.UserLibrary
{
/// <summary>
/// Class MarkPlayedItem
/// </summary>
[Route("/Users/{UserId}/PlayedItems/{Id}", "POST")]
[Api(Description = "Marks an item as played")]
public class MarkPlayedItem : IReturn < UserItemDataDto >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public Guid UserId { get ; set ; }
[ApiMember(Name = "DatePlayed", Description = "The date the item was played (if any). Format = yyyyMMddHHmmss", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "POST")]
public string DatePlayed { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public string Id { get ; set ; }
}
/// <summary>
/// Class MarkUnplayedItem
/// </summary>
[Route("/Users/{UserId}/PlayedItems/{Id}", "DELETE")]
[Api(Description = "Marks an item as unplayed")]
public class MarkUnplayedItem : IReturn < UserItemDataDto >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
public Guid UserId { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
public string Id { get ; set ; }
}
[Route("/Sessions/Playing", "POST")]
[Api(Description = "Reports playback has started within a session")]
public class ReportPlaybackStart : PlaybackStartInfo , IReturnVoid
{
}
[Route("/Sessions/Playing/Progress", "POST")]
[Api(Description = "Reports playback progress within a session")]
public class ReportPlaybackProgress : PlaybackProgressInfo , IReturnVoid
{
}
[Route("/Sessions/Playing/Stopped", "POST")]
[Api(Description = "Reports playback has stopped within a session")]
public class ReportPlaybackStopped : PlaybackStopInfo , IReturnVoid
{
}
/// <summary>
/// Class OnPlaybackStart
/// </summary>
[Route("/Users/{UserId}/PlayingItems/{Id}", "POST")]
[Api(Description = "Reports that a user has begun playing an item")]
public class OnPlaybackStart : IReturnVoid
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public Guid UserId { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public string Id { get ; set ; }
[ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST")]
public string MediaSourceId { get ; set ; }
/// <summary>
/// Gets or sets a value indicating whether this <see cref="UpdateUserItemRating" /> is likes.
/// </summary>
/// <value><c>true</c> if likes; otherwise, <c>false</c>.</value>
[ApiMember(Name = "CanSeek", Description = "Indicates if the client can seek", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
public bool CanSeek { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "QueueableMediaTypes", Description = "A list of media types that can be queued from this item, comma delimited. Audio,Video,Book,Game", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST", AllowMultiple = true)]
public string QueueableMediaTypes { get ; set ; }
[ApiMember(Name = "AudioStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public int? AudioStreamIndex { get ; set ; }
[ApiMember(Name = "SubtitleStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public int? SubtitleStreamIndex { get ; set ; }
}
/// <summary>
/// Class OnPlaybackProgress
/// </summary>
[Route("/Users/{UserId}/PlayingItems/{Id}/Progress", "POST")]
[Api(Description = "Reports a user's playback progress")]
public class OnPlaybackProgress : IReturnVoid
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public Guid UserId { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public string Id { get ; set ; }
[ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "POST")]
public string MediaSourceId { get ; set ; }
/// <summary>
/// Gets or sets the position ticks.
/// </summary>
/// <value>The position ticks.</value>
[ApiMember(Name = "PositionTicks", Description = "Optional. The current position, in ticks. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public long? PositionTicks { get ; set ; }
[ApiMember(Name = "IsPaused", Description = "Indicates if the player is paused.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
public bool IsPaused { get ; set ; }
[ApiMember(Name = "IsMuted", Description = "Indicates if the player is muted.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "POST")]
public bool IsMuted { get ; set ; }
[ApiMember(Name = "AudioStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public int? AudioStreamIndex { get ; set ; }
[ApiMember(Name = "SubtitleStreamIndex", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public int? SubtitleStreamIndex { get ; set ; }
[ApiMember(Name = "VolumeLevel", Description = "Scale of 0-100", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "POST")]
public int? VolumeLevel { get ; set ; }
}
/// <summary>
/// Class OnPlaybackStopped
/// </summary>
[Route("/Users/{UserId}/PlayingItems/{Id}", "DELETE")]
[Api(Description = "Reports that a user has stopped playing an item")]
public class OnPlaybackStopped : IReturnVoid
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
public Guid UserId { get ; set ; }
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
public string Id { get ; set ; }
[ApiMember(Name = "MediaSourceId", Description = "The id of the MediaSource", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "DELETE")]
public string MediaSourceId { get ; set ; }
/// <summary>
/// Gets or sets the position ticks.
/// </summary>
/// <value>The position ticks.</value>
[ApiMember(Name = "PositionTicks", Description = "Optional. The position, in ticks, where playback stopped. 1 tick = 10000 ms", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "DELETE")]
public long? PositionTicks { get ; set ; }
}
[Authenticated]
public class PlaystateService : BaseApiService
{
private readonly IUserManager _userManager ;
private readonly IUserDataManager _userDataRepository ;
private readonly ILibraryManager _libraryManager ;
private readonly ISessionManager _sessionManager ;
public PlaystateService ( IUserManager userManager , IUserDataManager userDataRepository , ILibraryManager libraryManager , ISessionManager sessionManager )
{
_userManager = userManager ;
_userDataRepository = userDataRepository ;
_libraryManager = libraryManager ;
_sessionManager = sessionManager ;
}
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-08-17 07:38:13 +02:00
public async Task < object > Post ( MarkPlayedItem request )
2014-07-05 07:21:13 +02:00
{
var user = _userManager . GetUserById ( request . UserId ) ;
DateTime ? datePlayed = null ;
if ( ! string . IsNullOrEmpty ( request . DatePlayed ) )
{
datePlayed = DateTime . ParseExact ( request . DatePlayed , "yyyyMMddHHmmss" , CultureInfo . InvariantCulture , DateTimeStyles . AssumeUniversal ) ;
}
var session = GetSession ( ) ;
var dto = await UpdatePlayedStatus ( user , request . Id , true , datePlayed ) . ConfigureAwait ( false ) ;
foreach ( var additionalUserInfo in session . AdditionalUsers )
{
var additionalUser = _userManager . GetUserById ( new Guid ( additionalUserInfo . UserId ) ) ;
await UpdatePlayedStatus ( additionalUser , request . Id , true , datePlayed ) . ConfigureAwait ( false ) ;
}
2014-08-17 07:38:13 +02:00
return ToOptimizedResult ( dto ) ;
2014-07-05 07:21:13 +02:00
}
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-08-17 07:38:13 +02:00
public Task Post ( OnPlaybackStart request )
2014-07-05 07:21:13 +02:00
{
var queueableMediaTypes = ( request . QueueableMediaTypes ? ? string . Empty ) ;
2014-08-17 07:38:13 +02:00
return Post ( new ReportPlaybackStart
2014-07-05 07:21:13 +02:00
{
CanSeek = request . CanSeek ,
ItemId = request . Id ,
QueueableMediaTypes = queueableMediaTypes . Split ( ',' ) . ToList ( ) ,
MediaSourceId = request . MediaSourceId ,
AudioStreamIndex = request . AudioStreamIndex ,
SubtitleStreamIndex = request . SubtitleStreamIndex
} ) ;
}
2014-08-17 07:38:13 +02:00
public Task Post ( ReportPlaybackStart request )
2014-07-05 07:21:13 +02:00
{
request . SessionId = GetSession ( ) . Id ;
2014-08-17 07:38:13 +02:00
return _sessionManager . OnPlaybackStart ( request ) ;
2014-07-05 07:21:13 +02:00
}
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-08-17 07:38:13 +02:00
public Task Post ( OnPlaybackProgress request )
2014-07-05 07:21:13 +02:00
{
2014-08-17 07:38:13 +02:00
return Post ( new ReportPlaybackProgress
2014-07-05 07:21:13 +02:00
{
ItemId = request . Id ,
PositionTicks = request . PositionTicks ,
IsMuted = request . IsMuted ,
IsPaused = request . IsPaused ,
MediaSourceId = request . MediaSourceId ,
AudioStreamIndex = request . AudioStreamIndex ,
SubtitleStreamIndex = request . SubtitleStreamIndex ,
VolumeLevel = request . VolumeLevel
} ) ;
}
2014-08-17 07:38:13 +02:00
public Task Post ( ReportPlaybackProgress request )
2014-07-05 07:21:13 +02:00
{
request . SessionId = GetSession ( ) . Id ;
2014-08-17 07:38:13 +02:00
return _sessionManager . OnPlaybackProgress ( request ) ;
2014-07-05 07:21:13 +02:00
}
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-08-17 07:38:13 +02:00
public Task Delete ( OnPlaybackStopped request )
2014-07-05 07:21:13 +02:00
{
2014-08-17 07:38:13 +02:00
return Post ( new ReportPlaybackStopped
2014-07-05 07:21:13 +02:00
{
ItemId = request . Id ,
PositionTicks = request . PositionTicks ,
MediaSourceId = request . MediaSourceId
} ) ;
}
2014-08-17 07:38:13 +02:00
public Task Post ( ReportPlaybackStopped request )
2014-07-05 07:21:13 +02:00
{
request . SessionId = GetSession ( ) . Id ;
2014-08-17 07:38:13 +02:00
return _sessionManager . OnPlaybackStopped ( request ) ;
2014-07-05 07:21:13 +02:00
}
/// <summary>
/// Deletes the specified request.
/// </summary>
/// <param name="request">The request.</param>
public object Delete ( MarkUnplayedItem request )
{
var task = MarkUnplayed ( request ) ;
return ToOptimizedResult ( task . Result ) ;
}
private async Task < UserItemDataDto > MarkUnplayed ( MarkUnplayedItem request )
{
var user = _userManager . GetUserById ( request . UserId ) ;
var session = GetSession ( ) ;
var dto = await UpdatePlayedStatus ( user , request . Id , false , null ) . ConfigureAwait ( false ) ;
foreach ( var additionalUserInfo in session . AdditionalUsers )
{
var additionalUser = _userManager . GetUserById ( new Guid ( additionalUserInfo . UserId ) ) ;
await UpdatePlayedStatus ( additionalUser , request . Id , false , null ) . ConfigureAwait ( false ) ;
}
return dto ;
}
/// <summary>
/// Updates the played status.
/// </summary>
/// <param name="user">The user.</param>
/// <param name="itemId">The item id.</param>
/// <param name="wasPlayed">if set to <c>true</c> [was played].</param>
/// <param name="datePlayed">The date played.</param>
/// <returns>Task.</returns>
private async Task < UserItemDataDto > UpdatePlayedStatus ( User user , string itemId , bool wasPlayed , DateTime ? datePlayed )
{
var item = _libraryManager . GetItemById ( itemId ) ;
if ( wasPlayed )
{
await item . MarkPlayed ( user , datePlayed , _userDataRepository ) . ConfigureAwait ( false ) ;
}
else
{
await item . MarkUnplayed ( user , _userDataRepository ) . ConfigureAwait ( false ) ;
}
return _userDataRepository . GetUserDataDto ( item , user ) ;
}
}
}