TvdbSeriesImageProvider.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363
  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.TV;
  6. using MediaBrowser.Controller.Library;
  7. using MediaBrowser.Controller.Providers;
  8. using MediaBrowser.Model.Dto;
  9. using MediaBrowser.Model.Entities;
  10. using MediaBrowser.Model.Providers;
  11. using System;
  12. using System.Collections.Generic;
  13. using System.Globalization;
  14. using System.IO;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Threading;
  18. using System.Threading.Tasks;
  19. using System.Xml;
  20. namespace MediaBrowser.Providers.TV
  21. {
  22. public class TvdbSeriesImageProvider : IRemoteImageProvider, IHasOrder, IHasItemChangeMonitor
  23. {
  24. private readonly IServerConfigurationManager _config;
  25. private readonly IHttpClient _httpClient;
  26. private readonly CultureInfo _usCulture = new CultureInfo("en-US");
  27. private readonly IFileSystem _fileSystem;
  28. public TvdbSeriesImageProvider(IServerConfigurationManager config, IHttpClient httpClient, IFileSystem fileSystem)
  29. {
  30. _config = config;
  31. _httpClient = httpClient;
  32. _fileSystem = fileSystem;
  33. }
  34. public string Name
  35. {
  36. get { return ProviderName; }
  37. }
  38. public static string ProviderName
  39. {
  40. get { return "TheTVDB"; }
  41. }
  42. public bool Supports(IHasImages item)
  43. {
  44. return item is Series;
  45. }
  46. public IEnumerable<ImageType> GetSupportedImages(IHasImages item)
  47. {
  48. return new List<ImageType>
  49. {
  50. ImageType.Primary,
  51. ImageType.Banner,
  52. ImageType.Backdrop
  53. };
  54. }
  55. public async Task<IEnumerable<RemoteImageInfo>> GetImages(IHasImages item, CancellationToken cancellationToken)
  56. {
  57. var series = (Series)item;
  58. var seriesId = series.GetProviderId(MetadataProviders.Tvdb);
  59. if (!string.IsNullOrEmpty(seriesId))
  60. {
  61. var language = item.GetPreferredMetadataLanguage();
  62. await TvdbSeriesProvider.Current.EnsureSeriesInfo(seriesId, language, cancellationToken).ConfigureAwait(false);
  63. // Process images
  64. var seriesDataPath = TvdbSeriesProvider.GetSeriesDataPath(_config.ApplicationPaths, seriesId);
  65. var path = Path.Combine(seriesDataPath, "banners.xml");
  66. try
  67. {
  68. var seriesOffset = TvdbSeriesProvider.GetSeriesOffset(series.ProviderIds);
  69. if (seriesOffset != null && seriesOffset.Value != 0)
  70. return TvdbSeasonImageProvider.GetImages(path, language, seriesOffset.Value + 1, cancellationToken);
  71. return GetImages(path, language, cancellationToken);
  72. }
  73. catch (FileNotFoundException)
  74. {
  75. // No tvdb data yet. Don't blow up
  76. }
  77. catch (DirectoryNotFoundException)
  78. {
  79. // No tvdb data yet. Don't blow up
  80. }
  81. }
  82. return new RemoteImageInfo[] { };
  83. }
  84. private IEnumerable<RemoteImageInfo> GetImages(string xmlPath, string preferredLanguage, CancellationToken cancellationToken)
  85. {
  86. var settings = new XmlReaderSettings
  87. {
  88. CheckCharacters = false,
  89. IgnoreProcessingInstructions = true,
  90. IgnoreComments = true,
  91. ValidationType = ValidationType.None
  92. };
  93. var list = new List<RemoteImageInfo>();
  94. using (var streamReader = new StreamReader(xmlPath, Encoding.UTF8))
  95. {
  96. // Use XmlReader for best performance
  97. using (var reader = XmlReader.Create(streamReader, settings))
  98. {
  99. reader.MoveToContent();
  100. // Loop through each element
  101. while (reader.Read())
  102. {
  103. cancellationToken.ThrowIfCancellationRequested();
  104. if (reader.NodeType == XmlNodeType.Element)
  105. {
  106. switch (reader.Name)
  107. {
  108. case "Banner":
  109. {
  110. using (var subtree = reader.ReadSubtree())
  111. {
  112. AddImage(subtree, list);
  113. }
  114. break;
  115. }
  116. default:
  117. reader.Skip();
  118. break;
  119. }
  120. }
  121. }
  122. }
  123. }
  124. var isLanguageEn = string.Equals(preferredLanguage, "en", StringComparison.OrdinalIgnoreCase);
  125. return list.OrderByDescending(i =>
  126. {
  127. if (string.Equals(preferredLanguage, i.Language, StringComparison.OrdinalIgnoreCase))
  128. {
  129. return 3;
  130. }
  131. if (!isLanguageEn)
  132. {
  133. if (string.Equals("en", i.Language, StringComparison.OrdinalIgnoreCase))
  134. {
  135. return 2;
  136. }
  137. }
  138. if (string.IsNullOrEmpty(i.Language))
  139. {
  140. return isLanguageEn ? 3 : 2;
  141. }
  142. return 0;
  143. })
  144. .ThenByDescending(i => i.CommunityRating ?? 0)
  145. .ThenByDescending(i => i.VoteCount ?? 0)
  146. .ToList();
  147. }
  148. private void AddImage(XmlReader reader, List<RemoteImageInfo> images)
  149. {
  150. reader.MoveToContent();
  151. string bannerType = null;
  152. string url = null;
  153. int? bannerSeason = null;
  154. int? width = null;
  155. int? height = null;
  156. string language = null;
  157. double? rating = null;
  158. int? voteCount = null;
  159. string thumbnailUrl = null;
  160. while (reader.Read())
  161. {
  162. if (reader.NodeType == XmlNodeType.Element)
  163. {
  164. switch (reader.Name)
  165. {
  166. case "Rating":
  167. {
  168. var val = reader.ReadElementContentAsString() ?? string.Empty;
  169. double rval;
  170. if (double.TryParse(val, NumberStyles.Any, _usCulture, out rval))
  171. {
  172. rating = rval;
  173. }
  174. break;
  175. }
  176. case "RatingCount":
  177. {
  178. var val = reader.ReadElementContentAsString() ?? string.Empty;
  179. int rval;
  180. if (int.TryParse(val, NumberStyles.Integer, _usCulture, out rval))
  181. {
  182. voteCount = rval;
  183. }
  184. break;
  185. }
  186. case "Language":
  187. {
  188. language = reader.ReadElementContentAsString() ?? string.Empty;
  189. break;
  190. }
  191. case "ThumbnailPath":
  192. {
  193. thumbnailUrl = reader.ReadElementContentAsString() ?? string.Empty;
  194. break;
  195. }
  196. case "BannerType":
  197. {
  198. bannerType = reader.ReadElementContentAsString() ?? string.Empty;
  199. break;
  200. }
  201. case "BannerPath":
  202. {
  203. url = reader.ReadElementContentAsString() ?? string.Empty;
  204. break;
  205. }
  206. case "BannerType2":
  207. {
  208. var bannerType2 = reader.ReadElementContentAsString() ?? string.Empty;
  209. // Sometimes the resolution is stuffed in here
  210. var resolutionParts = bannerType2.Split('x');
  211. if (resolutionParts.Length == 2)
  212. {
  213. int rval;
  214. if (int.TryParse(resolutionParts[0], NumberStyles.Integer, _usCulture, out rval))
  215. {
  216. width = rval;
  217. }
  218. if (int.TryParse(resolutionParts[1], NumberStyles.Integer, _usCulture, out rval))
  219. {
  220. height = rval;
  221. }
  222. }
  223. break;
  224. }
  225. case "Season":
  226. {
  227. var val = reader.ReadElementContentAsString();
  228. if (!string.IsNullOrWhiteSpace(val))
  229. {
  230. bannerSeason = int.Parse(val);
  231. }
  232. break;
  233. }
  234. default:
  235. reader.Skip();
  236. break;
  237. }
  238. }
  239. }
  240. if (!string.IsNullOrEmpty(url) && !bannerSeason.HasValue)
  241. {
  242. var imageInfo = new RemoteImageInfo
  243. {
  244. RatingType = RatingType.Score,
  245. CommunityRating = rating,
  246. VoteCount = voteCount,
  247. Url = TVUtils.BannerUrl + url,
  248. ProviderName = Name,
  249. Language = language,
  250. Width = width,
  251. Height = height
  252. };
  253. if (!string.IsNullOrEmpty(thumbnailUrl))
  254. {
  255. imageInfo.ThumbnailUrl = TVUtils.BannerUrl + thumbnailUrl;
  256. }
  257. if (string.Equals(bannerType, "poster", StringComparison.OrdinalIgnoreCase))
  258. {
  259. imageInfo.Type = ImageType.Primary;
  260. images.Add(imageInfo);
  261. }
  262. else if (string.Equals(bannerType, "series", StringComparison.OrdinalIgnoreCase))
  263. {
  264. imageInfo.Type = ImageType.Banner;
  265. images.Add(imageInfo);
  266. }
  267. else if (string.Equals(bannerType, "fanart", StringComparison.OrdinalIgnoreCase))
  268. {
  269. imageInfo.Type = ImageType.Backdrop;
  270. images.Add(imageInfo);
  271. }
  272. }
  273. }
  274. public int Order
  275. {
  276. get { return 0; }
  277. }
  278. public Task<HttpResponseInfo> GetImageResponse(string url, CancellationToken cancellationToken)
  279. {
  280. return _httpClient.GetResponse(new HttpRequestOptions
  281. {
  282. CancellationToken = cancellationToken,
  283. Url = url,
  284. ResourcePool = TvdbSeriesProvider.Current.TvDbResourcePool
  285. });
  286. }
  287. public bool HasChanged(IHasMetadata item, MetadataStatus status, IDirectoryService directoryService)
  288. {
  289. if (!TvdbSeriesProvider.Current.GetTvDbOptions().EnableAutomaticUpdates)
  290. {
  291. return false;
  292. }
  293. var tvdbId = item.GetProviderId(MetadataProviders.Tvdb);
  294. if (!String.IsNullOrEmpty(tvdbId))
  295. {
  296. // Process images
  297. var imagesXmlPath = Path.Combine(TvdbSeriesProvider.GetSeriesDataPath(_config.ApplicationPaths, tvdbId), "banners.xml");
  298. var fileInfo = new FileInfo(imagesXmlPath);
  299. return fileInfo.Exists && _fileSystem.GetLastWriteTimeUtc(fileInfo) > (status.DateLastMetadataRefresh ?? DateTime.MinValue);
  300. }
  301. return false;
  302. }
  303. }
  304. }