2013-05-15 16:56:38 +00:00
using MediaBrowser.Controller.Dto ;
using MediaBrowser.Controller.Entities ;
2013-05-14 05:36:36 +00:00
using MediaBrowser.Controller.Entities.Audio ;
using MediaBrowser.Controller.Entities.Movies ;
using MediaBrowser.Controller.Entities.TV ;
2013-05-13 01:46:36 +00:00
using MediaBrowser.Controller.Library ;
using MediaBrowser.Controller.Persistence ;
2013-05-14 05:36:36 +00:00
using MediaBrowser.Model.Dto ;
2013-05-15 22:55:24 +00:00
using MediaBrowser.Model.Entities ;
2013-05-11 04:10:58 +00:00
using MediaBrowser.Model.Querying ;
using ServiceStack.ServiceHost ;
using System ;
2013-05-14 05:36:36 +00:00
using System.Collections.Generic ;
2013-05-22 14:44:51 +00:00
using System.IO ;
2013-05-11 04:10:58 +00:00
using System.Linq ;
2013-05-14 05:36:36 +00:00
using System.Threading ;
2013-05-11 04:10:58 +00: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 16:56:38 +00: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 01:46:36 +00:00
[Route("/Library/Refresh", "POST")]
[Api(Description = "Starts a library scan")]
public class RefreshLibrary : IReturnVoid
{
}
2013-05-14 05:36:36 +00:00
2013-05-22 04:21:36 +00:00
[Route("/Items/{Id}/Refresh", "POST")]
[Api(Description = "Refreshes metadata for an item")]
public class RefreshItem : IReturnVoid
{
2013-05-22 18:28:49 +00: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 04:39:10 +00:00
public bool Forced { get ; set ; }
2013-05-22 04:21:36 +00:00
2013-05-22 18:28:49 +00:00
[ApiMember(Name = "Recursive", Description = "Indicates if the refresh should occur recursively.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "POST")]
2013-05-22 04:39:10 +00:00
public bool Recursive { get ; set ; }
2013-05-22 19:49:12 +00:00
2013-05-22 04:21:36 +00:00
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
public string Id { get ; set ; }
}
2013-05-22 14:44:51 +00: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 05:36:36 +00: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-28 02:36:51 +00:00
[Route("/Items/{ItemId}", "POST")]
[Api(("Updates an item"))]
public class UpdateItem : BaseItemDto , IReturnVoid
{
public string ItemId { get ; set ; }
}
2013-05-11 04:10:58 +00:00
/// <summary>
/// Class LibraryService
/// </summary>
public class LibraryService : BaseApiService
{
/// <summary>
/// The _item repo
/// </summary>
private readonly IItemRepository _itemRepo ;
2013-05-13 01:46:36 +00:00
private readonly ILibraryManager _libraryManager ;
2013-05-14 05:36:36 +00:00
private readonly IUserManager _userManager ;
2013-05-15 16:56:38 +00:00
private readonly IUserDataRepository _userDataRepository ;
2013-05-13 01:46:36 +00:00
2013-05-11 04:10:58 +00:00
/// <summary>
2013-05-13 01:46:36 +00:00
/// Initializes a new instance of the <see cref="LibraryService" /> class.
2013-05-11 04:10:58 +00:00
/// </summary>
/// <param name="itemRepo">The item repo.</param>
2013-05-13 01:46:36 +00:00
/// <param name="libraryManager">The library manager.</param>
2013-05-14 05:36:36 +00:00
/// <param name="userManager">The user manager.</param>
2013-05-28 02:36:51 +00:00
/// <param name="userDataRepository">The user data repository.</param>
2013-05-22 19:49:12 +00:00
public LibraryService ( IItemRepository itemRepo , ILibraryManager libraryManager , IUserManager userManager ,
IUserDataRepository userDataRepository )
2013-05-11 04:10:58 +00:00
{
_itemRepo = itemRepo ;
2013-05-13 01:46:36 +00:00
_libraryManager = libraryManager ;
2013-05-14 05:36:36 +00:00
_userManager = userManager ;
2013-05-15 16:56:38 +00:00
_userDataRepository = userDataRepository ;
2013-05-11 04:10:58 +00: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 05:36:36 +00: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-27 16:53:10 +00: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 ( ) ,
2013-05-28 01:59:26 +00:00
TrailerCount = items . OfType < Trailer > ( ) . Count ( ) ,
MusicVideoCount = items . OfType < MusicVideo > ( ) . Count ( )
2013-05-27 16:53:10 +00:00
} ;
2013-05-14 05:36:36 +00: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 01:46:36 +00:00
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2013-05-22 14:44:51 +00:00
public async void Post ( RefreshLibrary request )
2013-05-13 01:46:36 +00:00
{
2013-05-22 14:44:51 +00:00
try
{
2013-05-22 19:49:12 +00:00
await
_libraryManager . ValidateMediaLibrary ( new Progress < double > ( ) , CancellationToken . None )
. ConfigureAwait ( false ) ;
2013-05-22 14:44:51 +00:00
}
catch ( Exception ex )
{
Logger . ErrorException ( "Error refreshing library" , ex ) ;
}
}
2013-05-28 02:36:51 +00:00
public void Post ( UpdateItem request )
{
var task = UpdateItem ( request ) ;
Task . WaitAll ( task ) ;
}
private Task UpdateItem ( UpdateItem request )
{
var item = DtoBuilder . GetItemByClientId ( request . ItemId , _userManager , _libraryManager ) ;
item . Name = request . Name ;
item . ForcedSortName = request . SortName ;
item . DisplayMediaType = request . DisplayMediaType ;
item . CommunityRating = request . CommunityRating ;
item . HomePageUrl = request . HomePageUrl ;
item . Budget = request . Budget ;
item . Revenue = request . Revenue ;
item . CriticRating = request . CriticRating ;
item . CriticRatingSummary = request . CriticRatingSummary ;
item . IndexNumber = request . IndexNumber ;
item . ParentIndexNumber = request . ParentIndexNumber ;
2013-06-09 03:04:41 +00:00
item . Overview = request . Overview ;
item . Genres = request . Genres ;
item . Tags = request . Tags ;
item . Studios = request . Studios . Select ( x = > x . Name ) . ToList ( ) ;
2013-06-09 07:50:35 +00:00
item . People = request . People . Select ( x = > new PersonInfo { Name = x . Name , Role = x . Role , Type = x . Type } ) . ToList ( ) ;
2013-05-28 02:36:51 +00:00
2013-06-09 19:51:57 +00:00
item . EndDate = request . EndDate ! = default ( DateTime ) ? request . EndDate : null ;
item . PremiereDate = request . PremiereDate ! = default ( DateTime ) ? request . PremiereDate : null ;
2013-05-28 02:36:51 +00:00
item . ProductionYear = request . ProductionYear ;
item . AspectRatio = request . AspectRatio ;
item . Language = request . Language ;
item . OfficialRating = request . OfficialRating ;
item . CustomRating = request . CustomRating ;
2013-06-15 05:30:48 +00:00
item . DontFetchMeta = ! ( request . EnableInternetProviders ? ? true ) ;
2013-06-15 22:19:47 +00:00
if ( request . EnableInternetProviders ? ? true )
{
item . LockedFields = request . LockedFields ;
item . LockedImages = request . LockedImages ;
}
else
{
item . LockedFields . Clear ( ) ;
item . LockedImages . Clear ( ) ;
}
2013-05-28 02:36:51 +00:00
foreach ( var pair in request . ProviderIds . ToList ( ) )
{
if ( string . IsNullOrEmpty ( pair . Value ) )
{
request . ProviderIds . Remove ( pair . Key ) ;
}
}
item . ProviderIds = request . ProviderIds ;
var game = item as BaseGame ;
if ( game ! = null )
{
game . PlayersSupported = request . Players ;
}
var song = item as Audio ;
if ( song ! = null )
{
song . Album = request . Album ;
song . AlbumArtist = request . AlbumArtist ;
song . Artist = request . Artists [ 0 ] ;
}
2013-06-09 08:26:57 +00:00
var musicAlbum = item as MusicAlbum ;
if ( musicAlbum ! = null )
{
musicAlbum . MusicBrainzReleaseGroupId = request . ProviderIds [ "MusicBrainzReleaseGroupId" ] ;
}
2013-06-09 03:04:41 +00:00
var series = item as Series ;
if ( series ! = null )
{
series . Status = request . Status ;
series . AirDays = request . AirDays ;
series . AirTime = request . AirTime ;
}
2013-05-28 02:36:51 +00:00
return _libraryManager . UpdateItem ( item , CancellationToken . None ) ;
}
2013-05-22 14:44:51 +00:00
/// <summary>
/// Deletes the specified request.
/// </summary>
/// <param name="request">The request.</param>
2013-06-06 12:08:46 +00:00
public void Delete ( DeleteItem request )
{
var task = DeleteItem ( request ) ;
Task . WaitAll ( task ) ;
}
private async Task DeleteItem ( DeleteItem request )
2013-05-22 14:44:51 +00:00
{
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 19:49:12 +00:00
await
parent . ValidateChildren ( new Progress < double > ( ) , CancellationToken . None )
. ConfigureAwait ( false ) ;
2013-05-22 14:44:51 +00: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 01:46:36 +00:00
}
2013-05-11 04:10:58 +00: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 19:49:12 +00:00
{
TotalRecordCount = reviewsArray . Length
} ;
2013-05-11 04:10:58 +00: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 16:56:38 +00: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 19:49:12 +00: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 16:56:38 +00:00
// Get everything
2013-06-12 21:46:50 +00:00
var fields = Enum . GetNames ( typeof ( ItemFields ) )
2013-05-22 19:49:12 +00:00
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
2013-05-15 16:56:38 +00:00
2013-06-18 19:16:27 +00:00
var dtoBuilder = new DtoBuilder ( Logger , _libraryManager , _userDataRepository , _itemRepo ) ;
2013-05-15 16:56:38 +00:00
2013-06-17 20:35:43 +00:00
var items = _itemRepo . RetrieveItems < Audio > ( item . ThemeSongIds )
2013-05-22 19:49:12 +00:00
. OrderBy ( i = > i . SortName )
. Select ( i = > dtoBuilder . GetBaseItemDto ( i , fields , user ) )
. Select ( t = > t . Result )
. ToArray ( ) ;
2013-05-15 16:56:38 +00:00
var result = new ThemeSongsResult
2013-06-12 21:46:50 +00:00
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = DtoBuilder . GetClientItemId ( item )
} ;
2013-05-15 16:56:38 +00: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 19:49:12 +00: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 16:56:38 +00:00
// Get everything
2013-05-22 19:49:12 +00:00
var fields =
Enum . GetNames ( typeof ( ItemFields ) )
. Select ( i = > ( ItemFields ) Enum . Parse ( typeof ( ItemFields ) , i , true ) )
. ToList ( ) ;
2013-05-15 16:56:38 +00:00
2013-06-18 19:16:27 +00:00
var dtoBuilder = new DtoBuilder ( Logger , _libraryManager , _userDataRepository , _itemRepo ) ;
2013-05-15 16:56:38 +00:00
2013-05-22 19:49:12 +00:00
var items =
2013-06-17 20:35:43 +00:00
_itemRepo . RetrieveItems < Video > ( item . ThemeVideoIds )
2013-05-22 19:49:12 +00:00
. OrderBy ( i = > i . SortName )
. Select ( i = > dtoBuilder . GetBaseItemDto ( i , fields , user ) )
. Select ( t = > t . Result )
. ToArray ( ) ;
2013-05-15 16:56:38 +00:00
var result = new ThemeVideosResult
2013-05-22 19:49:12 +00:00
{
Items = items ,
TotalRecordCount = items . Length ,
OwnerId = DtoBuilder . GetClientItemId ( item )
} ;
2013-05-15 16:56:38 +00:00
return ToOptimizedResult ( result ) ;
}
2013-05-15 22:55:24 +00:00
2013-05-22 04:21:36 +00:00
/// <summary>
/// Posts the specified request.
/// </summary>
/// <param name="request">The request.</param>
2013-05-22 19:49:12 +00:00
public void Post ( RefreshItem request )
{
var task = RefreshItem ( request ) ;
Task . WaitAll ( task ) ;
}
2013-05-25 23:52:41 +00:00
/// <summary>
/// Refreshes the item.
/// </summary>
/// <param name="request">The request.</param>
/// <returns>Task.</returns>
2013-05-22 19:49:12 +00:00
private async Task RefreshItem ( RefreshItem request )
2013-05-22 04:21:36 +00:00
{
var item = DtoBuilder . GetItemByClientId ( request . Id , _userManager , _libraryManager ) ;
2013-05-22 04:39:10 +00:00
var folder = item as Folder ;
2013-05-22 14:44:51 +00:00
try
2013-05-22 04:39:10 +00:00
{
2013-05-24 16:05:53 +00:00
await item . RefreshMetadata ( CancellationToken . None , forceRefresh : request . Forced ) . ConfigureAwait ( false ) ;
2013-05-22 14:44:51 +00:00
if ( folder ! = null )
{
2013-05-24 16:05:53 +00:00
await folder . ValidateChildren ( new Progress < double > ( ) , CancellationToken . None , request . Recursive ,
2013-05-22 19:49:12 +00:00
request . Forced ) . ConfigureAwait ( false ) ;
2013-05-22 14:44:51 +00:00
}
2013-05-22 04:39:10 +00:00
}
2013-05-22 14:44:51 +00:00
catch ( Exception ex )
2013-05-22 04:39:10 +00:00
{
2013-05-22 14:44:51 +00:00
Logger . ErrorException ( "Error refreshing library" , ex ) ;
2013-05-22 04:39:10 +00:00
}
2013-05-22 04:21:36 +00:00
}
2013-05-11 04:10:58 +00:00
}
}