TvdbEpisodeImageProvider.cs 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  1. #pragma warning disable CS1591
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Net.Http;
  5. using System.Globalization;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. using MediaBrowser.Controller.Entities;
  9. using MediaBrowser.Controller.Entities.TV;
  10. using MediaBrowser.Controller.Providers;
  11. using MediaBrowser.Model.Entities;
  12. using MediaBrowser.Model.Providers;
  13. using Microsoft.Extensions.Logging;
  14. using TvDbSharper;
  15. using TvDbSharper.Dto;
  16. namespace MediaBrowser.Providers.Plugins.TheTvdb
  17. {
  18. public class TvdbEpisodeImageProvider : IRemoteImageProvider
  19. {
  20. private readonly IHttpClientFactory _httpClientFactory;
  21. private readonly ILogger<TvdbEpisodeImageProvider> _logger;
  22. private readonly TvdbClientManager _tvdbClientManager;
  23. public TvdbEpisodeImageProvider(IHttpClientFactory httpClientFactory, ILogger<TvdbEpisodeImageProvider> logger, TvdbClientManager tvdbClientManager)
  24. {
  25. _httpClientFactory = httpClientFactory;
  26. _logger = logger;
  27. _tvdbClientManager = tvdbClientManager;
  28. }
  29. public string Name => "TheTVDB";
  30. public bool Supports(BaseItem item)
  31. {
  32. return item is Episode;
  33. }
  34. public IEnumerable<ImageType> GetSupportedImages(BaseItem item)
  35. {
  36. return new List<ImageType>
  37. {
  38. ImageType.Primary
  39. };
  40. }
  41. public async Task<IEnumerable<RemoteImageInfo>> GetImages(BaseItem item, CancellationToken cancellationToken)
  42. {
  43. var episode = (Episode)item;
  44. var series = episode.Series;
  45. var imageResult = new List<RemoteImageInfo>();
  46. var language = item.GetPreferredMetadataLanguage();
  47. if (series != null && TvdbSeriesProvider.IsValidSeries(series.ProviderIds))
  48. {
  49. // Process images
  50. try
  51. {
  52. var episodeInfo = new EpisodeInfo
  53. {
  54. IndexNumber = episode.IndexNumber.Value,
  55. ParentIndexNumber = episode.ParentIndexNumber.Value,
  56. SeriesProviderIds = series.ProviderIds,
  57. SeriesDisplayOrder = series.DisplayOrder
  58. };
  59. string episodeTvdbId = await _tvdbClientManager
  60. .GetEpisodeTvdbId(episodeInfo, language, cancellationToken).ConfigureAwait(false);
  61. if (string.IsNullOrEmpty(episodeTvdbId))
  62. {
  63. _logger.LogError(
  64. "Episode {SeasonNumber}x{EpisodeNumber} not found for series {SeriesTvdbId}",
  65. episodeInfo.ParentIndexNumber,
  66. episodeInfo.IndexNumber,
  67. series.GetProviderId(MetadataProvider.Tvdb));
  68. return imageResult;
  69. }
  70. var episodeResult =
  71. await _tvdbClientManager
  72. .GetEpisodesAsync(Convert.ToInt32(episodeTvdbId, CultureInfo.InvariantCulture), language, cancellationToken)
  73. .ConfigureAwait(false);
  74. var image = GetImageInfo(episodeResult.Data);
  75. if (image != null)
  76. {
  77. imageResult.Add(image);
  78. }
  79. }
  80. catch (TvDbServerException e)
  81. {
  82. _logger.LogError(e, "Failed to retrieve episode images for series {TvDbId}", series.GetProviderId(MetadataProvider.Tvdb));
  83. }
  84. }
  85. return imageResult;
  86. }
  87. private RemoteImageInfo GetImageInfo(EpisodeRecord episode)
  88. {
  89. if (string.IsNullOrEmpty(episode.Filename))
  90. {
  91. return null;
  92. }
  93. return new RemoteImageInfo
  94. {
  95. Width = Convert.ToInt32(episode.ThumbWidth, CultureInfo.InvariantCulture),
  96. Height = Convert.ToInt32(episode.ThumbHeight, CultureInfo.InvariantCulture),
  97. ProviderName = Name,
  98. Url = TvdbUtils.BannerUrl + episode.Filename,
  99. Type = ImageType.Primary
  100. };
  101. }
  102. public int Order => 0;
  103. public Task<HttpResponseMessage> GetImageResponse(string url, CancellationToken cancellationToken)
  104. {
  105. return _httpClientFactory.CreateClient().GetAsync(url, cancellationToken);
  106. }
  107. }
  108. }