using System; using System.Collections.Generic; using System.Net; using FluentValidation.Results; using NLog; using NzbDrone.Common.EnvironmentInfo; using NzbDrone.Common.Http; using NzbDrone.Core.Localization; namespace NzbDrone.Core.Notifications.Prowl { public interface IProwlProxy { void SendNotification(string title, string message, ProwlSettings settings); ValidationFailure Test(ProwlSettings settings); } public class ProwlProxy : IProwlProxy { private const string PUSH_URL = "https://api.prowlapp.com/publicapi/add"; private readonly IHttpClient _httpClient; private readonly ILocalizationService _localizationService; private readonly Logger _logger; public ProwlProxy(IHttpClient httpClient, ILocalizationService localizationService, Logger logger) { _httpClient = httpClient; _localizationService = localizationService; _logger = logger; } public void SendNotification(string title, string message, ProwlSettings settings) { try { var requestBuilder = new HttpRequestBuilder(PUSH_URL); var request = requestBuilder.Post() .AddFormParameter("apikey", settings.ApiKey) .AddFormParameter("application", BuildInfo.AppName) .AddFormParameter("event", title) .AddFormParameter("description", message) .AddFormParameter("priority", settings.Priority) .Build(); _httpClient.Post(request); } catch (HttpException ex) { if (ex.Response.StatusCode == HttpStatusCode.Unauthorized) { _logger.Error(ex, "Apikey is invalid: {0}", settings.ApiKey); throw new ProwlException("Apikey is invalid", ex); } throw new ProwlException("Unable to send text message: " + ex.Message, ex); } catch (WebException ex) { throw new ProwlException("Failed to connect to prowl, please check your settings.", ex); } } public ValidationFailure Test(ProwlSettings settings) { try { const string title = "Test Notification"; const string body = "This is a test message from Radarr"; SendNotification(title, body, settings); } catch (Exception ex) { return new ValidationFailure("ApiKey", _localizationService.GetLocalizedString("NotificationsValidationUnableToSendTestMessage", new Dictionary { { "exceptionMessage", ex.Message } })); } return null; } } }