TmdbBoxSetProvider.cs 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. #pragma warning disable CS1591
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Globalization;
  5. using System.Linq;
  6. using System.Net.Http;
  7. using System.Threading;
  8. using System.Threading.Tasks;
  9. using MediaBrowser.Common.Net;
  10. using MediaBrowser.Controller.Entities.Movies;
  11. using MediaBrowser.Controller.Providers;
  12. using MediaBrowser.Model.Entities;
  13. using MediaBrowser.Model.Providers;
  14. namespace MediaBrowser.Providers.Plugins.Tmdb.BoxSets
  15. {
  16. public class TmdbBoxSetProvider : IRemoteMetadataProvider<BoxSet, BoxSetInfo>
  17. {
  18. private readonly IHttpClientFactory _httpClientFactory;
  19. private readonly TmdbClientManager _tmdbClientManager;
  20. public TmdbBoxSetProvider(IHttpClientFactory httpClientFactory, TmdbClientManager tmdbClientManager)
  21. {
  22. _httpClientFactory = httpClientFactory;
  23. _tmdbClientManager = tmdbClientManager;
  24. }
  25. public string Name => TmdbUtils.ProviderName;
  26. public async Task<IEnumerable<RemoteSearchResult>> GetSearchResults(BoxSetInfo searchInfo, CancellationToken cancellationToken)
  27. {
  28. var tmdbId = Convert.ToInt32(searchInfo.GetProviderId(MetadataProvider.Tmdb), CultureInfo.InvariantCulture);
  29. var language = searchInfo.MetadataLanguage;
  30. if (tmdbId > 0)
  31. {
  32. var collection = await _tmdbClientManager.GetCollectionAsync(tmdbId, language, TmdbUtils.GetImageLanguagesParam(language), cancellationToken).ConfigureAwait(false);
  33. if (collection == null)
  34. {
  35. return Enumerable.Empty<RemoteSearchResult>();
  36. }
  37. var result = new RemoteSearchResult
  38. {
  39. Name = collection.Name,
  40. SearchProviderName = Name
  41. };
  42. if (collection.Images != null)
  43. {
  44. result.ImageUrl = _tmdbClientManager.GetPosterUrl(collection.PosterPath);
  45. }
  46. result.SetProviderId(MetadataProvider.Tmdb, collection.Id.ToString(CultureInfo.InvariantCulture));
  47. return new[] { result };
  48. }
  49. var collectionSearchResults = await _tmdbClientManager.SearchCollectionAsync(searchInfo.Name, language, cancellationToken).ConfigureAwait(false);
  50. var collections = new List<RemoteSearchResult>();
  51. for (var i = 0; i < collectionSearchResults.Count; i++)
  52. {
  53. var collection = new RemoteSearchResult
  54. {
  55. Name = collectionSearchResults[i].Name,
  56. SearchProviderName = Name
  57. };
  58. collection.SetProviderId(MetadataProvider.Tmdb, collectionSearchResults[i].Id.ToString(CultureInfo.InvariantCulture));
  59. collections.Add(collection);
  60. }
  61. return collections;
  62. }
  63. public async Task<MetadataResult<BoxSet>> GetMetadata(BoxSetInfo id, CancellationToken cancellationToken)
  64. {
  65. var tmdbId = Convert.ToInt32(id.GetProviderId(MetadataProvider.Tmdb), CultureInfo.InvariantCulture);
  66. var language = id.MetadataLanguage;
  67. // We don't already have an Id, need to fetch it
  68. if (tmdbId <= 0)
  69. {
  70. var searchResults = await _tmdbClientManager.SearchCollectionAsync(id.Name, language, cancellationToken).ConfigureAwait(false);
  71. if (searchResults != null && searchResults.Count > 0)
  72. {
  73. tmdbId = searchResults[0].Id;
  74. }
  75. }
  76. var result = new MetadataResult<BoxSet>();
  77. if (tmdbId > 0)
  78. {
  79. var collection = await _tmdbClientManager.GetCollectionAsync(tmdbId, language, TmdbUtils.GetImageLanguagesParam(language), cancellationToken).ConfigureAwait(false);
  80. if (collection != null)
  81. {
  82. var item = new BoxSet
  83. {
  84. Name = collection.Name,
  85. Overview = collection.Overview
  86. };
  87. item.SetProviderId(MetadataProvider.Tmdb, collection.Id.ToString(CultureInfo.InvariantCulture));
  88. result.HasMetadata = true;
  89. result.Item = item;
  90. }
  91. }
  92. return result;
  93. }
  94. public Task<HttpResponseMessage> GetImageResponse(string url, CancellationToken cancellationToken)
  95. {
  96. return _httpClientFactory.CreateClient(NamedClient.Default).GetAsync(url, cancellationToken);
  97. }
  98. }
  99. }