ProviderManager.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  1. using MediaBrowser.Common.IO;
  2. using MediaBrowser.Common.Net;
  3. using MediaBrowser.Controller.Configuration;
  4. using MediaBrowser.Controller.Entities;
  5. using MediaBrowser.Controller.Entities.Audio;
  6. using MediaBrowser.Controller.Entities.Movies;
  7. using MediaBrowser.Controller.Entities.TV;
  8. using MediaBrowser.Controller.Library;
  9. using MediaBrowser.Controller.LiveTv;
  10. using MediaBrowser.Controller.Providers;
  11. using MediaBrowser.Model.Configuration;
  12. using MediaBrowser.Model.Entities;
  13. using MediaBrowser.Model.Logging;
  14. using MediaBrowser.Model.Providers;
  15. using System;
  16. using System.Collections.Concurrent;
  17. using System.Collections.Generic;
  18. using System.IO;
  19. using System.Linq;
  20. using System.Threading;
  21. using System.Threading.Tasks;
  22. namespace MediaBrowser.Providers.Manager
  23. {
  24. /// <summary>
  25. /// Class ProviderManager
  26. /// </summary>
  27. public class ProviderManager : IProviderManager
  28. {
  29. /// <summary>
  30. /// The _logger
  31. /// </summary>
  32. private readonly ILogger _logger;
  33. /// <summary>
  34. /// The _HTTP client
  35. /// </summary>
  36. private readonly IHttpClient _httpClient;
  37. /// <summary>
  38. /// The _directory watchers
  39. /// </summary>
  40. private readonly ILibraryMonitor _libraryMonitor;
  41. /// <summary>
  42. /// Gets or sets the configuration manager.
  43. /// </summary>
  44. /// <value>The configuration manager.</value>
  45. private IServerConfigurationManager ConfigurationManager { get; set; }
  46. private IImageProvider[] ImageProviders { get; set; }
  47. private readonly IFileSystem _fileSystem;
  48. private IMetadataService[] _metadataServices = { };
  49. private IItemIdentityProvider[] _identityProviders = { };
  50. private IItemIdentityConverter[] _identityConverters = { };
  51. private IMetadataProvider[] _metadataProviders = { };
  52. private IEnumerable<IMetadataSaver> _savers;
  53. private IImageSaver[] _imageSavers;
  54. private IExternalId[] _externalIds;
  55. /// <summary>
  56. /// Initializes a new instance of the <see cref="ProviderManager" /> class.
  57. /// </summary>
  58. /// <param name="httpClient">The HTTP client.</param>
  59. /// <param name="configurationManager">The configuration manager.</param>
  60. /// <param name="libraryMonitor">The directory watchers.</param>
  61. /// <param name="logManager">The log manager.</param>
  62. /// <param name="fileSystem">The file system.</param>
  63. public ProviderManager(IHttpClient httpClient, IServerConfigurationManager configurationManager, ILibraryMonitor libraryMonitor, ILogManager logManager, IFileSystem fileSystem)
  64. {
  65. _logger = logManager.GetLogger("ProviderManager");
  66. _httpClient = httpClient;
  67. ConfigurationManager = configurationManager;
  68. _libraryMonitor = libraryMonitor;
  69. _fileSystem = fileSystem;
  70. }
  71. /// <summary>
  72. /// Adds the metadata providers.
  73. /// </summary>
  74. /// <param name="imageProviders">The image providers.</param>
  75. /// <param name="metadataServices">The metadata services.</param>
  76. /// <param name="identityProviders">The identity providers.</param>
  77. /// <param name="identityConverters">The identity converters.</param>
  78. /// <param name="metadataProviders">The metadata providers.</param>
  79. /// <param name="metadataSavers">The metadata savers.</param>
  80. /// <param name="imageSavers">The image savers.</param>
  81. /// <param name="externalIds">The external ids.</param>
  82. public void AddParts(IEnumerable<IImageProvider> imageProviders, IEnumerable<IMetadataService> metadataServices,
  83. IEnumerable<IItemIdentityProvider> identityProviders, IEnumerable<IItemIdentityConverter> identityConverters,
  84. IEnumerable<IMetadataProvider> metadataProviders, IEnumerable<IMetadataSaver> metadataSavers,
  85. IEnumerable<IImageSaver> imageSavers, IEnumerable<IExternalId> externalIds)
  86. {
  87. ImageProviders = imageProviders.ToArray();
  88. _metadataServices = metadataServices.OrderBy(i => i.Order).ToArray();
  89. _identityProviders = identityProviders.ToArray();
  90. _identityConverters = identityConverters.ToArray();
  91. _metadataProviders = metadataProviders.ToArray();
  92. _savers = metadataSavers.ToArray();
  93. _imageSavers = imageSavers.ToArray();
  94. _externalIds = externalIds.OrderBy(i => i.Name).ToArray();
  95. }
  96. public Task RefreshMetadata(IHasMetadata item, MetadataRefreshOptions options, CancellationToken cancellationToken)
  97. {
  98. var service = _metadataServices.FirstOrDefault(i => i.CanRefresh(item));
  99. if (service != null)
  100. {
  101. return service.RefreshMetadata(item, options, cancellationToken);
  102. }
  103. _logger.Error("Unable to find a metadata service for item of type " + item.GetType().Name);
  104. return Task.FromResult(true);
  105. }
  106. public async Task SaveImage(IHasImages item, string url, SemaphoreSlim resourcePool, ImageType type, int? imageIndex, CancellationToken cancellationToken)
  107. {
  108. var response = await _httpClient.GetResponse(new HttpRequestOptions
  109. {
  110. CancellationToken = cancellationToken,
  111. ResourcePool = resourcePool,
  112. Url = url
  113. }).ConfigureAwait(false);
  114. await SaveImage(item, response.Content, response.ContentType, type, imageIndex, cancellationToken)
  115. .ConfigureAwait(false);
  116. }
  117. public Task SaveImage(IHasImages item, Stream source, string mimeType, ImageType type, int? imageIndex, CancellationToken cancellationToken)
  118. {
  119. return new ImageSaver(ConfigurationManager, _libraryMonitor, _fileSystem, _logger).SaveImage(item, source, mimeType, type, imageIndex, cancellationToken);
  120. }
  121. public async Task<IEnumerable<RemoteImageInfo>> GetAvailableRemoteImages(IHasImages item, RemoteImageQuery query, CancellationToken cancellationToken)
  122. {
  123. var providers = GetRemoteImageProviders(item, query.IncludeDisabledProviders);
  124. if (!string.IsNullOrEmpty(query.ProviderName))
  125. {
  126. var providerName = query.ProviderName;
  127. providers = providers.Where(i => string.Equals(i.Name, providerName, StringComparison.OrdinalIgnoreCase));
  128. }
  129. var preferredLanguage = item.GetPreferredMetadataLanguage();
  130. var languages = new List<string>();
  131. if (!query.IncludeAllLanguages && !string.IsNullOrWhiteSpace(preferredLanguage))
  132. {
  133. languages.Add(preferredLanguage);
  134. }
  135. var tasks = providers.Select(i => GetImages(item, cancellationToken, i, languages, query.ImageType));
  136. var results = await Task.WhenAll(tasks).ConfigureAwait(false);
  137. var images = results.SelectMany(i => i);
  138. return images;
  139. }
  140. /// <summary>
  141. /// Gets the images.
  142. /// </summary>
  143. /// <param name="item">The item.</param>
  144. /// <param name="cancellationToken">The cancellation token.</param>
  145. /// <param name="provider">The provider.</param>
  146. /// <param name="preferredLanguages">The preferred languages.</param>
  147. /// <param name="type">The type.</param>
  148. /// <returns>Task{IEnumerable{RemoteImageInfo}}.</returns>
  149. private async Task<IEnumerable<RemoteImageInfo>> GetImages(IHasImages item, CancellationToken cancellationToken, IRemoteImageProvider provider, List<string> preferredLanguages, ImageType? type = null)
  150. {
  151. try
  152. {
  153. var result = await provider.GetImages(item, cancellationToken).ConfigureAwait(false);
  154. if (type.HasValue)
  155. {
  156. result = result.Where(i => i.Type == type.Value);
  157. }
  158. if (preferredLanguages.Count > 0)
  159. {
  160. result = result.Where(i => string.IsNullOrEmpty(i.Language) ||
  161. preferredLanguages.Contains(i.Language, StringComparer.OrdinalIgnoreCase));
  162. }
  163. //if (string.Equals(preferredLanguage, "en", StringComparison.OrdinalIgnoreCase))
  164. //{
  165. // result = result.Where(i => string.IsNullOrEmpty(i.Language) ||
  166. // string.Equals(i.Language, "en", StringComparison.OrdinalIgnoreCase));
  167. //}
  168. return result;
  169. }
  170. catch (OperationCanceledException)
  171. {
  172. return new List<RemoteImageInfo>();
  173. }
  174. catch (Exception ex)
  175. {
  176. _logger.ErrorException("{0} failed in GetImageInfos for type {1}", ex, provider.GetType().Name, item.GetType().Name);
  177. return new List<RemoteImageInfo>();
  178. }
  179. }
  180. /// <summary>
  181. /// Gets the supported image providers.
  182. /// </summary>
  183. /// <param name="item">The item.</param>
  184. /// <returns>IEnumerable{IImageProvider}.</returns>
  185. public IEnumerable<ImageProviderInfo> GetRemoteImageProviderInfo(IHasImages item)
  186. {
  187. return GetRemoteImageProviders(item, true).Select(i => new ImageProviderInfo
  188. {
  189. Name = i.Name,
  190. SupportedImages = i.GetSupportedImages(item).ToList()
  191. });
  192. }
  193. public IEnumerable<IImageProvider> GetImageProviders(IHasImages item)
  194. {
  195. return GetImageProviders(item, GetMetadataOptions(item), false);
  196. }
  197. private IEnumerable<IImageProvider> GetImageProviders(IHasImages item, MetadataOptions options, bool includeDisabled)
  198. {
  199. // Avoid implicitly captured closure
  200. var currentOptions = options;
  201. return ImageProviders.Where(i => CanRefresh(i, item, options, includeDisabled))
  202. .OrderBy(i =>
  203. {
  204. // See if there's a user-defined order
  205. if (!(i is ILocalImageProvider))
  206. {
  207. var index = Array.IndexOf(currentOptions.ImageFetcherOrder, i.Name);
  208. if (index != -1)
  209. {
  210. return index;
  211. }
  212. }
  213. // Not configured. Just return some high number to put it at the end.
  214. return 100;
  215. })
  216. .ThenBy(GetOrder);
  217. }
  218. public IEnumerable<IMetadataProvider<T>> GetMetadataProviders<T>(IHasMetadata item)
  219. where T : IHasMetadata
  220. {
  221. var options = GetMetadataOptions(item);
  222. return GetMetadataProvidersInternal<T>(item, options, false);
  223. }
  224. private IEnumerable<IMetadataProvider<T>> GetMetadataProvidersInternal<T>(IHasMetadata item, MetadataOptions options, bool includeDisabled)
  225. where T : IHasMetadata
  226. {
  227. // Avoid implicitly captured closure
  228. var currentOptions = options;
  229. return _metadataProviders.OfType<IMetadataProvider<T>>()
  230. .Where(i => CanRefresh(i, item, currentOptions, includeDisabled))
  231. .OrderBy(i => GetConfiguredOrder(i, options))
  232. .ThenBy(GetDefaultOrder);
  233. }
  234. public IEnumerable<IItemIdentityProvider<TLookupInfo, TIdentity>> GetItemIdentityProviders<TLookupInfo, TIdentity>()
  235. where TLookupInfo : ItemLookupInfo
  236. where TIdentity : IItemIdentity
  237. {
  238. return _identityProviders.OfType<IItemIdentityProvider<TLookupInfo, TIdentity>>();
  239. }
  240. public IEnumerable<IItemIdentityConverter<TIdentity>> GetItemIdentityConverters<TIdentity>()
  241. where TIdentity : IItemIdentity
  242. {
  243. return _identityConverters.OfType<IItemIdentityConverter<TIdentity>>();
  244. }
  245. private IEnumerable<IRemoteImageProvider> GetRemoteImageProviders(IHasImages item, bool includeDisabled)
  246. {
  247. var options = GetMetadataOptions(item);
  248. return GetImageProviders(item, options, includeDisabled).OfType<IRemoteImageProvider>();
  249. }
  250. private bool CanRefresh(IMetadataProvider provider, IHasMetadata item, MetadataOptions options, bool includeDisabled)
  251. {
  252. if (!includeDisabled)
  253. {
  254. // If locked only allow local providers
  255. if (item.IsLocked && !(provider is ILocalMetadataProvider) && !(provider is IForcedProvider))
  256. {
  257. return false;
  258. }
  259. if (provider is IRemoteMetadataProvider)
  260. {
  261. if (!ConfigurationManager.Configuration.EnableInternetProviders)
  262. {
  263. return false;
  264. }
  265. if (Array.IndexOf(options.DisabledMetadataFetchers, provider.Name) != -1)
  266. {
  267. return false;
  268. }
  269. }
  270. }
  271. if (!item.SupportsLocalMetadata && provider is ILocalMetadataProvider)
  272. {
  273. return false;
  274. }
  275. // If this restriction is ever lifted, movie xml providers will have to be updated to prevent owned items like trailers from reading those files
  276. if (item.IsOwnedItem)
  277. {
  278. if (provider is ILocalMetadataProvider || provider is IRemoteMetadataProvider)
  279. {
  280. return false;
  281. }
  282. }
  283. return true;
  284. }
  285. private bool CanRefresh(IImageProvider provider, IHasImages item, MetadataOptions options, bool includeDisabled)
  286. {
  287. if (!includeDisabled)
  288. {
  289. // If locked only allow local providers
  290. if (item.IsLocked && !(provider is ILocalImageProvider))
  291. {
  292. return false;
  293. }
  294. if (provider is IRemoteImageProvider || provider is IDynamicImageProvider)
  295. {
  296. if (!ConfigurationManager.Configuration.EnableInternetProviders)
  297. {
  298. return false;
  299. }
  300. if (Array.IndexOf(options.DisabledImageFetchers, provider.Name) != -1)
  301. {
  302. return false;
  303. }
  304. }
  305. }
  306. if (!item.SupportsLocalMetadata && provider is ILocalImageProvider)
  307. {
  308. return false;
  309. }
  310. try
  311. {
  312. return provider.Supports(item);
  313. }
  314. catch (Exception ex)
  315. {
  316. _logger.ErrorException("{0} failed in Supports for type {1}", ex, provider.GetType().Name, item.GetType().Name);
  317. return false;
  318. }
  319. }
  320. /// <summary>
  321. /// Gets the order.
  322. /// </summary>
  323. /// <param name="provider">The provider.</param>
  324. /// <returns>System.Int32.</returns>
  325. private int GetOrder(IImageProvider provider)
  326. {
  327. var hasOrder = provider as IHasOrder;
  328. if (hasOrder == null)
  329. {
  330. return 0;
  331. }
  332. return hasOrder.Order;
  333. }
  334. private int GetConfiguredOrder(IMetadataProvider provider, MetadataOptions options)
  335. {
  336. // See if there's a user-defined order
  337. if (provider is ILocalMetadataProvider)
  338. {
  339. var index = Array.IndexOf(options.LocalMetadataReaderOrder, provider.Name);
  340. if (index != -1)
  341. {
  342. return index;
  343. }
  344. }
  345. // See if there's a user-defined order
  346. if (provider is IRemoteMetadataProvider)
  347. {
  348. var index = Array.IndexOf(options.MetadataFetcherOrder, provider.Name);
  349. if (index != -1)
  350. {
  351. return index;
  352. }
  353. }
  354. // Not configured. Just return some high number to put it at the end.
  355. return 100;
  356. }
  357. private int GetDefaultOrder(IMetadataProvider provider)
  358. {
  359. var hasOrder = provider as IHasOrder;
  360. if (hasOrder != null)
  361. {
  362. return hasOrder.Order;
  363. }
  364. return 0;
  365. }
  366. public IEnumerable<MetadataPluginSummary> GetAllMetadataPlugins()
  367. {
  368. var list = new List<MetadataPluginSummary>
  369. {
  370. GetPluginSummary<Game>(),
  371. GetPluginSummary<GameSystem>(),
  372. GetPluginSummary<Movie>(),
  373. GetPluginSummary<Trailer>(),
  374. GetPluginSummary<BoxSet>(),
  375. GetPluginSummary<Book>(),
  376. GetPluginSummary<Series>(),
  377. GetPluginSummary<Season>(),
  378. GetPluginSummary<Episode>(),
  379. GetPluginSummary<Person>(),
  380. GetPluginSummary<MusicAlbum>(),
  381. GetPluginSummary<MusicArtist>(),
  382. GetPluginSummary<Audio>(),
  383. GetPluginSummary<Genre>(),
  384. GetPluginSummary<Studio>(),
  385. GetPluginSummary<GameGenre>(),
  386. GetPluginSummary<MusicGenre>(),
  387. GetPluginSummary<AdultVideo>(),
  388. GetPluginSummary<MusicVideo>(),
  389. GetPluginSummary<Video>(),
  390. GetPluginSummary<LiveTvChannel>(),
  391. GetPluginSummary<LiveTvProgram>(),
  392. GetPluginSummary<LiveTvVideoRecording>(),
  393. GetPluginSummary<LiveTvAudioRecording>()
  394. };
  395. return list;
  396. }
  397. private MetadataPluginSummary GetPluginSummary<T>()
  398. where T : BaseItem, new()
  399. {
  400. // Give it a dummy path just so that it looks like a file system item
  401. var dummy = new T()
  402. {
  403. Path = "C:\\",
  404. // Dummy this up to fool the local trailer check
  405. Parent = new Folder()
  406. };
  407. var options = GetMetadataOptions(dummy);
  408. var summary = new MetadataPluginSummary
  409. {
  410. ItemType = typeof(T).Name
  411. };
  412. var imageProviders = GetImageProviders(dummy, options, true).ToList();
  413. AddMetadataPlugins(summary.Plugins, dummy, options);
  414. AddImagePlugins(summary.Plugins, dummy, imageProviders);
  415. var supportedImageTypes = imageProviders.OfType<IRemoteImageProvider>()
  416. .SelectMany(i => i.GetSupportedImages(dummy))
  417. .ToList();
  418. supportedImageTypes.AddRange(imageProviders.OfType<IDynamicImageProvider>()
  419. .SelectMany(i => i.GetSupportedImages(dummy)));
  420. summary.SupportedImageTypes = supportedImageTypes.Distinct().ToList();
  421. return summary;
  422. }
  423. private void AddMetadataPlugins<T>(List<MetadataPlugin> list, T item, MetadataOptions options)
  424. where T : IHasMetadata
  425. {
  426. var providers = GetMetadataProvidersInternal<T>(item, options, true).ToList();
  427. // Locals
  428. list.AddRange(providers.Where(i => (i is ILocalMetadataProvider)).Select(i => new MetadataPlugin
  429. {
  430. Name = i.Name,
  431. Type = MetadataPluginType.LocalMetadataProvider
  432. }));
  433. if (ConfigurationManager.Configuration.EnableInternetProviders)
  434. {
  435. // Fetchers
  436. list.AddRange(providers.Where(i => (i is IRemoteMetadataProvider)).Select(i => new MetadataPlugin
  437. {
  438. Name = i.Name,
  439. Type = MetadataPluginType.MetadataFetcher
  440. }));
  441. }
  442. if (item.IsSaveLocalMetadataEnabled())
  443. {
  444. // Savers
  445. list.AddRange(_savers.Where(i => IsSaverEnabledForItem(i, item, ItemUpdateType.MetadataEdit, true)).OrderBy(i => i.Name).Select(i => new MetadataPlugin
  446. {
  447. Name = i.Name,
  448. Type = MetadataPluginType.MetadataSaver
  449. }));
  450. }
  451. }
  452. private void AddImagePlugins<T>(List<MetadataPlugin> list, T item, List<IImageProvider> imageProviders)
  453. where T : IHasImages
  454. {
  455. // Locals
  456. list.AddRange(imageProviders.Where(i => (i is ILocalImageProvider)).Select(i => new MetadataPlugin
  457. {
  458. Name = i.Name,
  459. Type = MetadataPluginType.LocalImageProvider
  460. }));
  461. if (ConfigurationManager.Configuration.EnableInternetProviders)
  462. {
  463. // Fetchers
  464. list.AddRange(imageProviders.Where(i => i is IRemoteImageProvider).Select(i => new MetadataPlugin
  465. {
  466. Name = i.Name,
  467. Type = MetadataPluginType.ImageFetcher
  468. }));
  469. }
  470. // Fetchers
  471. list.AddRange(imageProviders.Where(i => i is IDynamicImageProvider).Select(i => new MetadataPlugin
  472. {
  473. Name = i.Name,
  474. Type = MetadataPluginType.ImageFetcher
  475. }));
  476. }
  477. public MetadataOptions GetMetadataOptions(IHasImages item)
  478. {
  479. var type = item.GetType().Name;
  480. return ConfigurationManager.Configuration.MetadataOptions
  481. .FirstOrDefault(i => string.Equals(i.ItemType, type, StringComparison.OrdinalIgnoreCase)) ??
  482. new MetadataOptions();
  483. }
  484. private readonly ConcurrentDictionary<string, SemaphoreSlim> _fileLocks = new ConcurrentDictionary<string, SemaphoreSlim>();
  485. /// <summary>
  486. /// Saves the metadata.
  487. /// </summary>
  488. /// <param name="item">The item.</param>
  489. /// <param name="updateType">Type of the update.</param>
  490. /// <returns>Task.</returns>
  491. public async Task SaveMetadata(IHasMetadata item, ItemUpdateType updateType)
  492. {
  493. foreach (var saver in _savers.Where(i => IsSaverEnabledForItem(i, item, updateType, false)))
  494. {
  495. _logger.Debug("Saving {0} to {1}.", item.Path ?? item.Name, saver.Name);
  496. var fileSaver = saver as IMetadataFileSaver;
  497. if (fileSaver != null)
  498. {
  499. string path = null;
  500. try
  501. {
  502. path = fileSaver.GetSavePath(item);
  503. }
  504. catch (Exception ex)
  505. {
  506. _logger.ErrorException("Error in {0} GetSavePath", ex, saver.Name);
  507. continue;
  508. }
  509. var semaphore = _fileLocks.GetOrAdd(path, key => new SemaphoreSlim(1, 1));
  510. await semaphore.WaitAsync().ConfigureAwait(false);
  511. try
  512. {
  513. _libraryMonitor.ReportFileSystemChangeBeginning(path);
  514. saver.Save(item, CancellationToken.None);
  515. }
  516. catch (Exception ex)
  517. {
  518. _logger.ErrorException("Error in metadata saver", ex);
  519. }
  520. finally
  521. {
  522. _libraryMonitor.ReportFileSystemChangeComplete(path, false);
  523. semaphore.Release();
  524. }
  525. }
  526. else
  527. {
  528. try
  529. {
  530. saver.Save(item, CancellationToken.None);
  531. }
  532. catch (Exception ex)
  533. {
  534. _logger.ErrorException("Error in metadata saver", ex);
  535. }
  536. }
  537. }
  538. }
  539. private bool IsSaverEnabledForItem(IMetadataSaver saver, IHasMetadata item, ItemUpdateType updateType, bool includeDisabled)
  540. {
  541. var options = GetMetadataOptions(item);
  542. try
  543. {
  544. var isEnabledFor = saver.IsEnabledFor(item, updateType);
  545. if (!includeDisabled)
  546. {
  547. if (options.DisabledMetadataSavers.Contains(saver.Name, StringComparer.OrdinalIgnoreCase))
  548. {
  549. return false;
  550. }
  551. if (!item.IsSaveLocalMetadataEnabled())
  552. {
  553. if (updateType >= ItemUpdateType.MetadataEdit)
  554. {
  555. var fileSaver = saver as IMetadataFileSaver;
  556. // Manual edit occurred
  557. // Even if save local is off, save locally anyway if the metadata file already exists
  558. if (fileSaver == null || !isEnabledFor || !File.Exists(fileSaver.GetSavePath(item)))
  559. {
  560. return false;
  561. }
  562. }
  563. else
  564. {
  565. // Manual edit did not occur
  566. // Since local metadata saving is disabled, consider it disabled
  567. return false;
  568. }
  569. }
  570. }
  571. return isEnabledFor;
  572. }
  573. catch (Exception ex)
  574. {
  575. _logger.ErrorException("Error in {0}.IsEnabledFor", ex, saver.Name);
  576. return false;
  577. }
  578. }
  579. public async Task<IEnumerable<RemoteSearchResult>> GetRemoteSearchResults<TItemType, TLookupType>(RemoteSearchQuery<TLookupType> searchInfo,
  580. CancellationToken cancellationToken)
  581. where TItemType : BaseItem, new()
  582. where TLookupType : ItemLookupInfo
  583. {
  584. // Give it a dummy path just so that it looks like a file system item
  585. var dummy = new TItemType
  586. {
  587. Path = "C:\\",
  588. // Dummy this up to fool the local trailer check
  589. Parent = new Folder()
  590. };
  591. var options = GetMetadataOptions(dummy);
  592. var providers = GetMetadataProvidersInternal<TItemType>(dummy, options, searchInfo.IncludeDisabledProviders)
  593. .OfType<IRemoteSearchProvider<TLookupType>>();
  594. if (!string.IsNullOrEmpty(searchInfo.SearchProviderName))
  595. {
  596. providers = providers.Where(i => string.Equals(i.Name, searchInfo.SearchProviderName, StringComparison.OrdinalIgnoreCase));
  597. }
  598. if (string.IsNullOrWhiteSpace(searchInfo.SearchInfo.MetadataLanguage))
  599. {
  600. searchInfo.SearchInfo.MetadataLanguage = ConfigurationManager.Configuration.PreferredMetadataLanguage;
  601. }
  602. if (string.IsNullOrWhiteSpace(searchInfo.SearchInfo.MetadataCountryCode))
  603. {
  604. searchInfo.SearchInfo.MetadataCountryCode = ConfigurationManager.Configuration.MetadataCountryCode;
  605. }
  606. foreach (var provider in providers)
  607. {
  608. var results = await GetSearchResults(provider, searchInfo.SearchInfo, cancellationToken).ConfigureAwait(false);
  609. var list = results.ToList();
  610. if (list.Count > 0)
  611. {
  612. return list.Take(10);
  613. }
  614. }
  615. // Nothing found
  616. return new List<RemoteSearchResult>();
  617. }
  618. private async Task<IEnumerable<RemoteSearchResult>> GetSearchResults<TLookupType>(IRemoteSearchProvider<TLookupType> provider, TLookupType searchInfo,
  619. CancellationToken cancellationToken)
  620. where TLookupType : ItemLookupInfo
  621. {
  622. var results = await provider.GetSearchResults(searchInfo, cancellationToken).ConfigureAwait(false);
  623. var list = results.ToList();
  624. foreach (var item in list)
  625. {
  626. item.SearchProviderName = provider.Name;
  627. }
  628. return list;
  629. }
  630. public Task<HttpResponseInfo> GetSearchImage(string providerName, string url, CancellationToken cancellationToken)
  631. {
  632. var provider = _metadataProviders.OfType<IRemoteSearchProvider>().FirstOrDefault(i => string.Equals(i.Name, providerName, StringComparison.OrdinalIgnoreCase));
  633. if (provider == null)
  634. {
  635. throw new ArgumentException("Search provider not found.");
  636. }
  637. return provider.GetImageResponse(url, cancellationToken);
  638. }
  639. public IEnumerable<IExternalId> GetExternalIds(IHasProviderIds item)
  640. {
  641. return _externalIds.Where(i =>
  642. {
  643. try
  644. {
  645. return i.Supports(item);
  646. }
  647. catch (Exception ex)
  648. {
  649. _logger.ErrorException("Error in {0}.Suports", ex, i.GetType().Name);
  650. return false;
  651. }
  652. });
  653. }
  654. public IEnumerable<ExternalUrl> GetExternalUrls(IHasProviderIds item)
  655. {
  656. return GetExternalIds(item)
  657. .Select(i =>
  658. {
  659. if (string.IsNullOrEmpty(i.UrlFormatString))
  660. {
  661. return null;
  662. }
  663. var value = item.GetProviderId(i.Key);
  664. if (string.IsNullOrEmpty(value))
  665. {
  666. return null;
  667. }
  668. return new ExternalUrl
  669. {
  670. Name = i.Name,
  671. Url = string.Format(i.UrlFormatString, value)
  672. };
  673. }).Where(i => i != null);
  674. }
  675. public IEnumerable<ExternalIdInfo> GetExternalIdInfos(IHasProviderIds item)
  676. {
  677. return GetExternalIds(item)
  678. .Select(i => new ExternalIdInfo
  679. {
  680. Name = i.Name,
  681. Key = i.Key,
  682. UrlFormatString = i.UrlFormatString
  683. });
  684. }
  685. }
  686. }