using MediaBrowser.Controller.Dto;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Entities.Audio;
using MediaBrowser.Controller.Entities.Movies;
using MediaBrowser.Controller.Entities.TV;
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Localization;
using MediaBrowser.Controller.Persistence;
using MediaBrowser.Model.Entities;
using MediaBrowser.Model.Querying;
using ServiceStack.ServiceHost;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace MediaBrowser.Api.UserLibrary
{
    /// 
    /// Class GetItems
    /// 
    [Route("/Users/{UserId}/Items", "GET")]
    [Api(Description = "Gets items based on a query.")]
    public class GetItems : BaseItemsRequest, IReturn
    {
        /// 
        /// Gets or sets the user id.
        /// 
        /// The user id.
        [ApiMember(Name = "UserId", Description = "User Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
        public Guid UserId { get; set; }
        /// 
        /// Limit results to items containing a specific person
        /// 
        /// The person.
        [ApiMember(Name = "Person", Description = "Optional. If specified, results will be filtered to include only those containing the specified person.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public string Person { get; set; }
        /// 
        /// What to sort the results by
        /// 
        /// The sort by.
        [ApiMember(Name = "SortBy", Description = "Optional. Specify one or more sort orders, comma delimeted. Options: Album, AlbumArtist, Artist, Budget, CommunityRating, DateCreated, DatePlayed, PlayCount, PremiereDate, ProductionYear, SortName, Random, Revenue, Runtime", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string SortBy { get; set; }
        /// 
        /// If the Person filter is used, this can also be used to restrict to a specific person type
        /// 
        /// The type of the person.
        [ApiMember(Name = "PersonTypes", Description = "Optional. If specified, along with Person, results will be filtered to include only those containing the specified person and PersonType. Allows multiple, comma-delimited", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public string PersonTypes { get; set; }
        /// 
        /// Search characters used to find items
        /// 
        /// The index by.
        [ApiMember(Name = "SearchTerm", Description = "Optional. If specified, results will be filtered based on a search term.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public string SearchTerm { get; set; }
        /// 
        /// The dynamic, localized index function name
        /// 
        /// The index by.
        public string IndexBy { get; set; }
        /// 
        /// Limit results to items containing specific genres
        /// 
        /// The genres.
        [ApiMember(Name = "Genres", Description = "Optional. If specified, results will be filtered based on genre. This allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string Genres { get; set; }
        /// 
        /// Limit results to items containing specific studios
        /// 
        /// The studios.
        [ApiMember(Name = "Studios", Description = "Optional. If specified, results will be filtered based on studio. This allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string Studios { get; set; }
        /// 
        /// Gets or sets the studios.
        /// 
        /// The studios.
        [ApiMember(Name = "Artists", Description = "Optional. If specified, results will be filtered based on studio. This allows multiple, pipe delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string Artists { get; set; }
        /// 
        /// Limit results to items containing specific years
        /// 
        /// The years.
        [ApiMember(Name = "Years", Description = "Optional. If specified, results will be filtered based on production year. This allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string Years { get; set; }
        /// 
        /// Gets or sets the image types.
        /// 
        /// The image types.
        [ApiMember(Name = "ImageTypes", Description = "Optional. If specified, results will be filtered based on those containing image types. This allows multiple, comma delimited.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string ImageTypes { get; set; }
        /// 
        /// Gets or sets the item ids.
        /// 
        /// The item ids.
        [ApiMember(Name = "Ids", Description = "Optional. If specific items are needed, specify a list of item id's to retrieve. This allows multiple, comma delimited.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string Ids { get; set; }
        /// 
        /// Gets or sets the video types.
        /// 
        /// The video types.
        [ApiMember(Name = "VideoTypes", Description = "Optional filter by VideoType (videofile, dvd, bluray, iso). Allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string VideoTypes { get; set; }
        /// 
        /// Gets or sets the video formats.
        /// 
        /// The video formats.
        [ApiMember(Name = "VideoFormats", Description = "Optional filter by VideoFormat (Standard, Digital3D, Sbs3D). Allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string VideoFormats { get; set; }
        /// 
        /// Gets or sets the series status.
        /// 
        /// The series status.
        [ApiMember(Name = "SeriesStatus", Description = "Optional filter by Series Status. Allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string SeriesStatus { get; set; }
        /// 
        /// Gets or sets the air days.
        /// 
        /// The air days.
        [ApiMember(Name = "AirDays", Description = "Optional filter by Series Air Days. Allows multiple, comma delimeted.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET", AllowMultiple = true)]
        public string AirDays { get; set; }
        /// 
        /// Gets or sets the min offical rating.
        /// 
        /// The min offical rating.
        [ApiMember(Name = "MinOfficialRating", Description = "Optional filter by minimum official rating (PG, PG-13, TV-MA, etc).", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public string MinOfficialRating { get; set; }
        /// 
        /// Gets or sets the max offical rating.
        /// 
        /// The max offical rating.
        [ApiMember(Name = "MaxOfficialRating", Description = "Optional filter by maximum official rating (PG, PG-13, TV-MA, etc).", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public string MaxOfficialRating { get; set; }
        [ApiMember(Name = "HasThemeSong", Description = "Optional filter by items with theme songs.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public bool? HasThemeSong { get; set; }
        [ApiMember(Name = "HasThemeVideo", Description = "Optional filter by items with theme videos.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public bool? HasThemeVideo { get; set; }
        [ApiMember(Name = "HasSubtitles", Description = "Optional filter by items with subtitles.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public bool? HasSubtitles { get; set; }
        [ApiMember(Name = "HasSpecialFeature", Description = "Optional filter by items with special features.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public bool? HasSpecialFeature { get; set; }
        [ApiMember(Name = "HasTrailer", Description = "Optional filter by items with trailers.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
        public bool? HasTrailer { get; set; }
        
        /// 
        /// Gets the order by.
        /// 
        /// IEnumerable{ItemSortBy}.
        public IEnumerable GetOrderBy()
        {
            var val = SortBy;
            if (string.IsNullOrEmpty(val))
            {
                return new string[] { };
            }
            return val.Split(',');
        }
    }
    /// 
    /// Class ItemsService
    /// 
    public class ItemsService : BaseApiService
    {
        /// 
        /// The _user manager
        /// 
        private readonly IUserManager _userManager;
        private readonly IUserDataRepository _userDataRepository;
        /// 
        /// The _library manager
        /// 
        private readonly ILibraryManager _libraryManager;
        private readonly ILibrarySearchEngine _searchEngine;
        /// 
        /// Initializes a new instance of the  class.
        /// 
        /// The user manager.
        /// The library manager.
        /// The search engine.
        /// The user data repository.
        public ItemsService(IUserManager userManager, ILibraryManager libraryManager, ILibrarySearchEngine searchEngine, IUserDataRepository userDataRepository)
        {
            _userManager = userManager;
            _libraryManager = libraryManager;
            _searchEngine = searchEngine;
            _userDataRepository = userDataRepository;
        }
        /// 
        /// Gets the specified request.
        /// 
        /// The request.
        /// System.Object.
        public object Get(GetItems request)
        {
            var result = GetItems(request).Result;
            return ToOptimizedResult(result);
        }
        /// 
        /// Gets the items.
        /// 
        /// The request.
        /// Task{ItemsResult}.
        private async Task GetItems(GetItems request)
        {
            var user = _userManager.GetUserById(request.UserId);
            var items = GetItemsToSerialize(request, user);
            items = items.AsParallel();
            items = ApplyAdditionalFilters(request, items);
            // Apply filters
            // Run them starting with the ones that are likely to reduce the list the most
            foreach (var filter in request.GetFilters().OrderByDescending(f => (int)f))
            {
                items = ApplyFilter(items, filter, user, _userDataRepository);
            }
            items = items.AsEnumerable();
            items = ApplySearchTerm(request, items);
            items = ApplySortOrder(request, items, user, _libraryManager);
            var itemsArray = items.ToArray();
            var pagedItems = ApplyPaging(request, itemsArray);
            var fields = request.GetItemFields().ToList();
            var dtoBuilder = new DtoBuilder(Logger, _libraryManager, _userDataRepository);
            var returnItems = await Task.WhenAll(pagedItems.Select(i => dtoBuilder.GetBaseItemDto(i, user, fields))).ConfigureAwait(false);
            return new ItemsResult
            {
                TotalRecordCount = itemsArray.Length,
                Items = returnItems
            };
        }
        /// 
        /// Gets the items to serialize.
        /// 
        /// The request.
        /// The user.
        /// IEnumerable{BaseItem}.
        /// 
        private IEnumerable GetItemsToSerialize(GetItems request, User user)
        {
            var item = string.IsNullOrEmpty(request.ParentId) ? user.RootFolder : DtoBuilder.GetItemByClientId(request.ParentId, _userManager, _libraryManager, user.Id);
            // Default list type = children
            if (!string.IsNullOrEmpty(request.Ids))
            {
                var idList = request.Ids.Split(',').ToList();
                return idList.Select(i => DtoBuilder.GetItemByClientId(i, _userManager, _libraryManager, user.Id));
            }
            if (request.Recursive)
            {
                return ((Folder)item).GetRecursiveChildren(user);
            }
            return ((Folder)item).GetChildren(user, request.IndexBy);
        }
        /// 
        /// Applies sort order
        /// 
        /// The request.
        /// The items.
        /// The user.
        /// The library manager.
        /// IEnumerable{BaseItem}.
        internal static IEnumerable ApplySortOrder(GetItems request, IEnumerable items, User user, ILibraryManager libraryManager)
        {
            var orderBy = request.GetOrderBy().ToArray();
            return orderBy.Length == 0 ? items : libraryManager.Sort(items, user, orderBy, request.SortOrder ?? SortOrder.Ascending);
        }
        /// 
        /// Applies filtering
        /// 
        /// The items.
        /// The filter.
        /// The user.
        /// The repository.
        /// IEnumerable{BaseItem}.
        internal static IEnumerable ApplyFilter(IEnumerable items, ItemFilter filter, User user, IUserDataRepository repository)
        {
            // Avoids implicitly captured closure
            var currentUser = user;
            switch (filter)
            {
                case ItemFilter.Likes:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata != null && userdata.Likes.HasValue && userdata.Likes.Value;
                    });
                case ItemFilter.Dislikes:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata != null && userdata.Likes.HasValue && !userdata.Likes.Value;
                    });
                case ItemFilter.IsFavorite:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata != null && userdata.IsFavorite;
                    });
                case ItemFilter.IsRecentlyAdded:
                    return items.Where(item => item.IsRecentlyAdded());
                case ItemFilter.IsResumable:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata != null && userdata.PlaybackPositionTicks > 0;
                    });
                case ItemFilter.IsPlayed:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata != null && userdata.PlayCount > 0;
                    });
                case ItemFilter.IsUnplayed:
                    return items.Where(item =>
                    {
                        var userdata = repository.GetUserData(user.Id, item.GetUserDataKey()).Result;
                        return userdata == null || userdata.PlayCount == 0;
                    });
                case ItemFilter.IsFolder:
                    return items.Where(item => item.IsFolder);
                case ItemFilter.IsNotFolder:
                    return items.Where(item => !item.IsFolder);
            }
            return items;
        }
        /// 
        /// Applies the additional filters.
        /// 
        /// The request.
        /// The items.
        /// IEnumerable{BaseItem}.
        internal static IEnumerable ApplyAdditionalFilters(GetItems request, IEnumerable items)
        {
            // Artists
            if (!string.IsNullOrEmpty(request.Artists))
            {
                var artists = request.Artists.Split('|');
                items = items.Where(i =>
                {
                    var audio = i as Audio;
                    if (audio != null)
                    {
                        return artists.Any(audio.HasArtist);
                    }
                    var album = i as MusicAlbum;
                    if (album != null)
                    {
                        return artists.Any(album.HasArtist);
                    }
                    return false;
                });
            }
            // Min official rating
            if (!string.IsNullOrEmpty(request.MinOfficialRating))
            {
                var level = Ratings.Level(request.MinOfficialRating);
                items = items.Where(i => Ratings.Level(i.CustomRating ?? i.OfficialRating) >= level);
            }
            // Max official rating
            if (!string.IsNullOrEmpty(request.MaxOfficialRating))
            {
                var level = Ratings.Level(request.MaxOfficialRating);
                items = items.Where(i => Ratings.Level(i.CustomRating ?? i.OfficialRating) <= level);
            }
            // Exclude item types
            if (!string.IsNullOrEmpty(request.ExcludeItemTypes))
            {
                var vals = request.ExcludeItemTypes.Split(',');
                items = items.Where(f => !vals.Contains(f.GetType().Name, StringComparer.OrdinalIgnoreCase));
            }
            // Include item types
            if (!string.IsNullOrEmpty(request.IncludeItemTypes))
            {
                var vals = request.IncludeItemTypes.Split(',');
                items = items.Where(f => vals.Contains(f.GetType().Name, StringComparer.OrdinalIgnoreCase));
            }
            
            // Filter by Series Status
            if (!string.IsNullOrEmpty(request.SeriesStatus))
            {
                var vals = request.SeriesStatus.Split(',');
                items = items.OfType().Where(i => i.Status.HasValue && vals.Contains(i.Status.Value.ToString(), StringComparer.OrdinalIgnoreCase));
            }
            // Filter by Series AirDays
            if (!string.IsNullOrEmpty(request.AirDays))
            {
                var days = request.AirDays.Split(',').Select(d => (DayOfWeek)Enum.Parse(typeof(DayOfWeek), d, true));
                items = items.OfType().Where(i => i.AirDays != null && days.Any(d => i.AirDays.Contains(d)));
            }
            // Filter by VideoFormat
            if (!string.IsNullOrEmpty(request.VideoFormats))
            {
                var formats = request.VideoFormats.Split(',');
                items = items.OfType