using MediaBrowser.Common.IO;
using MediaBrowser.Common.Net;
using MediaBrowser.Controller.Configuration;
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.LiveTv;
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.Configuration;
using MediaBrowser.Model.Entities;
using MediaBrowser.Model.Logging;
using MediaBrowser.Model.Providers;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
namespace MediaBrowser.Providers.Manager
{
    /// 
    /// Class ProviderManager
    /// 
    public class ProviderManager : IProviderManager
    {
        /// 
        /// The _logger
        /// 
        private readonly ILogger _logger;
        /// 
        /// The _HTTP client
        /// 
        private readonly IHttpClient _httpClient;
        /// 
        /// The _directory watchers
        /// 
        private readonly ILibraryMonitor _libraryMonitor;
        /// 
        /// Gets or sets the configuration manager.
        /// 
        /// The configuration manager.
        private IServerConfigurationManager ConfigurationManager { get; set; }
        private IImageProvider[] ImageProviders { get; set; }
        private readonly IFileSystem _fileSystem;
        private IMetadataService[] _metadataServices = { };
        private IItemIdentityProvider[] _identityProviders = { };
        private IItemIdentityConverter[] _identityConverters = { };
        private IMetadataProvider[] _metadataProviders = { };
        private IEnumerable _savers;
        private IImageSaver[] _imageSavers;
        private IExternalId[] _externalIds;
        /// 
        /// Initializes a new instance of the  class.
        /// 
        /// The HTTP client.
        /// The configuration manager.
        /// The directory watchers.
        /// The log manager.
        /// The file system.
        public ProviderManager(IHttpClient httpClient, IServerConfigurationManager configurationManager, ILibraryMonitor libraryMonitor, ILogManager logManager, IFileSystem fileSystem)
        {
            _logger = logManager.GetLogger("ProviderManager");
            _httpClient = httpClient;
            ConfigurationManager = configurationManager;
            _libraryMonitor = libraryMonitor;
            _fileSystem = fileSystem;
        }
        /// 
        /// Adds the metadata providers.
        /// 
        /// The image providers.
        /// The metadata services.
        /// The identity providers.
        /// The identity converters.
        /// The metadata providers.
        /// The metadata savers.
        /// The image savers.
        /// The external ids.
        public void AddParts(IEnumerable imageProviders, IEnumerable metadataServices,
                             IEnumerable identityProviders, IEnumerable identityConverters,
                             IEnumerable metadataProviders, IEnumerable metadataSavers,
                             IEnumerable imageSavers, IEnumerable externalIds)
        {
            ImageProviders = imageProviders.ToArray();
            _metadataServices = metadataServices.OrderBy(i => i.Order).ToArray();
            _identityProviders = identityProviders.ToArray();
            _identityConverters = identityConverters.ToArray();
            _metadataProviders = metadataProviders.ToArray();
            _savers = metadataSavers.ToArray();
            _imageSavers = imageSavers.ToArray();
            _externalIds = externalIds.OrderBy(i => i.Name).ToArray();
        }
        public Task RefreshMetadata(IHasMetadata item, MetadataRefreshOptions options, CancellationToken cancellationToken)
        {
            var service = _metadataServices.FirstOrDefault(i => i.CanRefresh(item));
            if (service != null)
            {
                return service.RefreshMetadata(item, options, cancellationToken);
            }
            _logger.Error("Unable to find a metadata service for item of type " + item.GetType().Name);
            return Task.FromResult(true);
        }
        public async Task SaveImage(IHasImages item, string url, SemaphoreSlim resourcePool, ImageType type, int? imageIndex, CancellationToken cancellationToken)
        {
            var response = await _httpClient.GetResponse(new HttpRequestOptions
            {
                CancellationToken = cancellationToken,
                ResourcePool = resourcePool,
                Url = url
            }).ConfigureAwait(false);
            await SaveImage(item, response.Content, response.ContentType, type, imageIndex, cancellationToken)
                    .ConfigureAwait(false);
        }
        public Task SaveImage(IHasImages item, Stream source, string mimeType, ImageType type, int? imageIndex, CancellationToken cancellationToken)
        {
            return new ImageSaver(ConfigurationManager, _libraryMonitor, _fileSystem, _logger).SaveImage(item, source, mimeType, type, imageIndex, cancellationToken);
        }
        public Task SaveImage(IHasImages item, Stream source, string mimeType, ImageType type, int? imageIndex, string internalCacheKey, CancellationToken cancellationToken)
        {
            return new ImageSaver(ConfigurationManager, _libraryMonitor, _fileSystem, _logger).SaveImage(item, source, mimeType, type, imageIndex, internalCacheKey, cancellationToken);
        }
        public async Task> GetAvailableRemoteImages(IHasImages item, RemoteImageQuery query, CancellationToken cancellationToken)
        {
            var providers = GetRemoteImageProviders(item, query.IncludeDisabledProviders);
            if (!string.IsNullOrEmpty(query.ProviderName))
            {
                var providerName = query.ProviderName;
                providers = providers.Where(i => string.Equals(i.Name, providerName, StringComparison.OrdinalIgnoreCase));
            }
            var preferredLanguage = item.GetPreferredMetadataLanguage();
            var languages = new List();
            if (!query.IncludeAllLanguages && !string.IsNullOrWhiteSpace(preferredLanguage))
            {
                languages.Add(preferredLanguage);
            }
            var tasks = providers.Select(i => GetImages(item, cancellationToken, i, languages, query.ImageType));
            var results = await Task.WhenAll(tasks).ConfigureAwait(false);
            var images = results.SelectMany(i => i);
            return images;
        }
        /// 
        /// Gets the images.
        /// 
        /// The item.
        /// The cancellation token.
        /// The provider.
        /// The preferred languages.
        /// The type.
        /// Task{IEnumerable{RemoteImageInfo}}.
        private async Task> GetImages(IHasImages item, CancellationToken cancellationToken, IRemoteImageProvider provider, List preferredLanguages, ImageType? type = null)
        {
            try
            {
                var result = await provider.GetImages(item, cancellationToken).ConfigureAwait(false);
                if (type.HasValue)
                {
                    result = result.Where(i => i.Type == type.Value);
                }
                if (preferredLanguages.Count > 0)
                {
                    result = result.Where(i => string.IsNullOrEmpty(i.Language) ||
                                               preferredLanguages.Contains(i.Language, StringComparer.OrdinalIgnoreCase) ||
                                               string.Equals(i.Language, "en", StringComparison.OrdinalIgnoreCase));
                }
                return result;
            }
            catch (OperationCanceledException)
            {
                return new List();
            }
            catch (Exception ex)
            {
                _logger.ErrorException("{0} failed in GetImageInfos for type {1}", ex, provider.GetType().Name, item.GetType().Name);
                return new List();
            }
        }
        /// 
        /// Gets the supported image providers.
        /// 
        /// The item.
        /// IEnumerable{IImageProvider}.
        public IEnumerable GetRemoteImageProviderInfo(IHasImages item)
        {
            return GetRemoteImageProviders(item, true).Select(i => new ImageProviderInfo
            {
                Name = i.Name,
                SupportedImages = i.GetSupportedImages(item).ToList()
            });
        }
        public IEnumerable GetImageProviders(IHasImages item)
        {
            return GetImageProviders(item, GetMetadataOptions(item), false);
        }
        private IEnumerable GetImageProviders(IHasImages item, MetadataOptions options, bool includeDisabled)
        {
            // Avoid implicitly captured closure
            var currentOptions = options;
            return ImageProviders.Where(i => CanRefresh(i, item, options, includeDisabled))
            .OrderBy(i =>
            {
                // See if there's a user-defined order
                if (!(i is ILocalImageProvider))
                {
                    var index = Array.IndexOf(currentOptions.ImageFetcherOrder, i.Name);
                    if (index != -1)
                    {
                        return index;
                    }
                }
                // Not configured. Just return some high number to put it at the end.
                return 100;
            })
            .ThenBy(GetOrder);
        }
        public IEnumerable> GetMetadataProviders(IHasMetadata item)
            where T : IHasMetadata
        {
            var options = GetMetadataOptions(item);
            return GetMetadataProvidersInternal(item, options, false);
        }
        private IEnumerable> GetMetadataProvidersInternal(IHasMetadata item, MetadataOptions options, bool includeDisabled)
            where T : IHasMetadata
        {
            // Avoid implicitly captured closure
            var currentOptions = options;
            return _metadataProviders.OfType>()
                .Where(i => CanRefresh(i, item, currentOptions, includeDisabled))
                .OrderBy(i => GetConfiguredOrder(i, options))
                .ThenBy(GetDefaultOrder);
        }
        public IEnumerable> GetItemIdentityProviders()
            where TLookupInfo : ItemLookupInfo
            where TIdentity : IItemIdentity
        {
            return _identityProviders.OfType>();
        }
        public IEnumerable> GetItemIdentityConverters()
            where TIdentity : IItemIdentity
        {
            return _identityConverters.OfType>();
        }
        private IEnumerable GetRemoteImageProviders(IHasImages item, bool includeDisabled)
        {
            var options = GetMetadataOptions(item);
            return GetImageProviders(item, options, includeDisabled).OfType();
        }
        private bool CanRefresh(IMetadataProvider provider, IHasMetadata item, MetadataOptions options, bool includeDisabled)
        {
            if (!includeDisabled)
            {
                // If locked only allow local providers
                if (item.IsLocked && !(provider is ILocalMetadataProvider) && !(provider is IForcedProvider))
                {
                    return false;
                }
                if (provider is IRemoteMetadataProvider)
                {
                    if (!ConfigurationManager.Configuration.EnableInternetProviders)
                    {
                        return false;
                    }
                    if (Array.IndexOf(options.DisabledMetadataFetchers, provider.Name) != -1)
                    {
                        return false;
                    }
                }
            }
            if (!item.SupportsLocalMetadata && provider is ILocalMetadataProvider)
            {
                return false;
            }
            // If this restriction is ever lifted, movie xml providers will have to be updated to prevent owned items like trailers from reading those files
            if (item.IsOwnedItem)
            {
                if (provider is ILocalMetadataProvider || provider is IRemoteMetadataProvider)
                {
                    return false;
                }
            }
            return true;
        }
        private bool CanRefresh(IImageProvider provider, IHasImages item, MetadataOptions options, bool includeDisabled)
        {
            if (!includeDisabled)
            {
                // If locked only allow local providers
                if (item.IsLocked && !(provider is ILocalImageProvider))
                {
                    return false;
                }
                if (provider is IRemoteImageProvider || provider is IDynamicImageProvider)
                {
                    if (Array.IndexOf(options.DisabledImageFetchers, provider.Name) != -1)
                    {
                        return false;
                    }
                    if (provider is IRemoteImageProvider)
                    {
                        if (!ConfigurationManager.Configuration.EnableInternetProviders)
                        {
                            return false;
                        }
                    }
                }
            }
            try
            {
                return provider.Supports(item);
            }
            catch (Exception ex)
            {
                _logger.ErrorException("{0} failed in Supports for type {1}", ex, provider.GetType().Name, item.GetType().Name);
                return false;
            }
        }
        /// 
        /// Gets the order.
        /// 
        /// The provider.
        /// System.Int32.
        private int GetOrder(IImageProvider provider)
        {
            var hasOrder = provider as IHasOrder;
            if (hasOrder == null)
            {
                return 0;
            }
            return hasOrder.Order;
        }
        private int GetConfiguredOrder(IMetadataProvider provider, MetadataOptions options)
        {
            // See if there's a user-defined order
            if (provider is ILocalMetadataProvider)
            {
                var index = Array.IndexOf(options.LocalMetadataReaderOrder, provider.Name);
                if (index != -1)
                {
                    return index;
                }
            }
            // See if there's a user-defined order
            if (provider is IRemoteMetadataProvider)
            {
                var index = Array.IndexOf(options.MetadataFetcherOrder, provider.Name);
                if (index != -1)
                {
                    return index;
                }
            }
            // Not configured. Just return some high number to put it at the end.
            return 100;
        }
        private int GetDefaultOrder(IMetadataProvider provider)
        {
            var hasOrder = provider as IHasOrder;
            if (hasOrder != null)
            {
                return hasOrder.Order;
            }
            return 0;
        }
        public IEnumerable GetAllMetadataPlugins()
        {
            var list = new List
            {
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary(),
                GetPluginSummary