mirror of
https://github.com/jellyfin/jellyfin.git
synced 2025-11-03 19:17:24 -05:00
1131 lines
42 KiB
C#
1131 lines
42 KiB
C#
using MediaBrowser.Common.Net;
|
|
using MediaBrowser.Controller;
|
|
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.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Common.Progress;
|
|
using MediaBrowser.Model.IO;
|
|
using MediaBrowser.Controller.Dto;
|
|
using MediaBrowser.Model.Events;
|
|
using MediaBrowser.Model.Serialization;
|
|
using Priority_Queue;
|
|
using MediaBrowser.Model.Extensions;
|
|
|
|
namespace MediaBrowser.Providers.Manager
|
|
{
|
|
/// <summary>
|
|
/// Class ProviderManager
|
|
/// </summary>
|
|
public class ProviderManager : IProviderManager, IDisposable
|
|
{
|
|
/// <summary>
|
|
/// The _logger
|
|
/// </summary>
|
|
private readonly ILogger _logger;
|
|
|
|
/// <summary>
|
|
/// The _HTTP client
|
|
/// </summary>
|
|
private readonly IHttpClient _httpClient;
|
|
|
|
/// <summary>
|
|
/// The _directory watchers
|
|
/// </summary>
|
|
private readonly ILibraryMonitor _libraryMonitor;
|
|
|
|
/// <summary>
|
|
/// Gets or sets the configuration manager.
|
|
/// </summary>
|
|
/// <value>The configuration manager.</value>
|
|
private IServerConfigurationManager ConfigurationManager { get; set; }
|
|
|
|
private IImageProvider[] ImageProviders { get; set; }
|
|
|
|
private readonly IFileSystem _fileSystem;
|
|
|
|
private IMetadataService[] _metadataServices = { };
|
|
private IMetadataProvider[] _metadataProviders = { };
|
|
private IEnumerable<IMetadataSaver> _savers;
|
|
private readonly IServerApplicationPaths _appPaths;
|
|
private readonly IJsonSerializer _json;
|
|
|
|
private IExternalId[] _externalIds;
|
|
|
|
private readonly Func<ILibraryManager> _libraryManagerFactory;
|
|
private readonly IMemoryStreamFactory _memoryStreamProvider;
|
|
private CancellationTokenSource _disposeCancellationTokenSource = new CancellationTokenSource();
|
|
|
|
public event EventHandler<GenericEventArgs<BaseItem>> RefreshStarted;
|
|
public event EventHandler<GenericEventArgs<BaseItem>> RefreshCompleted;
|
|
public event EventHandler<GenericEventArgs<Tuple<BaseItem, double>>> RefreshProgress;
|
|
|
|
/// <summary>
|
|
/// Initializes a new instance of the <see cref="ProviderManager" /> class.
|
|
/// </summary>
|
|
/// <param name="httpClient">The HTTP client.</param>
|
|
/// <param name="configurationManager">The configuration manager.</param>
|
|
/// <param name="libraryMonitor">The directory watchers.</param>
|
|
/// <param name="logManager">The log manager.</param>
|
|
/// <param name="fileSystem">The file system.</param>
|
|
public ProviderManager(IHttpClient httpClient, IServerConfigurationManager configurationManager, ILibraryMonitor libraryMonitor, ILogManager logManager, IFileSystem fileSystem, IServerApplicationPaths appPaths, Func<ILibraryManager> libraryManagerFactory, IJsonSerializer json, IMemoryStreamFactory memoryStreamProvider)
|
|
{
|
|
_logger = logManager.GetLogger("ProviderManager");
|
|
_httpClient = httpClient;
|
|
ConfigurationManager = configurationManager;
|
|
_libraryMonitor = libraryMonitor;
|
|
_fileSystem = fileSystem;
|
|
_appPaths = appPaths;
|
|
_libraryManagerFactory = libraryManagerFactory;
|
|
_json = json;
|
|
_memoryStreamProvider = memoryStreamProvider;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds the metadata providers.
|
|
/// </summary>
|
|
public void AddParts(IEnumerable<IImageProvider> imageProviders, IEnumerable<IMetadataService> metadataServices,
|
|
IEnumerable<IMetadataProvider> metadataProviders, IEnumerable<IMetadataSaver> metadataSavers,
|
|
IEnumerable<IExternalId> externalIds)
|
|
{
|
|
ImageProviders = imageProviders.ToArray();
|
|
|
|
_metadataServices = metadataServices.OrderBy(i => i.Order).ToArray();
|
|
_metadataProviders = metadataProviders.ToArray();
|
|
_externalIds = externalIds.OrderBy(i => i.Name).ToArray();
|
|
|
|
_savers = metadataSavers.Where(i =>
|
|
{
|
|
var configurable = i as IConfigurableProvider;
|
|
|
|
return configurable == null || configurable.IsEnabled;
|
|
}).ToArray();
|
|
}
|
|
|
|
public Task<ItemUpdateType> RefreshSingleItem(IHasMetadata item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
|
{
|
|
IMetadataService service = null;
|
|
var type = item.GetType();
|
|
|
|
foreach (var current in _metadataServices)
|
|
{
|
|
if (current.CanRefreshPrimary(type))
|
|
{
|
|
service = current;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (service == null)
|
|
{
|
|
foreach (var current in _metadataServices)
|
|
{
|
|
if (current.CanRefresh(item))
|
|
{
|
|
service = current;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
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(ItemUpdateType.None);
|
|
}
|
|
|
|
public async Task SaveImage(IHasMetadata item, string url, ImageType type, int? imageIndex, CancellationToken cancellationToken)
|
|
{
|
|
using (var response = await _httpClient.GetResponse(new HttpRequestOptions
|
|
{
|
|
CancellationToken = cancellationToken,
|
|
Url = url,
|
|
BufferContent = false
|
|
|
|
}).ConfigureAwait(false))
|
|
{
|
|
await SaveImage(item, response.Content, response.ContentType, type, imageIndex, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
public Task SaveImage(IHasMetadata item, Stream source, string mimeType, ImageType type, int? imageIndex, CancellationToken cancellationToken)
|
|
{
|
|
return new ImageSaver(ConfigurationManager, _libraryMonitor, _fileSystem, _logger, _memoryStreamProvider).SaveImage(item, source, mimeType, type, imageIndex, cancellationToken);
|
|
}
|
|
|
|
public Task SaveImage(IHasMetadata item, string source, string mimeType, ImageType type, int? imageIndex, bool? saveLocallyWithMedia, CancellationToken cancellationToken)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(source))
|
|
{
|
|
throw new ArgumentNullException("source");
|
|
}
|
|
|
|
var fileStream = _fileSystem.GetFileStream(source, FileOpenMode.Open, FileAccessMode.Read, FileShareMode.ReadWrite, true);
|
|
|
|
return new ImageSaver(ConfigurationManager, _libraryMonitor, _fileSystem, _logger, _memoryStreamProvider).SaveImage(item, fileStream, mimeType, type, imageIndex, saveLocallyWithMedia, cancellationToken);
|
|
}
|
|
|
|
public async Task<IEnumerable<RemoteImageInfo>> GetAvailableRemoteImages(IHasMetadata 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<string>();
|
|
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);
|
|
|
|
return results.SelectMany(i => i.ToList());
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets the images.
|
|
/// </summary>
|
|
/// <param name="item">The item.</param>
|
|
/// <param name="cancellationToken">The cancellation token.</param>
|
|
/// <param name="provider">The provider.</param>
|
|
/// <param name="preferredLanguages">The preferred languages.</param>
|
|
/// <param name="type">The type.</param>
|
|
/// <returns>Task{IEnumerable{RemoteImageInfo}}.</returns>
|
|
private async Task<IEnumerable<RemoteImageInfo>> GetImages(IHasMetadata item, CancellationToken cancellationToken, IRemoteImageProvider provider, List<string> 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<RemoteImageInfo>();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("{0} failed in GetImageInfos for type {1}", ex, provider.GetType().Name, item.GetType().Name);
|
|
return new List<RemoteImageInfo>();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets the supported image providers.
|
|
/// </summary>
|
|
/// <param name="item">The item.</param>
|
|
/// <returns>IEnumerable{IImageProvider}.</returns>
|
|
public IEnumerable<ImageProviderInfo> GetRemoteImageProviderInfo(IHasMetadata item)
|
|
{
|
|
return GetRemoteImageProviders(item, true).Select(i => new ImageProviderInfo
|
|
{
|
|
Name = i.Name,
|
|
SupportedImages = i.GetSupportedImages(item).ToArray()
|
|
});
|
|
}
|
|
|
|
public IEnumerable<IImageProvider> GetImageProviders(IHasMetadata item, ImageRefreshOptions refreshOptions)
|
|
{
|
|
return GetImageProviders(item, GetMetadataOptions(item), refreshOptions, false);
|
|
}
|
|
|
|
private IEnumerable<IImageProvider> GetImageProviders(IHasMetadata item, MetadataOptions options, ImageRefreshOptions refreshOptions, bool includeDisabled)
|
|
{
|
|
// Avoid implicitly captured closure
|
|
var currentOptions = options;
|
|
|
|
return ImageProviders.Where(i => CanRefresh(i, item, options, refreshOptions, 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<IMetadataProvider<T>> GetMetadataProviders<T>(IHasMetadata item)
|
|
where T : IHasMetadata
|
|
{
|
|
var options = GetMetadataOptions(item);
|
|
|
|
return GetMetadataProvidersInternal<T>(item, options, false, false, true);
|
|
}
|
|
|
|
private IEnumerable<IMetadataProvider<T>> GetMetadataProvidersInternal<T>(IHasMetadata item, MetadataOptions options, bool includeDisabled, bool forceEnableInternetMetadata, bool checkIsOwnedItem)
|
|
where T : IHasMetadata
|
|
{
|
|
// Avoid implicitly captured closure
|
|
var currentOptions = options;
|
|
|
|
return _metadataProviders.OfType<IMetadataProvider<T>>()
|
|
.Where(i => CanRefresh(i, item, currentOptions, includeDisabled, forceEnableInternetMetadata, checkIsOwnedItem))
|
|
.OrderBy(i => GetConfiguredOrder(i, options))
|
|
.ThenBy(GetDefaultOrder);
|
|
}
|
|
|
|
private IEnumerable<IRemoteImageProvider> GetRemoteImageProviders(IHasMetadata item, bool includeDisabled)
|
|
{
|
|
var options = GetMetadataOptions(item);
|
|
|
|
return GetImageProviders(item, options, new ImageRefreshOptions(new DirectoryService(_logger, _fileSystem)), includeDisabled).OfType<IRemoteImageProvider>();
|
|
}
|
|
|
|
private bool CanRefresh(IMetadataProvider provider, IHasMetadata item, MetadataOptions options, bool includeDisabled, bool forceEnableInternetMetadata, bool checkIsOwnedItem)
|
|
{
|
|
if (!includeDisabled)
|
|
{
|
|
// If locked only allow local providers
|
|
if (item.IsLocked && !(provider is ILocalMetadataProvider) && !(provider is IForcedProvider))
|
|
{
|
|
return false;
|
|
}
|
|
|
|
if (provider is IRemoteMetadataProvider)
|
|
{
|
|
if (!forceEnableInternetMetadata && !item.IsInternetMetadataEnabled())
|
|
{
|
|
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 (checkIsOwnedItem && item.IsOwnedItem)
|
|
{
|
|
if (provider is ILocalMetadataProvider || provider is IRemoteMetadataProvider)
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
private bool CanRefresh(IImageProvider provider, IHasMetadata item, MetadataOptions options, ImageRefreshOptions refreshOptions, bool includeDisabled)
|
|
{
|
|
if (!includeDisabled)
|
|
{
|
|
// If locked only allow local providers
|
|
if (item.IsLocked && !(provider is ILocalImageProvider))
|
|
{
|
|
if (refreshOptions.ImageRefreshMode != ImageRefreshMode.FullRefresh)
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if (provider is IRemoteImageProvider || provider is IDynamicImageProvider)
|
|
{
|
|
if (Array.IndexOf(options.DisabledImageFetchers, provider.Name) != -1)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
if (provider is IRemoteImageProvider)
|
|
{
|
|
if (!refreshOptions.ForceEnableInternetMetadata && !item.IsInternetMetadataEnabled())
|
|
{
|
|
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;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets the order.
|
|
/// </summary>
|
|
/// <param name="provider">The provider.</param>
|
|
/// <returns>System.Int32.</returns>
|
|
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 MetadataPluginSummary[] GetAllMetadataPlugins()
|
|
{
|
|
return new MetadataPluginSummary[]
|
|
{
|
|
GetPluginSummary<Game>(),
|
|
GetPluginSummary<GameSystem>(),
|
|
GetPluginSummary<Movie>(),
|
|
GetPluginSummary<BoxSet>(),
|
|
GetPluginSummary<Book>(),
|
|
GetPluginSummary<Series>(),
|
|
GetPluginSummary<Season>(),
|
|
GetPluginSummary<Episode>(),
|
|
GetPluginSummary<Person>(),
|
|
GetPluginSummary<MusicAlbum>(),
|
|
GetPluginSummary<MusicArtist>(),
|
|
GetPluginSummary<Audio>(),
|
|
GetPluginSummary<AudioBook>(),
|
|
GetPluginSummary<AudioPodcast>(),
|
|
GetPluginSummary<Genre>(),
|
|
GetPluginSummary<Studio>(),
|
|
GetPluginSummary<GameGenre>(),
|
|
GetPluginSummary<MusicGenre>(),
|
|
GetPluginSummary<MusicVideo>(),
|
|
GetPluginSummary<Video>(),
|
|
GetPluginSummary<LiveTvChannel>(),
|
|
GetPluginSummary<LiveTvProgram>(),
|
|
GetPluginSummary<LiveTvVideoRecording>(),
|
|
GetPluginSummary<LiveTvAudioRecording>()
|
|
};
|
|
}
|
|
|
|
private MetadataPluginSummary GetPluginSummary<T>()
|
|
where T : BaseItem, new()
|
|
{
|
|
// Give it a dummy path just so that it looks like a file system item
|
|
var dummy = new T()
|
|
{
|
|
Path = Path.Combine(_appPaths.InternalMetadataPath, "dummy"),
|
|
ParentId = Guid.NewGuid()
|
|
};
|
|
|
|
var options = GetMetadataOptions(dummy);
|
|
|
|
var summary = new MetadataPluginSummary
|
|
{
|
|
ItemType = typeof(T).Name
|
|
};
|
|
|
|
var imageProviders = GetImageProviders(dummy, options, new ImageRefreshOptions(new DirectoryService(_logger, _fileSystem)), true).ToList();
|
|
|
|
var pluginList = summary.Plugins.ToList();
|
|
|
|
AddMetadataPlugins(pluginList, dummy, options);
|
|
AddImagePlugins(pluginList, dummy, imageProviders);
|
|
|
|
summary.Plugins = pluginList.ToArray(pluginList.Count);
|
|
|
|
var supportedImageTypes = imageProviders.OfType<IRemoteImageProvider>()
|
|
.SelectMany(i => i.GetSupportedImages(dummy))
|
|
.ToList();
|
|
|
|
supportedImageTypes.AddRange(imageProviders.OfType<IDynamicImageProvider>()
|
|
.SelectMany(i => i.GetSupportedImages(dummy)));
|
|
|
|
summary.SupportedImageTypes = supportedImageTypes.Distinct().ToArray();
|
|
|
|
return summary;
|
|
}
|
|
|
|
private void AddMetadataPlugins<T>(List<MetadataPlugin> list, T item, MetadataOptions options)
|
|
where T : IHasMetadata
|
|
{
|
|
var providers = GetMetadataProvidersInternal<T>(item, options, true, false, false).ToList();
|
|
|
|
// Locals
|
|
list.AddRange(providers.Where(i => (i is ILocalMetadataProvider)).Select(i => new MetadataPlugin
|
|
{
|
|
Name = i.Name,
|
|
Type = MetadataPluginType.LocalMetadataProvider
|
|
}));
|
|
|
|
// Fetchers
|
|
list.AddRange(providers.Where(i => (i is IRemoteMetadataProvider)).Select(i => new MetadataPlugin
|
|
{
|
|
Name = i.Name,
|
|
Type = MetadataPluginType.MetadataFetcher
|
|
}));
|
|
|
|
// Savers
|
|
list.AddRange(_savers.Where(i => IsSaverEnabledForItem(i, item, ItemUpdateType.MetadataEdit, true)).OrderBy(i => i.Name).Select(i => new MetadataPlugin
|
|
{
|
|
Name = i.Name,
|
|
Type = MetadataPluginType.MetadataSaver
|
|
}));
|
|
}
|
|
|
|
private void AddImagePlugins<T>(List<MetadataPlugin> list, T item, List<IImageProvider> imageProviders)
|
|
where T : IHasMetadata
|
|
{
|
|
|
|
// Locals
|
|
list.AddRange(imageProviders.Where(i => (i is ILocalImageProvider)).Select(i => new MetadataPlugin
|
|
{
|
|
Name = i.Name,
|
|
Type = MetadataPluginType.LocalImageProvider
|
|
}));
|
|
|
|
var enableInternet = item.IsInternetMetadataEnabled();
|
|
|
|
// Fetchers
|
|
list.AddRange(imageProviders.Where(i => i is IDynamicImageProvider || (enableInternet && i is IRemoteImageProvider)).Select(i => new MetadataPlugin
|
|
{
|
|
Name = i.Name,
|
|
Type = MetadataPluginType.ImageFetcher
|
|
}));
|
|
}
|
|
|
|
public MetadataOptions GetMetadataOptions(IHasMetadata item)
|
|
{
|
|
var type = item.GetType().Name;
|
|
|
|
return ConfigurationManager.Configuration.MetadataOptions
|
|
.FirstOrDefault(i => string.Equals(i.ItemType, type, StringComparison.OrdinalIgnoreCase)) ??
|
|
new MetadataOptions();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Saves the metadata.
|
|
/// </summary>
|
|
public void SaveMetadata(IHasMetadata item, ItemUpdateType updateType)
|
|
{
|
|
SaveMetadata(item, updateType, _savers);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Saves the metadata.
|
|
/// </summary>
|
|
public void SaveMetadata(IHasMetadata item, ItemUpdateType updateType, IEnumerable<string> savers)
|
|
{
|
|
SaveMetadata(item, updateType, _savers.Where(i => savers.Contains(i.Name, StringComparer.OrdinalIgnoreCase)));
|
|
}
|
|
|
|
/// <summary>
|
|
/// Saves the metadata.
|
|
/// </summary>
|
|
/// <param name="item">The item.</param>
|
|
/// <param name="updateType">Type of the update.</param>
|
|
/// <param name="savers">The savers.</param>
|
|
/// <returns>Task.</returns>
|
|
private void SaveMetadata(IHasMetadata item, ItemUpdateType updateType, IEnumerable<IMetadataSaver> savers)
|
|
{
|
|
foreach (var saver in savers.Where(i => IsSaverEnabledForItem(i, item, updateType, false)))
|
|
{
|
|
_logger.Debug("Saving {0} to {1}.", item.Path ?? item.Name, saver.Name);
|
|
|
|
var fileSaver = saver as IMetadataFileSaver;
|
|
|
|
if (fileSaver != null)
|
|
{
|
|
string path = null;
|
|
|
|
try
|
|
{
|
|
path = fileSaver.GetSavePath(item);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error in {0} GetSavePath", ex, saver.Name);
|
|
continue;
|
|
}
|
|
|
|
try
|
|
{
|
|
_libraryMonitor.ReportFileSystemChangeBeginning(path);
|
|
saver.Save(item, CancellationToken.None);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error in metadata saver", ex);
|
|
}
|
|
finally
|
|
{
|
|
_libraryMonitor.ReportFileSystemChangeComplete(path, false);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
try
|
|
{
|
|
saver.Save(item, CancellationToken.None);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error in metadata saver", ex);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Determines whether [is saver enabled for item] [the specified saver].
|
|
/// </summary>
|
|
/// <param name="saver">The saver.</param>
|
|
/// <param name="item">The item.</param>
|
|
/// <param name="updateType">Type of the update.</param>
|
|
/// <param name="includeDisabled">if set to <c>true</c> [include disabled].</param>
|
|
/// <returns><c>true</c> if [is saver enabled for item] [the specified saver]; otherwise, <c>false</c>.</returns>
|
|
private bool IsSaverEnabledForItem(IMetadataSaver saver, IHasMetadata item, ItemUpdateType updateType, bool includeDisabled)
|
|
{
|
|
var options = GetMetadataOptions(item);
|
|
|
|
try
|
|
{
|
|
var isEnabledFor = saver.IsEnabledFor(item, updateType);
|
|
|
|
if (!includeDisabled)
|
|
{
|
|
if (options.DisabledMetadataSavers.Contains(saver.Name, StringComparer.OrdinalIgnoreCase))
|
|
{
|
|
return false;
|
|
}
|
|
|
|
if (!item.IsSaveLocalMetadataEnabled())
|
|
{
|
|
if (updateType >= ItemUpdateType.MetadataEdit)
|
|
{
|
|
var fileSaver = saver as IMetadataFileSaver;
|
|
|
|
// Manual edit occurred
|
|
// Even if save local is off, save locally anyway if the metadata file already exists
|
|
if (fileSaver == null || !isEnabledFor || !_fileSystem.FileExists(fileSaver.GetSavePath(item)))
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// Manual edit did not occur
|
|
// Since local metadata saving is disabled, consider it disabled
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
return isEnabledFor;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error in {0}.IsEnabledFor", ex, saver.Name);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public async Task<IEnumerable<RemoteSearchResult>> GetRemoteSearchResults<TItemType, TLookupType>(RemoteSearchQuery<TLookupType> searchInfo,
|
|
CancellationToken cancellationToken)
|
|
where TItemType : BaseItem, new()
|
|
where TLookupType : ItemLookupInfo
|
|
{
|
|
// Give it a dummy path just so that it looks like a file system item
|
|
var dummy = new TItemType
|
|
{
|
|
Path = Path.Combine(_appPaths.InternalMetadataPath, "dummy"),
|
|
ParentId = Guid.NewGuid()
|
|
};
|
|
|
|
dummy.SetParent(new Folder());
|
|
|
|
var options = GetMetadataOptions(dummy);
|
|
|
|
var providers = GetMetadataProvidersInternal<TItemType>(dummy, options, searchInfo.IncludeDisabledProviders, false, false)
|
|
.OfType<IRemoteSearchProvider<TLookupType>>();
|
|
|
|
if (!string.IsNullOrEmpty(searchInfo.SearchProviderName))
|
|
{
|
|
providers = providers.Where(i => string.Equals(i.Name, searchInfo.SearchProviderName, StringComparison.OrdinalIgnoreCase));
|
|
}
|
|
|
|
if (string.IsNullOrWhiteSpace(searchInfo.SearchInfo.MetadataLanguage))
|
|
{
|
|
searchInfo.SearchInfo.MetadataLanguage = ConfigurationManager.Configuration.PreferredMetadataLanguage;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(searchInfo.SearchInfo.MetadataCountryCode))
|
|
{
|
|
searchInfo.SearchInfo.MetadataCountryCode = ConfigurationManager.Configuration.MetadataCountryCode;
|
|
}
|
|
|
|
var resultList = new List<RemoteSearchResult>();
|
|
|
|
foreach (var provider in providers)
|
|
{
|
|
try
|
|
{
|
|
var results = await GetSearchResults(provider, searchInfo.SearchInfo, cancellationToken).ConfigureAwait(false);
|
|
|
|
foreach (var result in results)
|
|
{
|
|
var existingMatch = resultList.FirstOrDefault(i => i.ProviderIds.Any(p => string.Equals(result.GetProviderId(p.Key), p.Value, StringComparison.OrdinalIgnoreCase)));
|
|
|
|
if (existingMatch == null)
|
|
{
|
|
resultList.Add(result);
|
|
}
|
|
else
|
|
{
|
|
foreach (var providerId in result.ProviderIds)
|
|
{
|
|
if (!existingMatch.ProviderIds.ContainsKey(providerId.Key))
|
|
{
|
|
existingMatch.ProviderIds.Add(providerId.Key, providerId.Value);
|
|
}
|
|
}
|
|
|
|
if (string.IsNullOrWhiteSpace(existingMatch.ImageUrl))
|
|
{
|
|
existingMatch.ImageUrl = result.ImageUrl;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
// Logged at lower levels
|
|
}
|
|
}
|
|
|
|
//_logger.Debug("Returning search results {0}", _json.SerializeToString(resultList));
|
|
|
|
return resultList;
|
|
}
|
|
|
|
private async Task<IEnumerable<RemoteSearchResult>> GetSearchResults<TLookupType>(IRemoteSearchProvider<TLookupType> provider, TLookupType searchInfo,
|
|
CancellationToken cancellationToken)
|
|
where TLookupType : ItemLookupInfo
|
|
{
|
|
var results = await provider.GetSearchResults(searchInfo, cancellationToken).ConfigureAwait(false);
|
|
|
|
var list = results.ToList();
|
|
|
|
foreach (var item in list)
|
|
{
|
|
item.SearchProviderName = provider.Name;
|
|
}
|
|
|
|
return list;
|
|
}
|
|
|
|
public Task<HttpResponseInfo> GetSearchImage(string providerName, string url, CancellationToken cancellationToken)
|
|
{
|
|
var provider = _metadataProviders.OfType<IRemoteSearchProvider>().FirstOrDefault(i => string.Equals(i.Name, providerName, StringComparison.OrdinalIgnoreCase));
|
|
|
|
if (provider == null)
|
|
{
|
|
throw new ArgumentException("Search provider not found.");
|
|
}
|
|
|
|
return provider.GetImageResponse(url, cancellationToken);
|
|
}
|
|
|
|
public IEnumerable<IExternalId> GetExternalIds(IHasProviderIds item)
|
|
{
|
|
return _externalIds.Where(i =>
|
|
{
|
|
try
|
|
{
|
|
return i.Supports(item);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error in {0}.Suports", ex, i.GetType().Name);
|
|
return false;
|
|
}
|
|
});
|
|
}
|
|
|
|
public IEnumerable<ExternalUrl> GetExternalUrls(BaseItem item)
|
|
{
|
|
return GetExternalIds(item)
|
|
.Select(i =>
|
|
{
|
|
if (string.IsNullOrEmpty(i.UrlFormatString))
|
|
{
|
|
return null;
|
|
}
|
|
|
|
var value = item.GetProviderId(i.Key);
|
|
|
|
if (string.IsNullOrEmpty(value))
|
|
{
|
|
return null;
|
|
}
|
|
|
|
return new ExternalUrl
|
|
{
|
|
Name = i.Name,
|
|
Url = string.Format(i.UrlFormatString, value)
|
|
};
|
|
|
|
}).Where(i => i != null).Concat(item.GetRelatedUrls());
|
|
}
|
|
|
|
public IEnumerable<ExternalIdInfo> GetExternalIdInfos(IHasProviderIds item)
|
|
{
|
|
return GetExternalIds(item)
|
|
.Select(i => new ExternalIdInfo
|
|
{
|
|
Name = i.Name,
|
|
Key = i.Key,
|
|
UrlFormatString = i.UrlFormatString
|
|
|
|
});
|
|
}
|
|
|
|
private Dictionary<Guid, double> _activeRefreshes = new Dictionary<Guid, double>();
|
|
|
|
public Dictionary<Guid, Guid> GetRefreshQueue()
|
|
{
|
|
lock (_refreshQueueLock)
|
|
{
|
|
var dict = new Dictionary<Guid, Guid>();
|
|
|
|
foreach (var item in _refreshQueue)
|
|
{
|
|
dict[item.Item1] = item.Item1;
|
|
}
|
|
return dict;
|
|
}
|
|
}
|
|
|
|
public void OnRefreshStart(BaseItem item)
|
|
{
|
|
//_logger.Info("OnRefreshStart {0}", item.Id.ToString("N"));
|
|
var id = item.Id;
|
|
|
|
lock (_activeRefreshes)
|
|
{
|
|
_activeRefreshes[id] = 0;
|
|
}
|
|
|
|
if (RefreshStarted != null)
|
|
{
|
|
RefreshStarted(this, new GenericEventArgs<BaseItem>(item));
|
|
}
|
|
}
|
|
|
|
public void OnRefreshComplete(BaseItem item)
|
|
{
|
|
//_logger.Info("OnRefreshComplete {0}", item.Id.ToString("N"));
|
|
lock (_activeRefreshes)
|
|
{
|
|
_activeRefreshes.Remove(item.Id);
|
|
}
|
|
|
|
if (RefreshCompleted != null)
|
|
{
|
|
RefreshCompleted(this, new GenericEventArgs<BaseItem>(item));
|
|
}
|
|
}
|
|
|
|
public double? GetRefreshProgress(Guid id)
|
|
{
|
|
lock (_activeRefreshes)
|
|
{
|
|
double value;
|
|
if (_activeRefreshes.TryGetValue(id, out value))
|
|
{
|
|
return value;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|
|
|
|
public void OnRefreshProgress(BaseItem item, double progress)
|
|
{
|
|
//_logger.Info("OnRefreshProgress {0} {1}", item.Id.ToString("N"), progress);
|
|
var id = item.Id;
|
|
|
|
lock (_activeRefreshes)
|
|
{
|
|
if (_activeRefreshes.ContainsKey(id))
|
|
{
|
|
_activeRefreshes[id] = progress;
|
|
|
|
if (RefreshProgress != null)
|
|
{
|
|
RefreshProgress(this, new GenericEventArgs<Tuple<BaseItem, double>>(new Tuple<BaseItem, double>(item, progress)));
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// TODO: Need to hunt down the conditions for this happening
|
|
//throw new Exception(string.Format("Refresh for item {0} {1} is not in progress", item.GetType().Name, item.Id.ToString("N")));
|
|
}
|
|
}
|
|
}
|
|
|
|
private readonly SimplePriorityQueue<Tuple<Guid, MetadataRefreshOptions>> _refreshQueue =
|
|
new SimplePriorityQueue<Tuple<Guid, MetadataRefreshOptions>>();
|
|
|
|
private readonly object _refreshQueueLock = new object();
|
|
private bool _isProcessingRefreshQueue;
|
|
|
|
public void QueueRefresh(Guid id, MetadataRefreshOptions options, RefreshPriority priority)
|
|
{
|
|
if (_disposed)
|
|
{
|
|
return;
|
|
}
|
|
|
|
_refreshQueue.Enqueue(new Tuple<Guid, MetadataRefreshOptions>(id, options), (int)priority);
|
|
|
|
lock (_refreshQueueLock)
|
|
{
|
|
if (!_isProcessingRefreshQueue)
|
|
{
|
|
_isProcessingRefreshQueue = true;
|
|
Task.Run(StartProcessingRefreshQueue);
|
|
}
|
|
}
|
|
}
|
|
|
|
private async Task StartProcessingRefreshQueue()
|
|
{
|
|
Tuple<Guid, MetadataRefreshOptions> refreshItem;
|
|
var libraryManager = _libraryManagerFactory();
|
|
|
|
if (_disposed)
|
|
{
|
|
return;
|
|
}
|
|
|
|
var cancellationToken = _disposeCancellationTokenSource.Token;
|
|
|
|
while (_refreshQueue.TryDequeue(out refreshItem))
|
|
{
|
|
if (_disposed)
|
|
{
|
|
return;
|
|
}
|
|
|
|
try
|
|
{
|
|
var item = libraryManager.GetItemById(refreshItem.Item1);
|
|
if (item != null)
|
|
{
|
|
// Try to throttle this a little bit.
|
|
await Task.Delay(100).ConfigureAwait(false);
|
|
|
|
if (refreshItem.Item2.ValidateChildren)
|
|
{
|
|
var folder = item as Folder;
|
|
if (folder != null)
|
|
{
|
|
await folder.ValidateChildren(new SimpleProgress<double>(), cancellationToken).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
var artist = item as MusicArtist;
|
|
var task = artist == null
|
|
? RefreshItem(item, refreshItem.Item2, cancellationToken)
|
|
: RefreshArtist(artist, refreshItem.Item2, cancellationToken);
|
|
|
|
await task.ConfigureAwait(false);
|
|
}
|
|
}
|
|
catch (OperationCanceledException)
|
|
{
|
|
break;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error refreshing item", ex);
|
|
}
|
|
}
|
|
|
|
lock (_refreshQueueLock)
|
|
{
|
|
_isProcessingRefreshQueue = false;
|
|
}
|
|
}
|
|
|
|
private async Task RefreshItem(BaseItem item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
|
{
|
|
await item.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
|
|
|
// Collection folders don't validate their children so we'll have to simulate that here
|
|
var collectionFolder = item as CollectionFolder;
|
|
|
|
if (collectionFolder != null)
|
|
{
|
|
await RefreshCollectionFolderChildren(options, collectionFolder, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
else
|
|
{
|
|
var folder = item as Folder;
|
|
|
|
if (folder != null)
|
|
{
|
|
await folder.ValidateChildren(new SimpleProgress<double>(), cancellationToken, options).ConfigureAwait(false);
|
|
}
|
|
}
|
|
}
|
|
|
|
private async Task RefreshCollectionFolderChildren(MetadataRefreshOptions options, CollectionFolder collectionFolder, CancellationToken cancellationToken)
|
|
{
|
|
foreach (var child in collectionFolder.GetPhysicalFolders().ToList())
|
|
{
|
|
await child.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
|
|
|
if (child.IsFolder)
|
|
{
|
|
var folder = (Folder)child;
|
|
|
|
await folder.ValidateChildren(new SimpleProgress<double>(), cancellationToken, options, true).ConfigureAwait(false);
|
|
}
|
|
}
|
|
}
|
|
|
|
private async Task RefreshArtist(MusicArtist item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
|
{
|
|
var albums = _libraryManagerFactory()
|
|
.GetItemList(new InternalItemsQuery
|
|
{
|
|
IncludeItemTypes = new[] { typeof(MusicAlbum).Name },
|
|
ArtistIds = new[] { item.Id.ToString("N") },
|
|
DtoOptions = new DtoOptions(false)
|
|
{
|
|
EnableImages = false
|
|
}
|
|
})
|
|
.OfType<MusicAlbum>()
|
|
.ToList();
|
|
|
|
var musicArtists = albums
|
|
.Select(i => i.MusicArtist)
|
|
.Where(i => i != null)
|
|
.ToList();
|
|
|
|
var musicArtistRefreshTasks = musicArtists.Select(i => i.ValidateChildren(new SimpleProgress<double>(), cancellationToken, options, true));
|
|
|
|
await Task.WhenAll(musicArtistRefreshTasks).ConfigureAwait(false);
|
|
|
|
try
|
|
{
|
|
await item.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.ErrorException("Error refreshing library", ex);
|
|
}
|
|
}
|
|
|
|
public Task RefreshFullItem(IHasMetadata item, MetadataRefreshOptions options,
|
|
CancellationToken cancellationToken)
|
|
{
|
|
return RefreshItem((BaseItem)item, options, cancellationToken);
|
|
}
|
|
|
|
private bool _disposed;
|
|
public void Dispose()
|
|
{
|
|
_disposed = true;
|
|
|
|
if (!_disposeCancellationTokenSource.IsCancellationRequested)
|
|
{
|
|
_disposeCancellationTokenSource.Cancel();
|
|
}
|
|
GC.SuppressFinalize(this);
|
|
}
|
|
}
|
|
} |