42 lines
1.1 KiB
C#
42 lines
1.1 KiB
C#
|
using NzbDrone.Common.Http;
|
|||
|
|
using NzbDrone.Common.Serializer;
|
|||
|
|
using NzbDrone.Core.Rest;
|
|||
|
|
|
|||
|
|
namespace NzbDrone.Core.Notifications.Webhook
|
|||
|
|
{
|
|||
|
|
public interface IWebhookProxy
|
|||
|
|
{
|
|||
|
|
void SendWebhook(WebhookPayload payload, WebhookSettings settings);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public class WebhookProxy : IWebhookProxy
|
|||
|
|
{
|
|||
|
|
private readonly IHttpClient _httpClient;
|
|||
|
|
|
|||
|
|
public WebhookProxy(IHttpClient httpClient)
|
|||
|
|
{
|
|||
|
|
_httpClient = httpClient;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void SendWebhook(WebhookPayload body, WebhookSettings settings)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var request = new HttpRequestBuilder(settings.Url)
|
|||
|
|
.Accept(HttpAccept.Json)
|
|||
|
|
.Build();
|
|||
|
|
|
|||
|
|
request.Method = (HttpMethod)settings.Method;
|
|||
|
|
request.Headers.ContentType = "application/json";
|
|||
|
|
request.SetContent(body.ToJson());
|
|||
|
|
|
|||
|
|
_httpClient.Execute(request);
|
|||
|
|
}
|
|||
|
|
catch (RestException ex)
|
|||
|
|
{
|
|||
|
|
throw new WebhookException("Unable to post to webhook: {0}", ex, ex.Message);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|