using MediaBrowser.Common.Net; using MediaBrowser.Controller.Channels; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities.Movies; using MediaBrowser.Controller.LiveTv; using MediaBrowser.Controller.Providers; using MediaBrowser.Model.Channels; using MediaBrowser.Model.Dto; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Providers; using MediaBrowser.Model.Serialization; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Providers.Movies { class MovieDbImageProvider : IRemoteImageProvider, IHasOrder, IHasChangeMonitor { private readonly IJsonSerializer _jsonSerializer; private readonly IHttpClient _httpClient; public MovieDbImageProvider(IJsonSerializer jsonSerializer, IHttpClient httpClient) { _jsonSerializer = jsonSerializer; _httpClient = httpClient; } public string Name { get { return ProviderName; } } public static string ProviderName { get { return "TheMovieDb"; } } public bool Supports(IHasImages item) { var channelItem = item as ChannelVideoItem; if (channelItem != null && channelItem.ContentType == ChannelMediaContentType.MovieExtra && channelItem.ExtraType == ExtraType.Trailer) { return true; } // Supports images for tv movies var tvProgram = item as LiveTvProgram; if (tvProgram != null && tvProgram.IsMovie) { return true; } // Don't support local trailers return item is Movie || item is MusicVideo; } public IEnumerable GetSupportedImages(IHasImages item) { var channelItem = item as ChannelVideoItem; if (channelItem != null) { // Too many channel items to allow backdrops here return new List { ImageType.Primary }; } return new List { ImageType.Primary, ImageType.Backdrop }; } public async Task> GetImages(IHasImages item, CancellationToken cancellationToken) { var list = new List(); var results = await FetchImages((BaseItem)item, _jsonSerializer, cancellationToken).ConfigureAwait(false); if (results == null) { return list; } var tmdbSettings = await MovieDbProvider.Current.GetTmdbSettings(cancellationToken).ConfigureAwait(false); var tmdbImageUrl = tmdbSettings.images.base_url + "original"; var supportedImages = GetSupportedImages(item).ToList(); if (supportedImages.Contains(ImageType.Primary)) { list.AddRange(GetPosters(results).Select(i => new RemoteImageInfo { Url = tmdbImageUrl + i.file_path, CommunityRating = i.vote_average, VoteCount = i.vote_count, Width = i.width, Height = i.height, Language = i.iso_639_1, ProviderName = Name, Type = ImageType.Primary, RatingType = RatingType.Score })); } if (supportedImages.Contains(ImageType.Backdrop)) { list.AddRange(GetBackdrops(results).Select(i => new RemoteImageInfo { Url = tmdbImageUrl + i.file_path, CommunityRating = i.vote_average, VoteCount = i.vote_count, Width = i.width, Height = i.height, ProviderName = Name, Type = ImageType.Backdrop, RatingType = RatingType.Score })); } var language = item.GetPreferredMetadataLanguage(); var isLanguageEn = string.Equals(language, "en", StringComparison.OrdinalIgnoreCase); return list.OrderByDescending(i => { if (string.Equals(language, i.Language, StringComparison.OrdinalIgnoreCase)) { return 3; } if (!isLanguageEn) { if (string.Equals("en", i.Language, StringComparison.OrdinalIgnoreCase)) { return 2; } } if (string.IsNullOrEmpty(i.Language)) { return isLanguageEn ? 3 : 2; } return 0; }) .ThenByDescending(i => i.CommunityRating ?? 0) .ThenByDescending(i => i.VoteCount ?? 0) .ToList(); } /// /// Gets the posters. /// /// The images. /// IEnumerable{MovieDbProvider.Poster}. private IEnumerable GetPosters(MovieDbProvider.Images images) { return images.posters ?? new List(); } /// /// Gets the backdrops. /// /// The images. /// IEnumerable{MovieDbProvider.Backdrop}. private IEnumerable GetBackdrops(MovieDbProvider.Images images) { var eligibleBackdrops = images.backdrops == null ? new List() : images.backdrops .ToList(); return eligibleBackdrops.OrderByDescending(i => i.vote_average) .ThenByDescending(i => i.vote_count); } /// /// Fetches the images. /// /// The item. /// The json serializer. /// The cancellation token. /// Task{MovieImages}. private async Task FetchImages(BaseItem item, IJsonSerializer jsonSerializer, CancellationToken cancellationToken) { var tmdbId = item.GetProviderId(MetadataProviders.Tmdb); var language = item.GetPreferredMetadataLanguage(); if (string.IsNullOrEmpty(tmdbId)) { return null; } await MovieDbProvider.Current.EnsureMovieInfo(tmdbId, language, cancellationToken).ConfigureAwait(false); var path = MovieDbProvider.Current.GetDataFilePath(tmdbId, language); if (!string.IsNullOrEmpty(path)) { var fileInfo = new FileInfo(path); if (fileInfo.Exists) { return jsonSerializer.DeserializeFromFile(path).images; } } return null; } public int Order { get { return 0; } } public Task GetImageResponse(string url, CancellationToken cancellationToken) { return _httpClient.GetResponse(new HttpRequestOptions { CancellationToken = cancellationToken, Url = url, ResourcePool = MovieDbProvider.Current.MovieDbResourcePool }); } public bool HasChanged(IHasMetadata item, IDirectoryService directoryService, DateTime date) { return MovieDbProvider.Current.HasChanged(item, date); } } }