using System.Collections.Generic; using System.Linq; using System.Net.Http; using System.Threading.Tasks; using Microsoft.Extensions.Logging; using Newtonsoft.Json; using Ombi.Api.Radarr.Models; using Ombi.Helpers; namespace Ombi.Api.Radarr { public class RadarrApi : IRadarrApi { public RadarrApi(ILogger logger, IApi api) { Api = api; Logger = logger; } private IApi Api { get; } private ILogger Logger { get; } public async Task> GetProfiles(string apiKey, string baseUrl) { var request = new Request("/api/profile", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request>(request); } public async Task> GetRootFolders(string apiKey, string baseUrl) { var request = new Request("/api/rootfolder", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request>(request); } public async Task SystemStatus(string apiKey, string baseUrl) { var request = new Request("/api/system/status", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request(request); } public async Task> GetMovies(string apiKey, string baseUrl) { var request = new Request("/api/movie", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request>(request); } public async Task GetMovie(int id, string apiKey, string baseUrl) { var request = new Request($"/api/movie/{id}", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request(request); } public async Task UpdateMovie(MovieResponse movie, string apiKey, string baseUrl) { var request = new Request($"/api/movie/", baseUrl, HttpMethod.Put); AddHeaders(request, apiKey); request.AddJsonBody(movie); return await Api.Request(request); } public async Task AddMovie(int tmdbId, string title, int year, int qualityId, string rootPath, string apiKey, string baseUrl, bool searchNow, string minimumAvailability) { var request = new Request("/api/movie", baseUrl, HttpMethod.Post); var options = new RadarrAddMovieResponse { title = title, tmdbId = tmdbId, qualityProfileId = qualityId, rootFolderPath = rootPath, titleSlug = title + year, monitored = true, year = year, minimumAvailability = minimumAvailability, sizeOnDisk = 0 }; if (searchNow) { options.addOptions = new RadarrAddOptions { searchForMovie = true }; } request.AddHeader("X-Api-Key", apiKey); request.AddJsonBody(options); var response = await Api.RequestContent(request); try { if (response.Contains("\"message\":")) { var error = JsonConvert.DeserializeObject(response); return new RadarrAddMovieResponse { Error = error }; } if (response.Contains("\"errorMessage\":")) { var error = JsonConvert.DeserializeObject>(response).FirstOrDefault(); return new RadarrAddMovieResponse { Error = new RadarrError { message = error?.errorMessage } }; } return JsonConvert.DeserializeObject(response); } catch (JsonSerializationException jse) { Logger.LogError(LoggingEvents.RadarrApi, jse, "Error When adding movie to Radarr, Reponse: {0}", response); } return null; } public async Task MovieSearch(int[] movieIds, string apiKey, string baseUrl) { var result = await Command(apiKey, baseUrl, new { name = "MoviesSearch", movieIds }); return result != null; } public async Task> GetTags(string apiKey, string baseUrl) { var request = new Request("/api/tag", baseUrl, HttpMethod.Get); AddHeaders(request, apiKey); return await Api.Request>(request); } private async Task Command(string apiKey, string baseUrl, object body) { var request = new Request($"/api/Command/", baseUrl, HttpMethod.Post); request.AddHeader("X-Api-Key", apiKey); request.AddJsonBody(body); return await Api.Request(request); } /// /// Adds the required headers and also the authorization header /// /// /// private void AddHeaders(Request request, string key) { request.AddHeader("X-Api-Key", key); } } }