2014-05-17 06:24:10 +02:00
using MediaBrowser.Controller.Channels ;
2014-02-21 06:04:11 +01:00
using MediaBrowser.Controller.Dto ;
using MediaBrowser.Controller.Entities ;
using MediaBrowser.Controller.Entities.Audio ;
using MediaBrowser.Controller.Entities.Movies ;
using MediaBrowser.Controller.Entities.TV ;
2013-02-21 02:33:05 +01:00
using MediaBrowser.Controller.Library ;
2014-07-04 04:22:57 +02:00
using MediaBrowser.Controller.Net ;
2014-02-21 06:04:11 +01:00
using MediaBrowser.Controller.Persistence ;
2014-03-25 22:13:55 +01:00
using MediaBrowser.Controller.Session ;
2014-02-21 06:04:11 +01:00
using MediaBrowser.Model.Dto ;
using MediaBrowser.Model.Entities ;
using MediaBrowser.Model.Querying ;
2013-12-07 16:52:38 +01:00
using ServiceStack ;
2013-02-21 02:33:05 +01:00
using System ;
2014-02-21 06:04:11 +01:00
using System.Collections ;
2013-02-21 02:33:05 +01:00
using System.Collections.Generic ;
2014-02-21 06:04:11 +01:00
using System.Globalization ;
using System.IO ;
2013-02-21 02:33:05 +01:00
using System.Linq ;
2014-02-21 06:04:11 +01:00
using System.Threading ;
using System.Threading.Tasks ;
2013-02-21 02:33:05 +01:00
2013-02-25 04:56:00 +01:00
namespace MediaBrowser.Api.Library
2013-02-21 02:33:05 +01:00
{
2014-02-21 06:04:11 +01:00
[Route("/Items/{Id}/File", "GET")]
[Api(Description = "Gets the original file of an item")]
public class GetFile
{
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { get ; set ; }
}
/// <summary>
/// Class GetCriticReviews
/// </summary>
[Route("/Items/{Id}/CriticReviews", "GET")]
[Api(Description = "Gets critic reviews for an item")]
public class GetCriticReviews : IReturn < QueryResult < ItemReview > >
{
/// <summary>
/// Gets or sets the id.
/// </summary>
/// <value>The id.</value>
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Id { 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>
/// Class GetThemeSongs
/// </summary>
[Route("/Items/{Id}/ThemeSongs", "GET")]
[Api(Description = "Gets theme songs for an item")]
public class GetThemeSongs : IReturn < ThemeMediaResult >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
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 = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public bool InheritFromParent { get ; set ; }
}
/// <summary>
/// Class GetThemeVideos
/// </summary>
[Route("/Items/{Id}/ThemeVideos", "GET")]
[Api(Description = "Gets theme videos for an item")]
public class GetThemeVideos : IReturn < ThemeMediaResult >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
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 = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public bool InheritFromParent { get ; set ; }
}
/// <summary>
/// Class GetThemeVideos
/// </summary>
[Route("/Items/{Id}/ThemeMedia", "GET")]
[Api(Description = "Gets theme videos and songs for an item")]
public class GetThemeMedia : IReturn < AllThemeMediaResult >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
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 = "GET")]
public string Id { get ; set ; }
[ApiMember(Name = "InheritFromParent", Description = "Determines whether or not parent items should be searched for theme media.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public bool InheritFromParent { get ; set ; }
}
[Route("/Library/Refresh", "POST")]
[Api(Description = "Starts a library scan")]
public class RefreshLibrary : IReturnVoid
{
}
[Route("/Items/{Id}", "DELETE")]
[Api(Description = "Deletes an item from the library and file system")]
public class DeleteItem : IReturnVoid
{
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")]
public string Id { get ; set ; }
}
[Route("/Items/Counts", "GET")]
[Api(Description = "Gets counts of various item types")]
public class GetItemCounts : IReturn < ItemCounts >
{
[ApiMember(Name = "UserId", Description = "Optional. Get counts from a specific user's library.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public Guid ? UserId { get ; set ; }
[ApiMember(Name = "IsFavorite", Description = "Optional. Get counts of favorite items", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
public bool? IsFavorite { get ; set ; }
}
[Route("/Items/{Id}/Ancestors", "GET")]
[Api(Description = "Gets all parents of an item")]
public class GetAncestors : IReturn < BaseItemDto [ ] >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
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 = "GET")]
public string Id { get ; set ; }
}
[Route("/Items/YearIndex", "GET")]
[Api(Description = "Gets a year index based on an item query.")]
public class GetYearIndex : IReturn < List < ItemIndex > >
{
/// <summary>
/// Gets or sets the user id.
/// </summary>
/// <value>The user id.</value>
[ApiMember(Name = "UserId", Description = "Optional. Filter by user id, and attach user data", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public Guid ? UserId { get ; set ; }
[ApiMember(Name = "IncludeItemTypes", Description = "Optional. If specified, results will be filtered based on item type. This allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
public string IncludeItemTypes { get ; set ; }
}
2013-02-21 02:33:05 +01:00
/// <summary>
/// Class GetPhyscialPaths
/// </summary>
[Route("/Library/PhysicalPaths", "GET")]
2013-03-24 03:45:00 +01:00
[Api(Description = "Gets a list of physical paths from virtual folders")]
2013-02-21 02:33:05 +01:00
public class GetPhyscialPaths : IReturn < List < string > >
{
}
2014-02-21 06:04:11 +01:00
[Route("/Library/MediaFolders", "GET")]
[Api(Description = "Gets all user media folders.")]
public class GetMediaFolders : IReturn < ItemsResult >
{
2014-07-01 06:26:50 +02:00
[ApiMember(Name = "IsHidden", Description = "Optional. Filter by folders that are marked hidden, or not.", IsRequired = false, DataType = "boolean", ParameterType = "query", Verb = "GET")]
public bool? IsHidden { get ; set ; }
2014-02-21 06:04:11 +01:00
}
2014-06-26 19:04:11 +02:00
[Route("/Library/Series/Added", "POST")]
2014-04-27 05:42:05 +02:00
[Route("/Library/Series/Updated", "POST")]
[Api(Description = "Reports that new episodes of a series have been added by an external source")]
public class PostUpdatedSeries : IReturnVoid
{
2014-07-12 16:05:51 +02:00
[ApiMember(Name = "TvdbId", Description = "Tvdb Id", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
2014-04-27 05:42:05 +02:00
public string TvdbId { get ; set ; }
}
2013-02-21 02:33:05 +01:00
/// <summary>
/// Class LibraryService
/// </summary>
2014-07-04 04:22:57 +02:00
[Authenticated]
2013-03-16 06:52:33 +01:00
public class LibraryService : BaseApiService
2013-02-21 02:33:05 +01:00
{
2013-02-24 22:53:54 +01:00
/// <summary>
2014-02-21 06:04:11 +01:00
/// The _item repo
2013-02-24 22:53:54 +01:00
/// </summary>
2014-02-21 06:04:11 +01:00
private readonly IItemRepository _itemRepo ;
2013-02-28 20:32:41 +01:00
private readonly ILibraryManager _libraryManager ;
2014-02-21 06:04:11 +01:00
private readonly IUserManager _userManager ;
private readonly IUserDataManager _userDataManager ;
private readonly IDtoService _dtoService ;
2014-03-18 18:05:57 +01:00
private readonly IChannelManager _channelManager ;
2014-03-25 22:13:55 +01:00
private readonly ISessionManager _sessionManager ;
2013-02-24 22:53:54 +01:00
/// <summary>
/// Initializes a new instance of the <see cref="LibraryService" /> class.
/// </summary>
2014-02-21 06:04:11 +01:00
public LibraryService ( IItemRepository itemRepo , ILibraryManager libraryManager , IUserManager userManager ,
2014-03-25 22:13:55 +01:00
IDtoService dtoService , IUserDataManager userDataManager , IChannelManager channelManager , ISessionManager sessionManager )
2013-02-24 22:53:54 +01:00
{
2014-02-21 06:04:11 +01:00
_itemRepo = itemRepo ;
_libraryManager = libraryManager ;
_userManager = userManager ;
_dtoService = dtoService ;
_userDataManager = userDataManager ;
2014-03-18 18:05:57 +01:00
_channelManager = channelManager ;
2014-03-25 22:13:55 +01:00
_sessionManager = sessionManager ;
2014-02-21 06:04:11 +01:00
}
public object Get ( GetMediaFolders request )
{
2014-02-21 06:47:32 +01:00
var items = _libraryManager . GetUserRootFolder ( ) . Children . OrderBy ( i = > i . SortName ) . ToList ( ) ;
2014-02-21 06:04:11 +01:00
2014-07-01 06:26:50 +02:00
if ( request . IsHidden . HasValue )
{
var val = request . IsHidden . Value ;
items = items . Where ( i = > i . IsHidden = = val ) . ToList ( ) ;
}
2014-02-21 06:04:11 +01:00
// Get everything
var fields = Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
var result = new ItemsResult
2013-02-24 22:53:54 +01:00
{
2014-02-21 06:04:11 +01:00
TotalRecordCount = items . Count ,
Items = items . Select ( i = > _dtoService . GetBaseItemDto ( i , fields ) ) . ToArray ( )
} ;
return ToOptimizedResult ( result ) ;
}
2014-08-05 05:41:56 +02:00
public void Post ( PostUpdatedSeries request )
{
2014-08-22 04:24:38 +02:00
Task . Run ( ( ) = > _libraryManager . ValidateMediaLibrary ( new Progress < double > ( ) , CancellationToken . None ) ) ;
2014-08-05 05:41:56 +02:00
}
2014-02-21 06:04:11 +01:00
public object Get ( GetFile request )
{
2014-04-25 22:15:50 +02:00
var item = _libraryManager . GetItemById ( request . Id ) ;
2014-02-21 06:04:11 +01:00
var locationType = item . LocationType ;
if ( locationType = = LocationType . Remote | | locationType = = LocationType . Virtual )
{
throw new ArgumentException ( "This command cannot be used for remote or virtual items." ) ;
}
if ( Directory . Exists ( item . Path ) )
{
throw new ArgumentException ( "This command cannot be used for directories." ) ;
2013-02-24 22:53:54 +01:00
}
2014-02-21 06:04:11 +01:00
return ToStaticFileResult ( item . Path ) ;
}
2013-02-21 02:33:05 +01:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetPhyscialPaths request )
{
2013-12-20 17:51:25 +01:00
var result = _libraryManager . RootFolder . Children
2014-02-10 21:11:46 +01:00
. SelectMany ( c = > c . PhysicalLocations )
2013-12-20 17:51:25 +01:00
. ToList ( ) ;
2013-02-21 02:33:05 +01:00
2014-02-04 05:04:19 +01:00
return ToOptimizedSerializedResultUsingCache ( result ) ;
2013-02-21 02:33:05 +01:00
}
2014-02-21 06:04:11 +01:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetAncestors request )
{
var result = GetAncestors ( request ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
/// <summary>
/// Gets the ancestors.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task{BaseItemDto[]}.</returns>
public List < BaseItemDto > GetAncestors ( GetAncestors request )
{
2014-04-25 22:15:50 +02:00
var item = _libraryManager . GetItemById ( request . Id ) ;
2014-02-21 06:04:11 +01:00
var baseItemDtos = new List < BaseItemDto > ( ) ;
var user = request . UserId . HasValue ? _userManager . GetUserById ( request . UserId . Value ) : null ;
// Get everything
var fields = Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
BaseItem parent = item . Parent ;
while ( parent ! = null )
{
if ( user ! = null )
{
parent = TranslateParentItem ( parent , user ) ;
}
baseItemDtos . Add ( _dtoService . GetBaseItemDto ( parent , fields , user ) ) ;
parent = parent . Parent ;
}
return baseItemDtos . ToList ( ) ;
}
private BaseItem TranslateParentItem ( BaseItem item , User user )
{
if ( item . Parent is AggregateFolder )
{
return user . RootFolder . GetChildren ( user , true ) . FirstOrDefault ( i = > i . PhysicalLocations . Contains ( item . Path ) ) ;
}
return item ;
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetCriticReviews request )
{
var result = GetCriticReviews ( request ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetItemCounts request )
{
var items = GetAllLibraryItems ( request . UserId , _userManager , _libraryManager )
. Where ( i = > i . LocationType ! = LocationType . Virtual )
. ToList ( ) ;
var filteredItems = request . UserId . HasValue ? FilterItems ( items , request , request . UserId . Value ) . ToList ( ) : items ;
var albums = filteredItems . OfType < MusicAlbum > ( ) . ToList ( ) ;
var episodes = filteredItems . OfType < Episode > ( ) . ToList ( ) ;
var games = filteredItems . OfType < Game > ( ) . ToList ( ) ;
var movies = filteredItems . OfType < Movie > ( ) . ToList ( ) ;
var musicVideos = filteredItems . OfType < MusicVideo > ( ) . ToList ( ) ;
var boxsets = filteredItems . OfType < BoxSet > ( ) . ToList ( ) ;
var books = filteredItems . OfType < Book > ( ) . ToList ( ) ;
var songs = filteredItems . OfType < Audio > ( ) . ToList ( ) ;
var series = filteredItems . OfType < Series > ( ) . ToList ( ) ;
var counts = new ItemCounts
{
AlbumCount = albums . Count ,
EpisodeCount = episodes . Count ,
GameCount = games . Count ,
GameSystemCount = filteredItems . OfType < GameSystem > ( ) . Count ( ) ,
MovieCount = movies . Count ,
SeriesCount = series . Count ,
SongCount = songs . Count ,
MusicVideoCount = musicVideos . Count ,
BoxSetCount = boxsets . Count ,
BookCount = books . Count ,
2014-05-14 20:04:26 +02:00
UniqueTypes = items . Select ( i = > i . GetClientTypeName ( ) ) . Distinct ( ) . ToList ( )
2014-02-21 06:04:11 +01:00
} ;
return ToOptimizedSerializedResultUsingCache ( counts ) ;
}
private IEnumerable < T > FilterItems < T > ( IEnumerable < T > items , GetItemCounts request , Guid userId )
where T : BaseItem
{
if ( request . IsFavorite . HasValue )
{
var val = request . IsFavorite . Value ;
items = items . Where ( i = > _userDataManager . GetUserData ( userId , i . GetUserDataKey ( ) ) . IsFavorite = = val ) ;
}
return items ;
}
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-04-04 00:50:04 +02:00
public void Post ( RefreshLibrary request )
2014-02-21 06:04:11 +01:00
{
try
{
2014-04-04 00:50:04 +02:00
_libraryManager . ValidateMediaLibrary ( new Progress < double > ( ) , CancellationToken . None ) ;
2014-02-21 06:04:11 +01:00
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error refreshing library" , ex ) ;
}
}
/// <summary>
/// Deletes the specified request.
/// </summary>
/// <param name="request">The request.</param>
2014-08-18 16:20:02 +02:00
public void Delete ( DeleteItem request )
2014-02-21 06:04:11 +01:00
{
2014-04-25 22:15:50 +02:00
var item = _libraryManager . GetItemById ( request . Id ) ;
2014-02-21 06:04:11 +01:00
2014-08-18 16:20:02 +02:00
var task = _libraryManager . DeleteItem ( item ) ;
Task . WaitAll ( task ) ;
2014-02-21 06:04:11 +01:00
}
/// <summary>
/// Gets the critic reviews async.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task{ItemReviewsResult}.</returns>
private QueryResult < ItemReview > GetCriticReviews ( GetCriticReviews request )
{
var reviews = _itemRepo . GetCriticReviews ( new Guid ( request . Id ) ) ;
var reviewsArray = reviews . ToArray ( ) ;
var result = new QueryResult < ItemReview >
{
TotalRecordCount = reviewsArray . Length
} ;
if ( request . StartIndex . HasValue )
{
reviewsArray = reviewsArray . Skip ( request . StartIndex . Value ) . ToArray ( ) ;
}
if ( request . Limit . HasValue )
{
reviewsArray = reviewsArray . Take ( request . Limit . Value ) . ToArray ( ) ;
}
result . Items = reviewsArray ;
return result ;
}
public object Get ( GetThemeMedia request )
{
var themeSongs = GetThemeSongs ( new GetThemeSongs
{
InheritFromParent = request . InheritFromParent ,
Id = request . Id ,
UserId = request . UserId
} ) ;
var themeVideos = GetThemeVideos ( new GetThemeVideos
{
InheritFromParent = request . InheritFromParent ,
Id = request . Id ,
UserId = request . UserId
} ) ;
return ToOptimizedSerializedResultUsingCache ( new AllThemeMediaResult
{
ThemeSongsResult = themeSongs ,
ThemeVideosResult = themeVideos ,
SoundtrackSongsResult = GetSoundtrackSongs ( request . Id , request . UserId , request . InheritFromParent )
} ) ;
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetThemeSongs request )
{
var result = GetThemeSongs ( request ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
private ThemeMediaResult GetThemeSongs ( GetThemeSongs request )
{
var user = request . UserId . HasValue ? _userManager . GetUserById ( request . UserId . Value ) : null ;
var item = string . IsNullOrEmpty ( request . Id )
? ( request . UserId . HasValue
? user . RootFolder
: ( Folder ) _libraryManager . RootFolder )
2014-04-25 22:15:50 +02:00
: _libraryManager . GetItemById ( request . Id ) ;
2014-02-21 06:04:11 +01:00
var originalItem = item ;
while ( GetThemeSongIds ( item ) . Count = = 0 & & request . InheritFromParent & & item . Parent ! = null )
{
item = item . Parent ;
}
// Get everything
var fields = Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
var themeSongIds = GetThemeSongIds ( item ) ;
if ( themeSongIds . Count = = 0 & & request . InheritFromParent )
{
var album = originalItem as MusicAlbum ;
if ( album ! = null )
{
var linkedItemWithThemes = album . SoundtrackIds
. Select ( i = > _libraryManager . GetItemById ( i ) )
. FirstOrDefault ( i = > GetThemeSongIds ( i ) . Count > 0 ) ;
if ( linkedItemWithThemes ! = null )
{
themeSongIds = GetThemeSongIds ( linkedItemWithThemes ) ;
item = linkedItemWithThemes ;
}
}
}
var dtos = themeSongIds . Select ( _libraryManager . GetItemById )
. OrderBy ( i = > i . SortName )
. Select ( i = > _dtoService . GetBaseItemDto ( i , fields , user , item ) ) ;
var items = dtos . ToArray ( ) ;
return new ThemeMediaResult
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = _dtoService . GetDtoId ( item )
} ;
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetThemeVideos request )
{
var result = GetThemeVideos ( request ) ;
return ToOptimizedSerializedResultUsingCache ( result ) ;
}
public ThemeMediaResult GetThemeVideos ( GetThemeVideos request )
{
var user = request . UserId . HasValue ? _userManager . GetUserById ( request . UserId . Value ) : null ;
var item = string . IsNullOrEmpty ( request . Id )
? ( request . UserId . HasValue
? user . RootFolder
: ( Folder ) _libraryManager . RootFolder )
2014-04-25 22:15:50 +02:00
: _libraryManager . GetItemById ( request . Id ) ;
2014-02-21 06:04:11 +01:00
var originalItem = item ;
while ( GetThemeVideoIds ( item ) . Count = = 0 & & request . InheritFromParent & & item . Parent ! = null )
{
item = item . Parent ;
}
// Get everything
var fields = Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
var themeVideoIds = GetThemeVideoIds ( item ) ;
if ( themeVideoIds . Count = = 0 & & request . InheritFromParent )
{
var album = originalItem as MusicAlbum ;
if ( album = = null )
{
album = originalItem . Parents . OfType < MusicAlbum > ( ) . FirstOrDefault ( ) ;
}
if ( album ! = null )
{
var linkedItemWithThemes = album . SoundtrackIds
. Select ( i = > _libraryManager . GetItemById ( i ) )
. FirstOrDefault ( i = > GetThemeVideoIds ( i ) . Count > 0 ) ;
if ( linkedItemWithThemes ! = null )
{
themeVideoIds = GetThemeVideoIds ( linkedItemWithThemes ) ;
item = linkedItemWithThemes ;
}
}
}
var dtos = themeVideoIds . Select ( _libraryManager . GetItemById )
. OrderBy ( i = > i . SortName )
. Select ( i = > _dtoService . GetBaseItemDto ( i , fields , user , item ) ) ;
var items = dtos . ToArray ( ) ;
return new ThemeMediaResult
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = _dtoService . GetDtoId ( item )
} ;
}
private List < Guid > GetThemeVideoIds ( BaseItem item )
{
var i = item as IHasThemeMedia ;
if ( i ! = null )
{
return i . ThemeVideoIds ;
}
return new List < Guid > ( ) ;
}
private List < Guid > GetThemeSongIds ( BaseItem item )
{
var i = item as IHasThemeMedia ;
if ( i ! = null )
{
return i . ThemeSongIds ;
}
return new List < Guid > ( ) ;
}
private readonly CultureInfo _usCulture = new CultureInfo ( "en-US" ) ;
public object Get ( GetYearIndex request )
{
IEnumerable < BaseItem > items = GetAllLibraryItems ( request . UserId , _userManager , _libraryManager ) ;
if ( ! string . IsNullOrEmpty ( request . IncludeItemTypes ) )
{
var vals = request . IncludeItemTypes . Split ( ',' ) ;
items = items . Where ( f = > vals . Contains ( f . GetType ( ) . Name , StringComparer . OrdinalIgnoreCase ) ) ;
}
var lookup = items
. ToLookup ( i = > i . ProductionYear ? ? - 1 )
. OrderBy ( i = > i . Key )
. Select ( i = > new ItemIndex
{
ItemCount = i . Count ( ) ,
Name = i . Key = = - 1 ? string . Empty : i . Key . ToString ( _usCulture )
} )
. ToList ( ) ;
return ToOptimizedSerializedResultUsingCache ( lookup ) ;
}
public ThemeMediaResult GetSoundtrackSongs ( string id , Guid ? userId , bool inheritFromParent )
{
var user = userId . HasValue ? _userManager . GetUserById ( userId . Value ) : null ;
var item = string . IsNullOrEmpty ( id )
? ( userId . HasValue
? user . RootFolder
: ( Folder ) _libraryManager . RootFolder )
2014-04-25 22:15:50 +02:00
: _libraryManager . GetItemById ( id ) ;
2014-02-21 06:04:11 +01:00
// Get everything
var fields = Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
var dtos = GetSoundtrackSongIds ( item , inheritFromParent )
. Select ( _libraryManager . GetItemById )
. OfType < MusicAlbum > ( )
. SelectMany ( i = > i . RecursiveChildren )
. OfType < Audio > ( )
. OrderBy ( i = > i . SortName )
. Select ( i = > _dtoService . GetBaseItemDto ( i , fields , user , item ) ) ;
var items = dtos . ToArray ( ) ;
return new ThemeMediaResult
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = _dtoService . GetDtoId ( item )
} ;
}
private IEnumerable < Guid > GetSoundtrackSongIds ( BaseItem item , bool inherit )
{
var hasSoundtracks = item as IHasSoundtracks ;
if ( hasSoundtracks ! = null )
{
return hasSoundtracks . SoundtrackIds ;
}
if ( ! inherit )
{
2014-11-05 04:41:14 +01:00
return new List < Guid > ( ) ;
2014-02-21 06:04:11 +01:00
}
hasSoundtracks = item . Parents . OfType < IHasSoundtracks > ( ) . FirstOrDefault ( ) ;
return hasSoundtracks ! = null ? hasSoundtracks . SoundtrackIds : new List < Guid > ( ) ;
}
2013-02-21 02:33:05 +01:00
}
}