jellyfin-server/MediaBrowser.Providers/Manager/MetadataService.cs

717 lines
28 KiB
C#
Raw Normal View History

2014-09-28 15:27:26 +00:00
using MediaBrowser.Common.Extensions;
2014-02-02 13:36:31 +00:00
using MediaBrowser.Common.IO;
2014-01-29 05:17:58 +00:00
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.Entities;
using MediaBrowser.Model.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
2015-10-04 04:23:11 +00:00
using CommonIO;
2015-10-14 22:35:32 +00:00
using MediaBrowser.Controller.Entities.Audio;
2015-10-14 05:02:30 +00:00
using MediaBrowser.Controller.Entities.Movies;
namespace MediaBrowser.Providers.Manager
{
2014-01-31 19:55:21 +00:00
public abstract class MetadataService<TItemType, TIdType> : IMetadataService
2014-02-07 03:10:13 +00:00
where TItemType : IHasMetadata, IHasLookupInfo<TIdType>, new()
where TIdType : ItemLookupInfo, new()
{
protected readonly IServerConfigurationManager ServerConfigurationManager;
protected readonly ILogger Logger;
protected readonly IProviderManager ProviderManager;
2014-02-02 13:36:31 +00:00
protected readonly IProviderRepository ProviderRepo;
protected readonly IFileSystem FileSystem;
protected readonly IUserDataManager UserDataManager;
2015-06-29 01:10:45 +00:00
protected readonly ILibraryManager LibraryManager;
2015-06-29 01:10:45 +00:00
protected MetadataService(IServerConfigurationManager serverConfigurationManager, ILogger logger, IProviderManager providerManager, IProviderRepository providerRepo, IFileSystem fileSystem, IUserDataManager userDataManager, ILibraryManager libraryManager)
{
ServerConfigurationManager = serverConfigurationManager;
Logger = logger;
ProviderManager = providerManager;
2014-02-02 13:36:31 +00:00
ProviderRepo = providerRepo;
FileSystem = fileSystem;
UserDataManager = userDataManager;
2015-06-29 01:10:45 +00:00
LibraryManager = libraryManager;
}
/// <summary>
/// Saves the provider result.
/// </summary>
2014-02-08 20:02:35 +00:00
/// <param name="item">The item.</param>
/// <param name="result">The result.</param>
2014-09-11 01:57:11 +00:00
/// <param name="directoryService">The directory service.</param>
/// <returns>Task.</returns>
2014-09-11 01:57:11 +00:00
protected Task SaveProviderResult(TItemType item, MetadataStatus result, IDirectoryService directoryService)
{
2014-02-08 20:02:35 +00:00
result.ItemId = item.Id;
2014-09-11 01:57:11 +00:00
//var locationType = item.LocationType;
//if (locationType == LocationType.FileSystem || locationType == LocationType.Offline)
//{
// if (!string.IsNullOrWhiteSpace(item.Path))
// {
// var file = directoryService.GetFile(item.Path);
// if ((file.Attributes & FileAttributes.Directory) != FileAttributes.Directory && file.Exists)
// {
// result.ItemDateModified = FileSystem.GetLastWriteTimeUtc(file);
// }
// }
//}
result.ItemDateModified = item.DateModified;
2014-02-02 13:36:31 +00:00
return ProviderRepo.SaveMetadataStatus(result, CancellationToken.None);
}
/// <summary>
/// Gets the last result.
/// </summary>
2014-03-16 16:15:10 +00:00
/// <param name="item">The item.</param>
/// <returns>ProviderResult.</returns>
2014-03-16 16:15:10 +00:00
protected MetadataStatus GetLastResult(IHasMetadata item)
{
2015-10-14 05:02:30 +00:00
if (GetLastRefreshDate(item) == default(DateTime))
2014-03-16 16:15:10 +00:00
{
return new MetadataStatus { ItemId = item.Id };
}
return ProviderRepo.GetMetadataStatus(item.Id) ?? new MetadataStatus { ItemId = item.Id };
}
public async Task<ItemUpdateType> RefreshMetadata(IHasMetadata item, MetadataRefreshOptions refreshOptions, CancellationToken cancellationToken)
{
var itemOfType = (TItemType)item;
var config = ProviderManager.GetMetadataOptions(item);
2014-02-02 13:36:31 +00:00
2014-02-10 18:39:41 +00:00
var updateType = ItemUpdateType.None;
2014-03-16 16:15:10 +00:00
var refreshResult = GetLastResult(item);
2014-02-02 13:36:31 +00:00
var itemImageProvider = new ItemImageProvider(Logger, ProviderManager, ServerConfigurationManager, FileSystem);
var localImagesFailed = false;
2014-01-31 19:55:21 +00:00
var allImageProviders = ((ProviderManager)ProviderManager).GetImageProviders(item).ToList();
// Start by validating images
try
{
// Always validate images and check for new locally stored ones.
2014-02-08 22:38:02 +00:00
if (itemImageProvider.ValidateImages(item, allImageProviders.OfType<ILocalImageProvider>(), refreshOptions.DirectoryService))
{
updateType = updateType | ItemUpdateType.ImageUpdate;
}
}
catch (Exception ex)
{
localImagesFailed = true;
2015-01-27 06:50:40 +00:00
Logger.ErrorException("Error validating images for {0}", ex, item.Path ?? item.Name ?? "Unknown name");
}
2015-06-29 01:10:45 +00:00
var metadataResult = new MetadataResult<TItemType>
{
Item = itemOfType
};
// Next run metadata providers
2014-02-02 13:36:31 +00:00
if (refreshOptions.MetadataRefreshMode != MetadataRefreshMode.None)
{
2014-09-11 01:57:11 +00:00
var providers = GetProviders(item, refreshResult, refreshOptions)
2014-03-24 17:54:45 +00:00
.ToList();
if (providers.Count > 0 || !refreshResult.DateLastMetadataRefresh.HasValue)
{
2014-02-13 05:11:54 +00:00
if (item.BeforeMetadataRefresh())
{
updateType = updateType | ItemUpdateType.MetadataImport;
}
}
if (providers.Count > 0)
{
2015-09-19 21:25:19 +00:00
var id = itemOfType.GetLookupInfo();
2015-10-23 16:04:33 +00:00
2015-11-30 18:16:56 +00:00
//await FindIdentities(id, cancellationToken).ConfigureAwait(false);
2015-06-29 01:10:45 +00:00
var result = await RefreshWithProviders(metadataResult, id, refreshOptions, providers, itemImageProvider, cancellationToken).ConfigureAwait(false);
updateType = updateType | result.UpdateType;
2015-09-10 18:28:22 +00:00
if (result.Failures == 0)
{
refreshResult.SetDateLastMetadataRefresh(DateTime.UtcNow);
}
else
{
refreshResult.SetDateLastMetadataRefresh(null);
}
}
}
// Next run remote image providers, but only if local image providers didn't throw an exception
2014-02-02 13:36:31 +00:00
if (!localImagesFailed && refreshOptions.ImageRefreshMode != ImageRefreshMode.ValidationOnly)
{
2014-09-11 01:57:11 +00:00
var providers = GetNonLocalImageProviders(item, allImageProviders, refreshResult, refreshOptions).ToList();
2014-01-29 17:23:38 +00:00
if (providers.Count > 0)
{
2014-02-02 13:36:31 +00:00
var result = await itemImageProvider.RefreshImages(itemOfType, providers, refreshOptions, config, cancellationToken).ConfigureAwait(false);
2014-01-29 05:17:58 +00:00
updateType = updateType | result.UpdateType;
2015-09-10 18:28:22 +00:00
if (result.Failures == 0)
{
refreshResult.SetDateLastImagesRefresh(DateTime.UtcNow);
}
else
{
refreshResult.SetDateLastImagesRefresh(null);
}
}
}
2015-10-14 05:02:30 +00:00
var isFirstRefresh = GetLastRefreshDate(item) == default(DateTime);
var beforeSaveResult = await BeforeSave(itemOfType, isFirstRefresh || refreshOptions.ReplaceAllMetadata || refreshOptions.MetadataRefreshMode == MetadataRefreshMode.FullRefresh, updateType).ConfigureAwait(false);
updateType = updateType | beforeSaveResult;
2014-02-11 21:41:01 +00:00
// Save if changes were made, or it's never been saved before
2015-10-14 05:02:30 +00:00
if (refreshOptions.ForceSave || updateType > ItemUpdateType.None || isFirstRefresh || refreshOptions.ReplaceAllMetadata)
{
2015-01-17 18:15:09 +00:00
// If any of these properties are set then make sure the updateType is not None, just to force everything to save
if (refreshOptions.ForceSave || refreshOptions.ReplaceAllMetadata)
2014-09-13 14:10:30 +00:00
{
updateType = updateType | ItemUpdateType.MetadataDownload;
}
2015-10-14 05:02:30 +00:00
if (refreshOptions.MetadataRefreshMode >= MetadataRefreshMode.Default && refreshOptions.ImageRefreshMode >= ImageRefreshMode.Default)
{
item.DateLastRefreshed = DateTime.UtcNow;
}
// Save to database
2015-06-29 01:10:45 +00:00
await SaveItem(metadataResult, updateType, cancellationToken).ConfigureAwait(false);
}
2015-01-17 18:15:09 +00:00
if (updateType > ItemUpdateType.None || refreshResult.IsDirty)
{
2014-09-11 01:57:11 +00:00
await SaveProviderResult(itemOfType, refreshResult, refreshOptions.DirectoryService).ConfigureAwait(false);
}
2015-01-27 06:50:40 +00:00
2015-01-28 21:29:02 +00:00
await AfterMetadataRefresh(itemOfType, refreshOptions, cancellationToken).ConfigureAwait(false);
return updateType;
2015-01-28 21:29:02 +00:00
}
2015-10-23 16:04:33 +00:00
private async Task FindIdentities(TIdType id, CancellationToken cancellationToken)
{
try
{
await ItemIdentifier<TIdType>.FindIdentities(id, ProviderManager, cancellationToken).ConfigureAwait(false);
}
catch (Exception ex)
{
Logger.ErrorException("Error in FindIdentities", ex);
}
}
2015-10-14 05:02:30 +00:00
private DateTime GetLastRefreshDate(IHasMetadata item)
{
2015-12-03 17:03:47 +00:00
if (EnableDateLastRefreshed(item))
2015-10-14 05:02:30 +00:00
{
return item.DateLastRefreshed;
}
2015-12-03 17:03:47 +00:00
return item.DateLastSaved;
}
private bool EnableDateLastRefreshed(IHasMetadata item)
{
2015-10-14 05:02:30 +00:00
if (ServerConfigurationManager.Configuration.EnableDateLastRefresh)
{
2015-12-03 17:03:47 +00:00
return true;
}
if (item.DateLastRefreshed != default(DateTime))
{
return true;
2015-10-14 05:02:30 +00:00
}
2015-10-14 22:35:32 +00:00
if (item is BoxSet || (item is IItemByName && !(item is MusicArtist)))
2015-10-14 05:02:30 +00:00
{
2015-12-03 17:03:47 +00:00
return true;
2015-10-14 05:02:30 +00:00
}
2015-12-03 17:03:47 +00:00
return false;
2015-10-14 05:02:30 +00:00
}
2015-07-24 02:48:10 +00:00
protected async Task SaveItem(MetadataResult<TItemType> result, ItemUpdateType reason, CancellationToken cancellationToken)
{
if (result.Item.SupportsPeople && result.People != null)
{
await LibraryManager.UpdatePeople(result.Item as BaseItem, result.People.ToList());
}
await result.Item.UpdateToRepository(reason, cancellationToken).ConfigureAwait(false);
}
2015-01-28 21:29:02 +00:00
private readonly Task _cachedTask = Task.FromResult(true);
protected virtual Task AfterMetadataRefresh(TItemType item, MetadataRefreshOptions refreshOptions, CancellationToken cancellationToken)
{
item.AfterMetadataRefresh();
return _cachedTask;
}
2015-10-14 05:02:30 +00:00
2015-01-17 18:15:09 +00:00
private readonly Task<ItemUpdateType> _cachedResult = Task.FromResult(ItemUpdateType.None);
2014-02-03 05:35:43 +00:00
/// <summary>
/// Befores the save.
2014-02-03 05:35:43 +00:00
/// </summary>
/// <param name="item">The item.</param>
2015-01-17 18:15:09 +00:00
/// <param name="isFullRefresh">if set to <c>true</c> [is full refresh].</param>
/// <param name="currentUpdateType">Type of the current update.</param>
2014-02-03 05:35:43 +00:00
/// <returns>ItemUpdateType.</returns>
2015-01-17 18:15:09 +00:00
protected virtual Task<ItemUpdateType> BeforeSave(TItemType item, bool isFullRefresh, ItemUpdateType currentUpdateType)
2014-02-03 05:35:43 +00:00
{
2015-01-17 18:15:09 +00:00
return _cachedResult;
2014-02-03 05:35:43 +00:00
}
/// <summary>
/// Gets the providers.
/// </summary>
/// <param name="item">The item.</param>
2014-09-11 01:57:11 +00:00
/// <param name="status">The status.</param>
/// <param name="options">The options.</param>
/// <returns>IEnumerable{`0}.</returns>
2014-09-11 01:57:11 +00:00
protected IEnumerable<IMetadataProvider> GetProviders(IHasMetadata item, MetadataStatus status, MetadataRefreshOptions options)
{
// Get providers to refresh
2014-02-01 06:18:16 +00:00
var providers = ((ProviderManager)ProviderManager).GetMetadataProviders<TItemType>(item).ToList();
// Run all if either of these flags are true
2014-09-11 01:57:11 +00:00
var runAllProviders = options.ReplaceAllMetadata || options.MetadataRefreshMode == MetadataRefreshMode.FullRefresh || !status.DateLastMetadataRefresh.HasValue;
if (!runAllProviders)
{
// Avoid implicitly captured closure
var currentItem = item;
2014-09-11 01:57:11 +00:00
var providersWithChanges = providers
.Where(i =>
{
var hasChangeMonitor = i as IHasChangeMonitor;
if (hasChangeMonitor != null)
{
return HasChanged(item, hasChangeMonitor, currentItem.DateLastSaved, options.DirectoryService);
}
var hasFileChangeMonitor = i as IHasItemChangeMonitor;
if (hasFileChangeMonitor != null)
{
return HasChanged(item, hasFileChangeMonitor, status, options.DirectoryService);
}
return false;
})
.ToList();
2014-02-10 18:39:41 +00:00
if (providersWithChanges.Count == 0)
{
2014-02-10 18:39:41 +00:00
providers = new List<IMetadataProvider<TItemType>>();
}
else
{
providers = providers.Where(i =>
{
// If any provider reports a change, always run local ones as well
if (i is ILocalMetadataProvider)
{
return true;
}
var anyRemoteProvidersChanged = providersWithChanges.OfType<IRemoteMetadataProvider>()
.Any();
// If any remote providers changed, run them all so that priorities can be honored
if (i is IRemoteMetadataProvider)
{
return anyRemoteProvidersChanged;
}
// Run custom providers if they report a change or any remote providers change
return anyRemoteProvidersChanged || providersWithChanges.Contains(i);
}).ToList();
}
}
return providers;
}
2014-09-11 01:57:11 +00:00
protected virtual IEnumerable<IImageProvider> GetNonLocalImageProviders(IHasMetadata item, IEnumerable<IImageProvider> allImageProviders, MetadataStatus status, ImageRefreshOptions options)
2014-01-29 17:23:38 +00:00
{
// Get providers to refresh
2014-01-31 19:55:21 +00:00
var providers = allImageProviders.Where(i => !(i is ILocalImageProvider)).ToList();
2014-01-29 17:23:38 +00:00
// Run all if either of these flags are true
2014-09-11 01:57:11 +00:00
var runAllProviders = options.ImageRefreshMode == ImageRefreshMode.FullRefresh || !status.DateLastImagesRefresh.HasValue;
2014-01-29 17:23:38 +00:00
if (!runAllProviders)
{
2014-09-11 01:57:11 +00:00
providers = providers
.Where(i =>
{
var hasChangeMonitor = i as IHasChangeMonitor;
if (hasChangeMonitor != null)
{
return HasChanged(item, hasChangeMonitor, status.DateLastImagesRefresh.Value, options.DirectoryService);
}
var hasFileChangeMonitor = i as IHasItemChangeMonitor;
if (hasFileChangeMonitor != null)
{
return HasChanged(item, hasFileChangeMonitor, status, options.DirectoryService);
}
2014-09-11 01:57:11 +00:00
return false;
})
2014-01-29 17:23:38 +00:00
.ToList();
}
return providers;
}
public bool CanRefresh(IHasMetadata item)
{
return item is TItemType;
}
2015-06-29 01:10:45 +00:00
protected virtual async Task<RefreshResult> RefreshWithProviders(MetadataResult<TItemType> metadata,
2015-01-28 21:29:02 +00:00
TIdType id,
MetadataRefreshOptions options,
List<IMetadataProvider> providers,
ItemImageProvider imageService,
2014-10-25 18:32:58 +00:00
CancellationToken cancellationToken)
{
2014-01-29 05:17:58 +00:00
var refreshResult = new RefreshResult
{
2014-02-10 18:39:41 +00:00
UpdateType = ItemUpdateType.None,
2014-01-29 05:17:58 +00:00
Providers = providers.Select(i => i.GetType().FullName.GetMD5()).ToList()
};
2015-06-29 01:10:45 +00:00
var item = metadata.Item;
var customProviders = providers.OfType<ICustomMetadataProvider<TItemType>>().ToList();
2014-09-28 20:49:43 +00:00
var logName = item.LocationType == LocationType.Remote ? item.Name ?? item.Path : item.Path ?? item.Name;
foreach (var provider in customProviders.Where(i => i is IPreRefreshProvider))
{
2014-09-28 20:49:43 +00:00
await RunCustomProvider(provider, item, logName, options, refreshResult, cancellationToken).ConfigureAwait(false);
}
2015-06-29 01:10:45 +00:00
var temp = new MetadataResult<TItemType>
{
Item = CreateNew()
};
temp.Item.Path = item.Path;
2015-06-29 01:10:45 +00:00
var userDataList = new List<UserItemData>();
// If replacing all metadata, run internet providers first
if (options.ReplaceAllMetadata)
{
2015-04-24 20:06:37 +00:00
var remoteResult = await ExecuteRemoteProviders(temp, logName, id, providers.OfType<IRemoteMetadataProvider<TItemType, TIdType>>(), cancellationToken)
.ConfigureAwait(false);
2014-10-28 23:17:55 +00:00
refreshResult.UpdateType = refreshResult.UpdateType | remoteResult.UpdateType;
refreshResult.ErrorMessage = remoteResult.ErrorMessage;
2015-10-05 03:24:24 +00:00
refreshResult.Failures += remoteResult.Failures;
}
var hasLocalMetadata = false;
2015-04-24 20:06:37 +00:00
foreach (var provider in providers.OfType<ILocalMetadataProvider<TItemType>>().ToList())
{
var providerName = provider.GetType().Name;
2014-09-28 20:49:43 +00:00
Logger.Debug("Running {0} for {1}", providerName, logName);
2015-05-15 15:46:20 +00:00
var itemInfo = new ItemInfo(item);
try
{
2014-10-25 18:32:58 +00:00
var localItem = await provider.GetMetadata(itemInfo, options.DirectoryService, cancellationToken).ConfigureAwait(false);
if (localItem.HasMetadata)
{
2014-02-09 04:52:52 +00:00
if (imageService.MergeImages(item, localItem.Images))
{
2014-02-22 21:05:00 +00:00
refreshResult.UpdateType = refreshResult.UpdateType | ItemUpdateType.ImageUpdate;
2014-02-09 04:52:52 +00:00
}
2015-08-02 17:31:08 +00:00
if (localItem.UserDataList != null)
{
userDataList.AddRange(localItem.UserDataList);
}
2015-06-29 01:10:45 +00:00
MergeData(localItem, temp, new List<MetadataFields>(), !options.ReplaceAllMetadata, true);
refreshResult.UpdateType = refreshResult.UpdateType | ItemUpdateType.MetadataImport;
// Only one local provider allowed per item
2015-02-25 18:11:49 +00:00
if (IsFullLocalMetadata(localItem.Item))
{
hasLocalMetadata = true;
}
break;
}
2014-09-28 20:49:43 +00:00
Logger.Debug("{0} returned no metadata for {1}", providerName, logName);
}
catch (OperationCanceledException)
{
throw;
}
catch (Exception ex)
{
2015-10-05 03:24:24 +00:00
refreshResult.Failures++;
Logger.ErrorException("Error in {0}", ex, provider.Name);
// If a local provider fails, consider that a failure
refreshResult.ErrorMessage = ex.Message;
if (options.MetadataRefreshMode != MetadataRefreshMode.FullRefresh)
{
// If the local provider fails don't continue with remote providers because the user's saved metadata could be lost
return refreshResult;
}
}
}
2014-02-08 20:02:35 +00:00
// Local metadata is king - if any is found don't run remote providers
2014-02-15 16:36:09 +00:00
if (!options.ReplaceAllMetadata && (!hasLocalMetadata || options.MetadataRefreshMode == MetadataRefreshMode.FullRefresh))
{
2015-04-24 20:06:37 +00:00
var remoteResult = await ExecuteRemoteProviders(temp, logName, id, providers.OfType<IRemoteMetadataProvider<TItemType, TIdType>>(), cancellationToken)
.ConfigureAwait(false);
refreshResult.UpdateType = refreshResult.UpdateType | remoteResult.UpdateType;
2015-10-05 03:24:24 +00:00
refreshResult.ErrorMessage = remoteResult.ErrorMessage;
refreshResult.Failures += remoteResult.Failures;
}
2015-03-22 23:24:35 +00:00
if (providers.Any(i => !(i is ICustomMetadataProvider)))
2014-10-28 23:17:55 +00:00
{
2015-03-22 23:24:35 +00:00
if (refreshResult.UpdateType > ItemUpdateType.None)
{
2015-04-24 20:06:37 +00:00
// If no local metadata, take data from item itself
if (!hasLocalMetadata)
{
// TODO: If the new metadata from above has some blank data, this can cause old data to get filled into those empty fields
2015-06-29 01:10:45 +00:00
MergeData(metadata, temp, new List<MetadataFields>(), false, true);
2015-04-24 20:06:37 +00:00
}
2015-06-29 01:10:45 +00:00
MergeData(temp, metadata, item.LockedFields, true, true);
2015-03-22 23:24:35 +00:00
}
2014-02-01 06:18:16 +00:00
}
2015-09-29 17:35:23 +00:00
//var isUnidentified = failedProviderCount > 0 && successfulProviderCount == 0;
foreach (var provider in customProviders.Where(i => !(i is IPreRefreshProvider)))
2014-02-02 13:36:31 +00:00
{
2014-09-28 20:49:43 +00:00
await RunCustomProvider(provider, item, logName, options, refreshResult, cancellationToken).ConfigureAwait(false);
2014-02-02 13:36:31 +00:00
}
await ImportUserData(item, userDataList, cancellationToken).ConfigureAwait(false);
return refreshResult;
}
2015-02-25 18:11:49 +00:00
protected virtual bool IsFullLocalMetadata(TItemType item)
{
2015-04-19 00:05:36 +00:00
if (string.IsNullOrWhiteSpace(item.Name))
{
return false;
}
2015-09-10 18:28:22 +00:00
2015-02-25 18:11:49 +00:00
return true;
}
private async Task ImportUserData(TItemType item, List<UserItemData> userDataList, CancellationToken cancellationToken)
{
var hasUserData = item as IHasUserData;
if (hasUserData != null)
{
foreach (var userData in userDataList)
{
await UserDataManager.SaveUserData(userData.UserId, hasUserData, userData, UserDataSaveReason.Import, cancellationToken)
.ConfigureAwait(false);
}
}
}
2014-09-28 20:49:43 +00:00
private async Task RunCustomProvider(ICustomMetadataProvider<TItemType> provider, TItemType item, string logName, MetadataRefreshOptions options, RefreshResult refreshResult, CancellationToken cancellationToken)
{
2014-09-28 20:49:43 +00:00
Logger.Debug("Running {0} for {1}", provider.GetType().Name, logName);
try
{
2014-06-09 19:16:14 +00:00
refreshResult.UpdateType = refreshResult.UpdateType | await provider.FetchAsync(item, options, cancellationToken).ConfigureAwait(false);
}
catch (OperationCanceledException)
{
throw;
}
catch (Exception ex)
{
refreshResult.ErrorMessage = ex.Message;
Logger.ErrorException("Error in {0}", ex, provider.Name);
}
}
2014-02-02 13:36:31 +00:00
protected virtual TItemType CreateNew()
{
return new TItemType();
}
2014-01-30 21:23:54 +00:00
2015-06-29 01:10:45 +00:00
private async Task<RefreshResult> ExecuteRemoteProviders(MetadataResult<TItemType> temp, string logName, TIdType id, IEnumerable<IRemoteMetadataProvider<TItemType, TIdType>> providers, CancellationToken cancellationToken)
{
var refreshResult = new RefreshResult();
foreach (var provider in providers)
{
var providerName = provider.GetType().Name;
2014-09-28 20:49:43 +00:00
Logger.Debug("Running {0} for {1}", providerName, logName);
if (id != null)
2014-02-08 20:02:35 +00:00
{
2015-06-29 01:10:45 +00:00
MergeNewData(temp.Item, id);
2014-02-08 20:02:35 +00:00
}
2014-02-07 03:10:13 +00:00
try
{
var result = await provider.GetMetadata(id, cancellationToken).ConfigureAwait(false);
if (result.HasMetadata)
{
2014-09-22 21:56:54 +00:00
NormalizeRemoteResult(result.Item);
2015-06-29 01:10:45 +00:00
MergeData(result, temp, new List<MetadataFields>(), false, false);
refreshResult.UpdateType = refreshResult.UpdateType | ItemUpdateType.MetadataDownload;
}
else
{
refreshResult.Failures++;
2014-09-28 20:49:43 +00:00
Logger.Debug("{0} returned no metadata for {1}", providerName, logName);
}
}
catch (OperationCanceledException)
{
throw;
}
catch (Exception ex)
{
refreshResult.Failures++;
refreshResult.ErrorMessage = ex.Message;
Logger.ErrorException("Error in {0}", ex, provider.Name);
}
}
return refreshResult;
}
2014-09-22 21:56:54 +00:00
private void NormalizeRemoteResult(TItemType item)
{
if (!ServerConfigurationManager.Configuration.FindInternetTrailers)
{
var hasTrailers = item as IHasTrailers;
if (hasTrailers != null)
{
hasTrailers.RemoteTrailers.Clear();
}
}
}
2014-02-08 20:02:35 +00:00
private void MergeNewData(TItemType source, TIdType lookupInfo)
{
// Copy new provider id's that may have been obtained
foreach (var providerId in source.ProviderIds)
{
2014-02-13 05:11:54 +00:00
var key = providerId.Key;
// Don't replace existing Id's.
if (!lookupInfo.ProviderIds.ContainsKey(key))
{
lookupInfo.ProviderIds[key] = providerId.Value;
}
2014-02-08 20:02:35 +00:00
}
}
2015-06-29 01:10:45 +00:00
protected abstract void MergeData(MetadataResult<TItemType> source,
MetadataResult<TItemType> target,
2015-01-28 21:29:02 +00:00
List<MetadataFields> lockedFields,
bool replaceData,
2014-10-28 23:17:55 +00:00
bool mergeMetadataSettings);
public virtual int Order
{
get
{
return 0;
}
}
2014-02-14 04:00:13 +00:00
2014-09-11 01:57:11 +00:00
private bool HasChanged(IHasMetadata item, IHasItemChangeMonitor changeMonitor, MetadataStatus status, IDirectoryService directoryService)
{
try
{
2015-12-03 17:03:47 +00:00
var hasChanged = changeMonitor.HasChanged(item, status, directoryService);
//if (hasChanged)
//{
// Logger.Debug("{0} reports change to {1}", changeMonitor.GetType().Name, item.Path ?? item.Name);
//}
return hasChanged;
2014-09-11 01:57:11 +00:00
}
catch (Exception ex)
{
Logger.ErrorException("Error in {0}.HasChanged", ex, changeMonitor.GetType().Name);
return false;
}
}
2014-02-14 04:00:13 +00:00
private bool HasChanged(IHasMetadata item, IHasChangeMonitor changeMonitor, DateTime date, IDirectoryService directoryService)
{
try
{
2015-12-03 17:03:47 +00:00
var hasChanged = changeMonitor.HasChanged(item, directoryService, date);
//if (hasChanged)
//{
// Logger.Debug("{0} reports change to {1} since {2}", changeMonitor.GetType().Name,
// item.Path ?? item.Name, date);
//}
return hasChanged;
2014-02-14 04:00:13 +00:00
}
catch (Exception ex)
{
Logger.ErrorException("Error in {0}.HasChanged", ex, changeMonitor.GetType().Name);
return false;
}
}
}
public class RefreshResult
{
public ItemUpdateType UpdateType { get; set; }
public string ErrorMessage { get; set; }
2014-01-29 05:17:58 +00:00
public List<Guid> Providers { get; set; }
public int Failures { get; set; }
}
}