2013-05-15 18:56:38 +02:00
using MediaBrowser.Controller.Dto ;
using MediaBrowser.Controller.Entities ;
2013-05-14 07:36:36 +02:00
using MediaBrowser.Controller.Entities.Audio ;
using MediaBrowser.Controller.Entities.Movies ;
using MediaBrowser.Controller.Entities.TV ;
2013-05-13 03:46:36 +02:00
using MediaBrowser.Controller.Library ;
using MediaBrowser.Controller.Persistence ;
2013-05-14 07:36:36 +02:00
using MediaBrowser.Model.Dto ;
2013-05-16 00:55:24 +02:00
using MediaBrowser.Model.Entities ;
2013-05-11 06:10:58 +02:00
using MediaBrowser.Model.Querying ;
using ServiceStack.ServiceHost ;
using System ;
2013-05-14 07:36:36 +02:00
using System.Collections.Generic ;
2013-05-22 16:44:51 +02:00
using System.IO ;
2013-05-11 06:10:58 +02:00
using System.Linq ;
2013-05-14 07:36:36 +02:00
using System.Threading ;
2013-05-11 06:10:58 +02:00
using System.Threading.Tasks ;
namespace MediaBrowser.Api
{
/// <summary>
/// Class GetCriticReviews
/// </summary>
[Route("/Items/{Id}/CriticReviews", "GET")]
[Api(Description = "Gets critic reviews for an item")]
public class GetCriticReviews : IReturn < ItemReviewsResult >
{
/// <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 ; }
}
2013-05-15 18:56:38 +02:00
/// <summary>
/// Class GetThemeSongs
/// </summary>
[Route("/Items/{Id}/ThemeSongs", "GET")]
[Api(Description = "Gets theme songs for an item")]
public class GetThemeSongs : IReturn < ThemeSongsResult >
{
/// <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 ; }
}
/// <summary>
/// Class GetThemeVideos
/// </summary>
[Route("/Items/{Id}/ThemeVideos", "GET")]
[Api(Description = "Gets video backdrops for an item")]
public class GetThemeVideos : IReturn < ThemeVideosResult >
{
/// <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 ; }
}
2013-05-13 03:46:36 +02:00
[Route("/Library/Refresh", "POST")]
[Api(Description = "Starts a library scan")]
public class RefreshLibrary : IReturnVoid
{
}
2013-05-14 07:36:36 +02:00
2013-05-22 06:21:36 +02:00
[Route("/Items/{Id}/Refresh", "POST")]
[Api(Description = "Refreshes metadata for an item")]
public class RefreshItem : IReturnVoid
{
2013-05-22 20:28:49 +02:00
[ApiMember(Name = "Forced", Description = "Indicates if a normal or forced refresh should occur.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "POST")]
2013-05-22 06:39:10 +02:00
public bool Forced { get ; set ; }
2013-05-22 06:21:36 +02:00
2013-05-22 20:28:49 +02:00
[ApiMember(Name = "Recursive", Description = "Indicates if the refresh should occur recursively.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "POST")]
2013-05-22 06:39:10 +02:00
public bool Recursive { get ; set ; }
2013-05-22 21:49:12 +02:00
2013-05-22 06:21:36 +02:00
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public string Id { get ; set ; }
}
2013-05-22 16:44:51 +02:00
[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 ; }
}
2013-05-14 07:36:36 +02:00
[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 ; }
}
2013-05-11 06:10:58 +02:00
/// <summary>
/// Class LibraryService
/// </summary>
public class LibraryService : BaseApiService
{
/// <summary>
/// The _item repo
/// </summary>
private readonly IItemRepository _itemRepo ;
2013-05-13 03:46:36 +02:00
private readonly ILibraryManager _libraryManager ;
2013-05-14 07:36:36 +02:00
private readonly IUserManager _userManager ;
2013-05-15 18:56:38 +02:00
private readonly IUserDataRepository _userDataRepository ;
2013-05-13 03:46:36 +02:00
2013-05-11 06:10:58 +02:00
/// <summary>
2013-05-13 03:46:36 +02:00
/// Initializes a new instance of the <see cref="LibraryService" /> class.
2013-05-11 06:10:58 +02:00
/// </summary>
/// <param name="itemRepo">The item repo.</param>
2013-05-13 03:46:36 +02:00
/// <param name="libraryManager">The library manager.</param>
2013-05-14 07:36:36 +02:00
/// <param name="userManager">The user manager.</param>
2013-05-22 21:49:12 +02:00
public LibraryService ( IItemRepository itemRepo , ILibraryManager libraryManager , IUserManager userManager ,
IUserDataRepository userDataRepository )
2013-05-11 06:10:58 +02:00
{
_itemRepo = itemRepo ;
2013-05-13 03:46:36 +02:00
_libraryManager = libraryManager ;
2013-05-14 07:36:36 +02:00
_userManager = userManager ;
2013-05-15 18:56:38 +02:00
_userDataRepository = userDataRepository ;
2013-05-11 06:10:58 +02:00
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetCriticReviews request )
{
var result = GetCriticReviewsAsync ( request ) . Result ;
return ToOptimizedResult ( result ) ;
}
2013-05-14 07:36:36 +02:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetItemCounts request )
{
var items = GetItems ( request . UserId ) . ToList ( ) ;
var counts = new ItemCounts
2013-05-22 21:49:12 +02:00
{
AlbumCount = items . OfType < MusicAlbum > ( ) . Count ( ) ,
EpisodeCount = items . OfType < Episode > ( ) . Count ( ) ,
GameCount = items . OfType < BaseGame > ( ) . Count ( ) ,
MovieCount = items . OfType < Movie > ( ) . Count ( ) ,
SeriesCount = items . OfType < Series > ( ) . Count ( ) ,
SongCount = items . OfType < Audio > ( ) . Count ( ) ,
TrailerCount = items . OfType < Trailer > ( ) . Count ( )
} ;
2013-05-14 07:36:36 +02:00
return ToOptimizedResult ( counts ) ;
}
protected IEnumerable < BaseItem > GetItems ( Guid ? userId )
{
if ( userId . HasValue )
{
var user = _userManager . GetUserById ( userId . Value ) ;
return _userManager . GetUserById ( userId . Value ) . RootFolder . GetRecursiveChildren ( user ) ;
}
return _libraryManager . RootFolder . RecursiveChildren ;
}
2013-05-13 03:46:36 +02:00
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2013-05-22 16:44:51 +02:00
public async void Post ( RefreshLibrary request )
2013-05-13 03:46:36 +02:00
{
2013-05-22 16:44:51 +02:00
try
{
2013-05-22 21:49:12 +02:00
await
_libraryManager . ValidateMediaLibrary ( new Progress < double > ( ) , CancellationToken . None )
. ConfigureAwait ( false ) ;
2013-05-22 16:44:51 +02:00
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error refreshing library" , ex ) ;
}
}
/// <summary>
/// Deletes the specified request.
/// </summary>
/// <param name="request">The request.</param>
public async void Delete ( DeleteItem request )
{
var item = DtoBuilder . GetItemByClientId ( request . Id , _userManager , _libraryManager ) ;
var parent = item . Parent ;
if ( item . LocationType = = LocationType . FileSystem )
{
if ( Directory . Exists ( item . Path ) )
{
Directory . Delete ( item . Path , true ) ;
}
else if ( File . Exists ( item . Path ) )
{
File . Delete ( item . Path ) ;
}
if ( parent ! = null )
{
try
{
2013-05-22 21:49:12 +02:00
await
parent . ValidateChildren ( new Progress < double > ( ) , CancellationToken . None )
. ConfigureAwait ( false ) ;
2013-05-22 16:44:51 +02:00
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error refreshing item" , ex ) ;
}
}
}
else if ( parent ! = null )
{
try
{
await parent . RemoveChild ( item , CancellationToken . None ) . ConfigureAwait ( false ) ;
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error removing item" , ex ) ;
}
}
else
{
throw new InvalidOperationException ( "Don't know how to delete " + item . Name ) ;
}
2013-05-13 03:46:36 +02:00
}
2013-05-11 06:10:58 +02:00
/// <summary>
/// Gets the critic reviews async.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task{ItemReviewsResult}.</returns>
private async Task < ItemReviewsResult > GetCriticReviewsAsync ( GetCriticReviews request )
{
var reviews = await _itemRepo . GetCriticReviews ( new Guid ( request . Id ) ) . ConfigureAwait ( false ) ;
var reviewsArray = reviews . ToArray ( ) ;
var result = new ItemReviewsResult
2013-05-22 21:49:12 +02:00
{
TotalRecordCount = reviewsArray . Length
} ;
2013-05-11 06:10:58 +02:00
if ( request . StartIndex . HasValue )
{
reviewsArray = reviewsArray . Skip ( request . StartIndex . Value ) . ToArray ( ) ;
}
if ( request . Limit . HasValue )
{
reviewsArray = reviewsArray . Take ( request . Limit . Value ) . ToArray ( ) ;
}
result . ItemReviews = reviewsArray ;
return result ;
}
2013-05-15 18:56:38 +02:00
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetThemeSongs request )
{
var user = request . UserId . HasValue ? _userManager . GetUserById ( request . UserId . Value ) : null ;
2013-05-22 21:49:12 +02:00
var item = string . IsNullOrEmpty ( request . Id )
? ( request . UserId . HasValue
? user . RootFolder
: ( Folder ) _libraryManager . RootFolder )
: DtoBuilder . GetItemByClientId ( request . Id , _userManager , _libraryManager , request . UserId ) ;
2013-05-15 18:56:38 +02:00
// Get everything
2013-05-22 21:49:12 +02:00
var fields =
Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
2013-05-15 18:56:38 +02:00
var dtoBuilder = new DtoBuilder ( Logger , _libraryManager , _userDataRepository ) ;
2013-05-22 21:49:12 +02:00
var items =
_itemRepo . GetItems ( item . ThemeSongIds )
. OrderBy ( i = > i . SortName )
. Select ( i = > dtoBuilder . GetBaseItemDto ( i , fields , user ) )
. Select ( t = > t . Result )
. ToArray ( ) ;
2013-05-15 18:56:38 +02:00
var result = new ThemeSongsResult
2013-05-22 21:49:12 +02:00
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = DtoBuilder . GetClientItemId ( item )
} ;
2013-05-15 18:56:38 +02:00
return ToOptimizedResult ( result ) ;
}
/// <summary>
/// Gets the specified request.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>System.Object.</returns>
public object Get ( GetThemeVideos request )
{
var user = request . UserId . HasValue ? _userManager . GetUserById ( request . UserId . Value ) : null ;
2013-05-22 21:49:12 +02:00
var item = string . IsNullOrEmpty ( request . Id )
? ( request . UserId . HasValue
? user . RootFolder
: ( Folder ) _libraryManager . RootFolder )
: DtoBuilder . GetItemByClientId ( request . Id , _userManager , _libraryManager , request . UserId ) ;
2013-05-15 18:56:38 +02:00
// Get everything
2013-05-22 21:49:12 +02:00
var fields =
Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
2013-05-15 18:56:38 +02:00
var dtoBuilder = new DtoBuilder ( Logger , _libraryManager , _userDataRepository ) ;
2013-05-22 21:49:12 +02:00
var items =
_itemRepo . GetItems ( item . ThemeVideoIds )
. OrderBy ( i = > i . SortName )
. Select ( i = > dtoBuilder . GetBaseItemDto ( i , fields , user ) )
. Select ( t = > t . Result )
. ToArray ( ) ;
2013-05-15 18:56:38 +02:00
var result = new ThemeVideosResult
2013-05-22 21:49:12 +02:00
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = DtoBuilder . GetClientItemId ( item )
} ;
2013-05-15 18:56:38 +02:00
return ToOptimizedResult ( result ) ;
}
2013-05-16 00:55:24 +02:00
2013-05-22 06:21:36 +02:00
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2013-05-22 21:49:12 +02:00
public void Post ( RefreshItem request )
{
var task = RefreshItem ( request ) ;
Task . WaitAll ( task ) ;
}
2013-05-26 01:52:41 +02:00
/// <summary>
/// Refreshes the item.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task.</returns>
2013-05-22 21:49:12 +02:00
private async Task RefreshItem ( RefreshItem request )
2013-05-22 06:21:36 +02:00
{
var item = DtoBuilder . GetItemByClientId ( request . Id , _userManager , _libraryManager ) ;
2013-05-22 06:39:10 +02:00
var folder = item as Folder ;
2013-05-22 16:44:51 +02:00
try
2013-05-22 06:39:10 +02:00
{
2013-05-24 18:05:53 +02:00
await item . RefreshMetadata ( CancellationToken . None , forceRefresh : request . Forced ) . ConfigureAwait ( false ) ;
2013-05-22 16:44:51 +02:00
if ( folder ! = null )
{
2013-05-24 18:05:53 +02:00
await folder . ValidateChildren ( new Progress < double > ( ) , CancellationToken . None , request . Recursive ,
2013-05-22 21:49:12 +02:00
request . Forced ) . ConfigureAwait ( false ) ;
2013-05-22 16:44:51 +02:00
}
2013-05-22 06:39:10 +02:00
}
2013-05-22 16:44:51 +02:00
catch ( Exception ex )
2013-05-22 06:39:10 +02:00
{
2013-05-22 16:44:51 +02:00
Logger . ErrorException ( "Error refreshing library" , ex ) ;
2013-05-22 06:39:10 +02:00
}
2013-05-22 06:21:36 +02:00
}
2013-05-11 06:10:58 +02:00
}
}