using MediaBrowser.Common.IO; using MediaBrowser.Common.Net; using MediaBrowser.Controller.Configuration; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities.TV; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Providers; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Providers; using System; using System.Collections.Generic; using System.Globalization; using System.IO; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; using System.Xml; namespace MediaBrowser.Providers.TV { public class TvdbEpisodeImageProvider : IRemoteImageProvider, IHasChangeMonitor { private readonly IServerConfigurationManager _config; private readonly CultureInfo _usCulture = new CultureInfo("en-US"); private readonly IHttpClient _httpClient; private readonly IFileSystem _fileSystem; public TvdbEpisodeImageProvider(IServerConfigurationManager config, IHttpClient httpClient, IFileSystem fileSystem) { _config = config; _httpClient = httpClient; _fileSystem = fileSystem; } public string Name { get { return "TheTVDB"; } } public bool Supports(IHasImages item) { return item is Episode; } public IEnumerable GetSupportedImages(IHasImages item) { return new List { ImageType.Primary }; } public Task> GetImages(IHasImages item, CancellationToken cancellationToken) { var episode = (Episode)item; var series = episode.Series; var seriesId = series != null ? series.GetProviderId(MetadataProviders.Tvdb) : null; if (!string.IsNullOrEmpty(seriesId)) { // Process images var seriesDataPath = TvdbSeriesProvider.GetSeriesDataPath(_config.ApplicationPaths, seriesId); var indexOffset = TvdbSeriesProvider.GetSeriesOffset(series.ProviderIds) ?? 0; var files = TvdbEpisodeProvider.Current.GetEpisodeXmlFiles(episode.ParentIndexNumber + indexOffset, episode.IndexNumber, episode.IndexNumberEnd, seriesDataPath); var result = files.Select(i => GetImageInfo(i, cancellationToken)) .Where(i => i != null); return Task.FromResult(result); } return Task.FromResult>(new RemoteImageInfo[] { }); } private RemoteImageInfo GetImageInfo(FileInfo xmlFile, CancellationToken cancellationToken) { var height = 225; var width = 400; var url = string.Empty; using (var streamReader = new StreamReader(xmlFile.FullName, Encoding.UTF8)) { // Use XmlReader for best performance using (var reader = XmlReader.Create(streamReader, new XmlReaderSettings { CheckCharacters = false, IgnoreProcessingInstructions = true, IgnoreComments = true, ValidationType = ValidationType.None })) { reader.MoveToContent(); // Loop through each element while (reader.Read()) { cancellationToken.ThrowIfCancellationRequested(); if (reader.NodeType == XmlNodeType.Element) { switch (reader.Name) { case "thumb_width": { var val = reader.ReadElementContentAsString(); if (!string.IsNullOrWhiteSpace(val)) { int rval; // int.TryParse is local aware, so it can be probamatic, force us culture if (int.TryParse(val, NumberStyles.Integer, _usCulture, out rval)) { width = rval; } } break; } case "thumb_height": { var val = reader.ReadElementContentAsString(); if (!string.IsNullOrWhiteSpace(val)) { int rval; // int.TryParse is local aware, so it can be probamatic, force us culture if (int.TryParse(val, NumberStyles.Integer, _usCulture, out rval)) { height = rval; } } break; } case "filename": { var val = reader.ReadElementContentAsString(); if (!string.IsNullOrWhiteSpace(val)) { url = TVUtils.BannerUrl + val; } break; } default: reader.Skip(); break; } } } } } if (string.IsNullOrEmpty(url)) { return null; } return new RemoteImageInfo { Width = width, Height = height, ProviderName = Name, Url = url, Type = ImageType.Primary }; } public int Order { get { return 0; } } public Task GetImageResponse(string url, CancellationToken cancellationToken) { return _httpClient.GetResponse(new HttpRequestOptions { CancellationToken = cancellationToken, Url = url, ResourcePool = TvdbSeriesProvider.Current.TvDbResourcePool }); } public bool HasChanged(IHasMetadata item, IDirectoryService directoryService, DateTime date) { var episode = (Episode)item; if (!episode.IsVirtualUnaired) { // For non-unaired items, only enable if configured if (!_config.Configuration.EnableTvDbUpdates) { return false; } } if (!item.HasImage(ImageType.Primary)) { var series = episode.Series; var seriesId = series != null ? series.GetProviderId(MetadataProviders.Tvdb) : null; if (!string.IsNullOrEmpty(seriesId)) { // Process images var seriesDataPath = TvdbSeriesProvider.GetSeriesDataPath(_config.ApplicationPaths, seriesId); var files = TvdbEpisodeProvider.Current.GetEpisodeXmlFiles(episode.ParentIndexNumber, episode.IndexNumber, episode.IndexNumberEnd, seriesDataPath); return files.Any(i => _fileSystem.GetLastWriteTimeUtc(i) > date); } } return false; } } }