2013-10-27 00:01:21 +02:00
using MediaBrowser.Controller.Dto ;
2013-05-01 15:45:25 +02:00
using MediaBrowser.Controller.Entities ;
using MediaBrowser.Controller.Entities.TV ;
using MediaBrowser.Controller.Library ;
using MediaBrowser.Controller.Persistence ;
2013-10-27 00:01:21 +02:00
using MediaBrowser.Model.Entities ;
2013-05-01 15:45:25 +02:00
using MediaBrowser.Model.Querying ;
using ServiceStack.ServiceHost ;
using System ;
using System.Collections.Generic ;
using System.Linq ;
namespace MediaBrowser.Api
{
/// <summary>
/// Class GetNextUpEpisodes
/// </summary>
[Route("/Shows/NextUp", "GET")]
[Api(("Gets a list of currently installed plugins"))]
public class GetNextUpEpisodes : IReturn < ItemsResult >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")]
public Guid UserId { get ; set ; }
/// <summary>
/// Skips over a given number of items within the results. Use for paging.
/// </summary>
/// <value>The start index.</value>
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? StartIndex { get ; set ; }
/// <summary>
/// The maximum number of items to return
/// </summary>
/// <value>The limit.</value>
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
public int? Limit { get ; set ; }
/// <summary>
/// Fields to return within the items, in addition to basic information
/// </summary>
/// <value>The fields.</value>
2013-09-23 16:26:20 +02:00
[ApiMember(Name = "Fields", Description = "Optional. Specify additional fields of information to return in the output. This allows multiple, comma delimeted. Options: Budget, Chapters, CriticRatingSummary, DateCreated, Genres, HomePageUrl, IndexOptions, MediaStreams, Overview, OverviewHtml, ParentId, Path, People, ProviderIds, PrimaryImageAspectRatio, Revenue, SortName, Studios, Taglines, TrailerUrls", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
2013-05-01 15:45:25 +02:00
public string Fields { get ; set ; }
2013-10-27 00:01:21 +02:00
[ApiMember(Name = "SeriesId", Description = "Optional. Filter by series id", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string SeriesId { get ; set ; }
2013-10-17 01:35:11 +02:00
2013-05-01 15:45:25 +02:00
/// <summary>
/// Gets the item fields.
/// </summary>
/// <returns>IEnumerable{ItemFields}.</returns>
public IEnumerable < ItemFields > GetItemFields ( )
{
var val = Fields ;
if ( string . IsNullOrEmpty ( val ) )
{
return new ItemFields [ ] { } ;
}
2013-07-22 16:58:38 +02:00
return val . Split ( ',' ) . Select ( v = >
{
ItemFields value ;
if ( Enum . TryParse ( v , true , out value ) )
{
return ( ItemFields ? ) value ;
}
return null ;
} ) . Where ( i = > i . HasValue ) . Select ( i = > i . Value ) ;
2013-05-01 15:45:25 +02:00
}
}
2013-05-26 01:52:41 +02:00
[Route("/Shows/{Id}/Similar", "GET")]
[Api(Description = "Finds tv shows similar to a given one.")]
2013-08-09 17:55:22 +02:00
public class GetSimilarShows : BaseGetSimilarItemsFromItem
2013-05-26 01:52:41 +02:00
{
}
2013-06-17 22:35:43 +02:00
2013-05-01 15:45:25 +02:00
/// <summary>
/// Class TvShowsService
/// </summary>
public class TvShowsService : BaseApiService
{
/// <summary>
/// The _user manager
/// </summary>
private readonly IUserManager _userManager ;
/// <summary>
/// The _user data repository
/// </summary>
2013-11-03 21:48:16 +01:00
private readonly IUserDataManager _userDataManager ;
2013-05-01 15:45:25 +02:00
/// <summary>
/// The _library manager
/// </summary>
private readonly ILibraryManager _libraryManager ;
2013-06-18 21:16:27 +02:00
private readonly IItemRepository _itemRepo ;
2013-09-04 19:02:19 +02:00
private readonly IDtoService _dtoService ;
2013-05-01 15:45:25 +02:00
/// <summary>
/// Initializes a new instance of the <see cref="TvShowsService" /> class.
/// </summary>
/// <param name="userManager">The user manager.</param>
2013-11-03 21:48:16 +01:00
/// <param name="userDataManager">The user data repository.</param>
2013-05-01 15:45:25 +02:00
/// <param name="libraryManager">The library manager.</param>
2013-11-03 21:48:16 +01:00
public TvShowsService ( IUserManager userManager , IUserDataManager userDataManager , ILibraryManager libraryManager , IItemRepository itemRepo , IDtoService dtoService )
2013-05-01 15:45:25 +02:00
{
_userManager = userManager ;
2013-11-03 21:48:16 +01:00
_userDataManager = userDataManager ;
2013-05-01 15:45:25 +02:00
_libraryManager = libraryManager ;
2013-06-18 21:16:27 +02:00
_itemRepo = itemRepo ;
2013-09-04 19:02:19 +02:00
_dtoService = dtoService ;
2013-05-01 15:45:25 +02:00
}
2013-05-26 01:52:41 +02:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetSimilarShows request )
{
2013-08-08 22:18:05 +02:00
var result = SimilarItemsHelper . GetSimilarItemsResult ( _userManager ,
2013-06-18 21:16:27 +02:00
_itemRepo ,
2013-06-17 22:35:43 +02:00
_libraryManager ,
2013-11-03 21:48:16 +01:00
_userDataManager ,
2013-09-04 19:02:19 +02:00
_dtoService ,
2013-05-26 01:52:41 +02:00
Logger ,
request , item = > item is Series ,
SimilarItemsHelper . GetSimiliarityScore ) ;
return ToOptimizedResult ( result ) ;
}
2013-05-01 15:45:25 +02:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetNextUpEpisodes request )
{
2013-11-03 21:48:16 +01:00
var result = GetNextUpEpisodeItemsResult ( request ) ;
2013-05-01 15:45:25 +02:00
return ToOptimizedResult ( result ) ;
}
/// <summary>
/// Gets the next up episodes.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task{ItemsResult}.</returns>
2013-11-03 21:48:16 +01:00
private ItemsResult GetNextUpEpisodeItemsResult ( GetNextUpEpisodes request )
{
var user = _userManager . GetUserById ( request . UserId ) ;
var itemsList = GetNextUpEpisodes ( request )
. ToList ( ) ;
var pagedItems = ApplyPaging ( request , itemsList ) ;
var fields = request . GetItemFields ( ) . ToList ( ) ;
var returnItems = pagedItems . Select ( i = > _dtoService . GetBaseItemDto ( i , fields , user ) ) . ToArray ( ) ;
return new ItemsResult
{
TotalRecordCount = itemsList . Count ,
Items = returnItems
} ;
}
public IEnumerable < Episode > GetNextUpEpisodes ( GetNextUpEpisodes request )
2013-05-01 15:45:25 +02:00
{
var user = _userManager . GetUserById ( request . UserId ) ;
2013-10-27 00:01:21 +02:00
var items = user . RootFolder
. GetRecursiveChildren ( user )
. OfType < Series > ( ) ;
2013-11-03 21:48:16 +01:00
// Avoid implicitly captured closure
return GetNextUpEpisodes ( request , items ) ;
}
public IEnumerable < Episode > GetNextUpEpisodes ( GetNextUpEpisodes request , IEnumerable < Series > series )
{
var user = _userManager . GetUserById ( request . UserId ) ;
2013-10-27 00:01:21 +02:00
2013-11-03 21:48:16 +01:00
// Avoid implicitly captured closure
var currentUser = user ;
2013-05-01 15:45:25 +02:00
2013-11-03 21:48:16 +01:00
return FilterSeries ( request , series )
. AsParallel ( )
. Select ( i = > GetNextUp ( i , currentUser , request ) . Item1 )
. Where ( i = > i ! = null )
2013-05-01 15:45:25 +02:00
. OrderByDescending ( i = >
{
2013-11-03 21:48:16 +01:00
var seriesUserData = _userDataManager . GetUserData ( user . Id , i . Series . GetUserDataKey ( ) ) ;
2013-05-01 15:45:25 +02:00
if ( seriesUserData . IsFavorite )
{
return 2 ;
}
if ( seriesUserData . Likes . HasValue )
{
return seriesUserData . Likes . Value ? 1 : - 1 ;
}
return 0 ;
} )
2013-11-03 21:48:16 +01:00
. ThenByDescending ( i = > i . PremiereDate ? ? DateTime . MinValue ) ;
2013-05-01 15:45:25 +02:00
}
/// <summary>
/// Gets the next up.
/// </summary>
/// <param name="series">The series.</param>
/// <param name="user">The user.</param>
2013-10-17 01:35:11 +02:00
/// <param name="request">The request.</param>
2013-05-01 15:45:25 +02:00
/// <returns>Task{Episode}.</returns>
2013-10-17 01:35:11 +02:00
private Tuple < Episode , DateTime > GetNextUp ( Series series , User user , GetNextUpEpisodes request )
2013-05-01 15:45:25 +02:00
{
var allEpisodes = series . GetRecursiveChildren ( user )
. OfType < Episode > ( )
2013-05-02 16:30:38 +02:00
. OrderByDescending ( i = > i . PremiereDate ? ? DateTime . MinValue )
. ThenByDescending ( i = > i . IndexNumber ? ? 0 )
2013-05-01 15:45:25 +02:00
. ToList ( ) ;
2013-10-17 01:35:11 +02:00
allEpisodes = FilterItems ( request , allEpisodes ) . ToList ( ) ;
2013-05-01 15:45:25 +02:00
Episode lastWatched = null ;
var lastWatchedDate = DateTime . MinValue ;
Episode nextUp = null ;
// Go back starting with the most recent episodes
foreach ( var episode in allEpisodes )
{
2013-11-03 21:48:16 +01:00
var userData = _userDataManager . GetUserData ( user . Id , episode . GetUserDataKey ( ) ) ;
2013-05-01 15:45:25 +02:00
if ( userData . Played )
{
if ( lastWatched ! = null | | nextUp = = null )
{
break ;
}
lastWatched = episode ;
lastWatchedDate = userData . LastPlayedDate ? ? DateTime . MinValue ;
}
else
{
nextUp = episode ;
}
}
if ( lastWatched ! = null )
{
return new Tuple < Episode , DateTime > ( nextUp , lastWatchedDate ) ;
}
return new Tuple < Episode , DateTime > ( null , lastWatchedDate ) ;
}
2013-10-17 01:35:11 +02:00
private IEnumerable < Episode > FilterItems ( GetNextUpEpisodes request , IEnumerable < Episode > items )
{
2013-10-27 00:01:21 +02:00
// Make this configurable when needed
items = items . Where ( i = > i . LocationType ! = LocationType . Virtual ) ;
2013-10-17 01:35:11 +02:00
2013-10-27 00:01:21 +02:00
return items ;
}
2013-10-17 01:35:11 +02:00
2013-10-27 00:01:21 +02:00
private IEnumerable < Series > FilterSeries ( GetNextUpEpisodes request , IEnumerable < Series > items )
{
if ( ! string . IsNullOrWhiteSpace ( request . SeriesId ) )
2013-10-17 01:35:11 +02:00
{
2013-10-27 00:01:21 +02:00
var id = new Guid ( request . SeriesId ) ;
2013-10-17 01:35:11 +02:00
2013-10-27 00:01:21 +02:00
items = items . Where ( i = > i . Id = = id ) ;
2013-10-17 01:35:11 +02:00
}
return items ;
}
2013-05-01 15:45:25 +02:00
/// <summary>
/// Applies the paging.
/// </summary>
/// <param name="request">The request.</param>
/// <param name="items">The items.</param>
/// <returns>IEnumerable{BaseItem}.</returns>
private IEnumerable < BaseItem > ApplyPaging ( GetNextUpEpisodes request , IEnumerable < BaseItem > items )
{
// Start at
if ( request . StartIndex . HasValue )
{
items = items . Skip ( request . StartIndex . Value ) ;
}
// Return limit
if ( request . Limit . HasValue )
{
items = items . Take ( request . Limit . Value ) ;
}
return items ;
}
}
}