TvdbEpisodeImageProvider.cs 4.5 KB

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