#region Copyright // /************************************************************************ // Copyright (c) 2016 Jamie Rees // File: TheMovieDbApi.cs // Created By: Jamie Rees // // Permission is hereby granted, free of charge, to any person obtaining // a copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to // permit persons to whom the Software is furnished to do so, subject to // the following conditions: // // The above copyright notice and this permission notice shall be // included in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // ************************************************************************/ #endregion using System; using System.Collections.Generic; using System.Threading.Tasks; using NLog; using NLog.Fluent; using Ombi.Api.Models.Movie; using RestSharp; using TMDbLib.Client; using TMDbLib.Objects.General; using TMDbLib.Objects.Movies; using TMDbLib.Objects.Search; using Movie = TMDbLib.Objects.Movies.Movie; using TMDbLib.Objects.People; using System.Linq; namespace Ombi.Api { public class TheMovieDbApi : MovieBase { public TheMovieDbApi() { Client = new TMDbClient(ApiKey); Api = new ApiRequest(); } private ApiRequest Api { get; } public TMDbClient Client { get; set; } private const string BaseUrl = "https://api.themoviedb.org/3/"; private static Logger Log = LogManager.GetCurrentClassLogger(); public async Task> SearchMovie(string searchTerm) { var results = await Client.SearchMovie(searchTerm); return results?.Results ?? new List(); } public async Task> GetCurrentPlayingMovies() { var movies = await Client.GetMovieList(MovieListType.NowPlaying); return movies?.Results ?? new List(); } public async Task> GetUpcomingMovies() { var movies = await Client.GetMovieList(MovieListType.Upcoming); return movies?.Results ?? new List(); } private async Task GetMovie(int id) { return await Client.GetMovie(id); } public TmdbMovieDetails GetMovieInformationWithVideos(int tmdbId) { var request = new RestRequest { Resource = "movie/{movieId}", Method = Method.GET }; request.AddUrlSegment("movieId", tmdbId.ToString()); request.AddQueryParameter("api_key", ApiKey); request.AddQueryParameter("append_to_response", "videos"); // Get the videos try { var obj = Api.ExecuteJson(request, new Uri(BaseUrl)); return obj; } catch (Exception e) { Log.Error(e); return null; } } public async Task GetMovieInformation(int tmdbId) { var movies = await Client.GetMovie(tmdbId); return movies; } public async Task GetMovieInformation(string imdbId) { var movies = await Client.GetMovie(imdbId); return movies ?? new Movie(); } public async Task> SearchPerson(string searchTerm) { return await SearchPerson(searchTerm, null); } public async Task> SearchPerson(string searchTerm, Func> alreadyAvailable) { SearchContainer result = await Client.SearchPerson(searchTerm); var people = result?.Results ?? new List(); var person = (people.Count != 0 ? people[0] : null); var movies = new List(); var counter = 0; try { if (person != null) { var credits = await Client.GetPersonMovieCredits(person.Id); // grab results from both cast and crew, prefer items in cast. we can handle directors like this. List movieResults = (from MovieRole role in credits.Cast select new Movie() { Id = role.Id, Title = role.Title, ReleaseDate = role.ReleaseDate }).ToList(); movieResults.AddRange((from MovieJob job in credits.Crew select new Movie() { Id = job.Id, Title = job.Title, ReleaseDate = job.ReleaseDate }).ToList()); //only get the first 10 movies and delay a bit between each request so we don't overload the API foreach (var m in movieResults) { if (counter == 10) break; if (alreadyAvailable == null || !(await alreadyAvailable(m.Id, m.Title, m.ReleaseDate.Value.Year.ToString()))) { movies.Add(await GetMovie(m.Id)); counter++; } await Task.Delay(50); } } } catch (Exception e) { Log.Log(LogLevel.Error, e); } return movies; } } }