Files
Readarr/src/NzbDrone.Core/Notifications/Webhook/Webhook.cs
T
nitsua 0672fc7b85 Custom Notification cleanup
- Renamed event "BookDownload" to "Download" to match sonarr/radarr
- Renamed "TrackRetag" to "BookRetag" (Lidarr leftovers)
2020-10-10 16:16:43 -04:00

127 lines
3.8 KiB
C#

using System.Collections.Generic;
using System.Linq;
using FluentValidation.Results;
using NzbDrone.Common.Extensions;
using NzbDrone.Core.Books;
using NzbDrone.Core.Validation;
namespace NzbDrone.Core.Notifications.Webhook
{
public class Webhook : NotificationBase<WebhookSettings>
{
private readonly IWebhookProxy _proxy;
public Webhook(IWebhookProxy proxy)
{
_proxy = proxy;
}
public override string Link => "https://github.com/Readarr/Readarr/wiki/Webhook";
public override void OnGrab(GrabMessage message)
{
var remoteBook = message.Book;
var quality = message.Quality;
var payload = new WebhookGrabPayload
{
EventType = "Grab",
Author = new WebhookAuthor(message.Author),
Books = remoteBook.Books.ConvertAll(x => new WebhookBook(x)
{
// TODO: Stop passing these parameters inside an album v3
Quality = quality.Quality.Name,
QualityVersion = quality.Revision.Version,
ReleaseGroup = remoteBook.ParsedBookInfo.ReleaseGroup
}),
Release = new WebhookRelease(quality, remoteBook)
};
_proxy.SendWebhook(payload, Settings);
}
public override void OnReleaseImport(BookDownloadMessage message)
{
var bookFiles = message.BookFiles;
var payload = new WebhookImportPayload
{
EventType = "Download",
Author = new WebhookAuthor(message.Author),
Book = new WebhookBook(message.Book),
BookFiles = bookFiles.ConvertAll(x => new WebhookBookFile(x)),
IsUpgrade = message.OldFiles.Any()
};
_proxy.SendWebhook(payload, Settings);
}
public override void OnRename(Author author)
{
var payload = new WebhookPayload
{
EventType = "Rename",
Author = new WebhookAuthor(author)
};
_proxy.SendWebhook(payload, Settings);
}
public override void OnBookRetag(BookRetagMessage message)
{
var payload = new WebhookPayload
{
EventType = "Retag",
Author = new WebhookAuthor(message.Author)
};
_proxy.SendWebhook(payload, Settings);
}
public override string Name => "Webhook";
public override ValidationResult Test()
{
var failures = new List<ValidationFailure>();
failures.AddIfNotNull(SendWebhookTest());
return new ValidationResult(failures);
}
private ValidationFailure SendWebhookTest()
{
try
{
var payload = new WebhookGrabPayload
{
EventType = "Test",
Author = new WebhookAuthor()
{
Id = 1,
Name = "Test Name",
Path = "C:\\testpath",
MBId = "aaaaa-aaa-aaaa-aaaaaa"
},
Books = new List<WebhookBook>()
{
new WebhookBook()
{
Id = 123,
Title = "Test title"
}
}
};
_proxy.SendWebhook(payload, Settings);
}
catch (WebhookException ex)
{
return new NzbDroneValidationFailure("Url", ex.Message);
}
return null;
}
}
}