2014-02-21 05:04:11 +00:00
using MediaBrowser.Common.Extensions ;
2014-03-18 17:05:57 +00:00
using MediaBrowser.Controller.Channels ;
2014-02-21 05:04:11 +00: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 01:33:05 +00:00
using MediaBrowser.Controller.Library ;
2014-02-21 05:04:11 +00:00
using MediaBrowser.Controller.Persistence ;
2014-03-25 21:13:55 +00:00
using MediaBrowser.Controller.Session ;
2014-03-18 17:05:57 +00:00
using MediaBrowser.Model.Channels ;
2014-02-21 05:04:11 +00:00
using MediaBrowser.Model.Dto ;
using MediaBrowser.Model.Entities ;
using MediaBrowser.Model.Querying ;
2013-12-07 15:52:38 +00:00
using ServiceStack ;
2013-02-21 01:33:05 +00:00
using System ;
2014-02-21 05:04:11 +00:00
using System.Collections ;
2013-02-21 01:33:05 +00:00
using System.Collections.Generic ;
2014-02-21 05:04:11 +00:00
using System.Globalization ;
using System.IO ;
2013-02-21 01:33:05 +00:00
using System.Linq ;
2014-02-21 05:04:11 +00:00
using System.Threading ;
using System.Threading.Tasks ;
2013-02-21 01:33:05 +00:00
2013-02-25 03:56:00 +00:00
namespace MediaBrowser.Api.Library
2013-02-21 01:33:05 +00:00
{
2014-02-21 05:04:11 +00: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 ; }
}
[Route("/Videos/{Id}/Subtitle/{Index}", "GET")]
[Api(Description = "Gets an external subtitle file")]
public class GetSubtitle
{
/// <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 = "Index", Description = "The subtitle stream index", IsRequired = true, DataType = "int", ParameterType = "path", Verb = "GET")]
public int Index { 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 01:33:05 +00:00
/// <summary>
/// Class GetPhyscialPaths
/// </summary>
[Route("/Library/PhysicalPaths", "GET")]
2013-03-24 02:45:00 +00:00
[Api(Description = "Gets a list of physical paths from virtual folders")]
2013-02-21 01:33:05 +00:00
public class GetPhyscialPaths : IReturn < List < string > >
{
}
2014-02-21 05:04:11 +00:00
[Route("/Library/MediaFolders", "GET")]
[Api(Description = "Gets all user media folders.")]
public class GetMediaFolders : IReturn < ItemsResult >
{
}
2013-02-21 01:33:05 +00:00
/// <summary>
/// Class LibraryService
/// </summary>
2013-03-16 05:52:33 +00:00
public class LibraryService : BaseApiService
2013-02-21 01:33:05 +00:00
{
2013-02-24 21:53:54 +00:00
/// <summary>
2014-02-21 05:04:11 +00:00
/// The _item repo
2013-02-24 21:53:54 +00:00
/// </summary>
2014-02-21 05:04:11 +00:00
private readonly IItemRepository _itemRepo ;
2013-02-28 19:32:41 +00:00
private readonly ILibraryManager _libraryManager ;
2014-02-21 05:04:11 +00:00
private readonly IUserManager _userManager ;
private readonly IUserDataManager _userDataManager ;
private readonly IDtoService _dtoService ;
2014-03-18 17:05:57 +00:00
private readonly IChannelManager _channelManager ;
2014-03-25 21:13:55 +00:00
private readonly ISessionManager _sessionManager ;
2013-02-24 21:53:54 +00:00
/// <summary>
/// Initializes a new instance of the <see cref="LibraryService" /> class.
/// </summary>
2014-02-21 05:04:11 +00:00
public LibraryService ( IItemRepository itemRepo , ILibraryManager libraryManager , IUserManager userManager ,
2014-03-25 21:13:55 +00:00
IDtoService dtoService , IUserDataManager userDataManager , IChannelManager channelManager , ISessionManager sessionManager )
2013-02-24 21:53:54 +00:00
{
2014-02-21 05:04:11 +00:00
_itemRepo = itemRepo ;
_libraryManager = libraryManager ;
_userManager = userManager ;
_dtoService = dtoService ;
_userDataManager = userDataManager ;
2014-03-18 17:05:57 +00:00
_channelManager = channelManager ;
2014-03-25 21:13:55 +00:00
_sessionManager = sessionManager ;
2014-02-21 05:04:11 +00:00
}
public object Get ( GetMediaFolders request )
{
2014-02-21 05:47:32 +00:00
var items = _libraryManager . GetUserRootFolder ( ) . Children . OrderBy ( i = > i . SortName ) . ToList ( ) ;
2014-02-21 05:04:11 +00: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 21:53:54 +00:00
{
2014-02-21 05:04:11 +00:00
TotalRecordCount = items . Count ,
Items = items . Select ( i = > _dtoService . GetBaseItemDto ( i , fields ) ) . ToArray ( )
} ;
return ToOptimizedResult ( result ) ;
}
public object Get ( GetFile request )
{
var item = _dtoService . GetItemByDtoId ( request . Id ) ;
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 21:53:54 +00:00
}
2014-02-21 05:04:11 +00:00
return ToStaticFileResult ( item . Path ) ;
}
public object Get ( GetSubtitle request )
{
var subtitleStream = _itemRepo . GetMediaStreams ( new MediaStreamQuery
{
Index = request . Index ,
ItemId = new Guid ( request . Id ) ,
Type = MediaStreamType . Subtitle
} ) . FirstOrDefault ( ) ;
if ( subtitleStream = = null )
{
throw new ResourceNotFoundException ( ) ;
}
return ToStaticFileResult ( subtitleStream . Path ) ;
2013-02-21 01:33:05 +00: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 16:51:25 +00:00
var result = _libraryManager . RootFolder . Children
2014-02-10 20:11:46 +00:00
. SelectMany ( c = > c . PhysicalLocations )
2013-12-20 16:51:25 +00:00
. ToList ( ) ;
2013-02-21 01:33:05 +00:00
2014-02-04 04:04:19 +00:00
return ToOptimizedSerializedResultUsingCache ( result ) ;
2013-02-21 01:33:05 +00:00
}
2014-02-21 05:04:11 +00: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 )
{
var item = _dtoService . GetItemByDtoId ( request . Id ) ;
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 adultVideos = filteredItems . OfType < AdultVideo > ( ) . 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 ( ) ;
2014-03-18 17:05:57 +00:00
var channelCount = 0 ;
try
{
channelCount = _channelManager . GetChannels ( new ChannelQuery
{
UserId = request . UserId . HasValue ? request . UserId . Value . ToString ( "N" ) : null
} , CancellationToken . None ) . Result . TotalRecordCount ;
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error getting channels" , ex ) ;
}
2014-02-21 05:04:11 +00:00
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 ,
TrailerCount = filteredItems . OfType < Trailer > ( ) . Count ( ) ,
MusicVideoCount = musicVideos . Count ,
AdultVideoCount = adultVideos . Count ,
BoxSetCount = boxsets . Count ,
BookCount = books . Count ,
2014-03-18 17:05:57 +00:00
UniqueTypes = items . Select ( i = > i . GetClientTypeName ( ) ) . Distinct ( ) . ToList ( ) ,
ChannelCount = channelCount
2014-02-21 05:04:11 +00: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>
public async void Post ( RefreshLibrary request )
{
try
{
await _libraryManager . ValidateMediaLibrary ( new Progress < double > ( ) , CancellationToken . None )
. ConfigureAwait ( false ) ;
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error refreshing library" , ex ) ;
}
}
/// <summary>
/// Deletes the specified request.
/// </summary>
/// <param name="request">The request.</param>
public void Delete ( DeleteItem request )
{
var task = DeleteItem ( request ) ;
Task . WaitAll ( task ) ;
}
private Task DeleteItem ( DeleteItem request )
{
var item = _dtoService . GetItemByDtoId ( request . Id ) ;
2014-03-25 21:13:55 +00:00
var session = GetSession ( _sessionManager ) ;
if ( ! session . UserId . HasValue | | ! _userManager . GetUserById ( session . UserId . Value ) . Configuration . EnableContentDeletion )
{
throw new UnauthorizedAccessException ( "This operation requires a logged in user with delete access." ) ;
}
2014-02-21 05:04:11 +00:00
return _libraryManager . DeleteItem ( item ) ;
}
/// <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 )
: _dtoService . GetItemByDtoId ( request . Id , request . UserId ) ;
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 )
: _dtoService . GetItemByDtoId ( request . Id , request . UserId ) ;
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 )
: _dtoService . GetItemByDtoId ( id , userId ) ;
// 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 )
{
return null ;
}
hasSoundtracks = item . Parents . OfType < IHasSoundtracks > ( ) . FirstOrDefault ( ) ;
return hasSoundtracks ! = null ? hasSoundtracks . SoundtrackIds : new List < Guid > ( ) ;
}
2013-02-21 01:33:05 +00:00
}
}