From 46da6577407c998fd6ece7589cd3340d4a8bc010 Mon Sep 17 00:00:00 2001
From: Mark McDowall <mark@mcdowall.ca>
Date: Thu, 8 Apr 2021 17:36:24 -0700
Subject: [PATCH] Handle events asynchronously for notifications

Fixed: Slow notification sending slowing down imports
Closes #4348
---
 .../Notifications/NotificationService.cs      | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/NzbDrone.Core/Notifications/NotificationService.cs b/src/NzbDrone.Core/Notifications/NotificationService.cs
index df520c1b8..08db00a83 100644
--- a/src/NzbDrone.Core/Notifications/NotificationService.cs
+++ b/src/NzbDrone.Core/Notifications/NotificationService.cs
@@ -15,12 +15,12 @@ using NzbDrone.Core.Tv.Events;
 namespace NzbDrone.Core.Notifications
 {
     public class NotificationService
-        : IHandle<EpisodeGrabbedEvent>,
-          IHandle<EpisodeImportedEvent>,
-          IHandle<SeriesRenamedEvent>,
-          IHandle<SeriesDeletedEvent>,
-          IHandle<EpisodeFileDeletedEvent>,
-          IHandle<HealthCheckFailedEvent>,
+        : IHandleAsync<EpisodeGrabbedEvent>,
+          IHandleAsync<EpisodeImportedEvent>,
+          IHandleAsync<SeriesRenamedEvent>,
+          IHandleAsync<SeriesDeletedEvent>,
+          IHandleAsync<EpisodeFileDeletedEvent>,
+          IHandleAsync<HealthCheckFailedEvent>,
           IHandleAsync<DeleteCompletedEvent>,
           IHandleAsync<DownloadsProcessedEvent>,
           IHandleAsync<RenameCompletedEvent>,
@@ -109,7 +109,7 @@ namespace NzbDrone.Core.Notifications
             return false;
         }
 
-        public void Handle(EpisodeGrabbedEvent message)
+        public void HandleAsync(EpisodeGrabbedEvent message)
         {
             var grabMessage = new GrabMessage
             {
@@ -136,7 +136,7 @@ namespace NzbDrone.Core.Notifications
             }
         }
 
-        public void Handle(EpisodeImportedEvent message)
+        public void HandleAsync(EpisodeImportedEvent message)
         {
             if (!message.NewDownload)
             {
@@ -174,7 +174,7 @@ namespace NzbDrone.Core.Notifications
             }
         }
 
-        public void Handle(SeriesRenamedEvent message)
+        public void HandleAsync(SeriesRenamedEvent message)
         {
             foreach (var notification in _notificationFactory.OnRenameEnabled())
             {
@@ -193,7 +193,7 @@ namespace NzbDrone.Core.Notifications
             }
         }
 
-        public void Handle(EpisodeFileDeletedEvent message)
+        public void HandleAsync(EpisodeFileDeletedEvent message)
         {
             if (message.EpisodeFile.Episodes.Value.Empty())
             {
@@ -227,7 +227,7 @@ namespace NzbDrone.Core.Notifications
             }
         }
 
-        public void Handle(SeriesDeletedEvent message)
+        public void HandleAsync(SeriesDeletedEvent message)
         {
             var deleteMessage = new SeriesDeleteMessage(message.Series,message.DeleteFiles);
 
@@ -247,7 +247,7 @@ namespace NzbDrone.Core.Notifications
             }
         }
 
-        public void Handle(HealthCheckFailedEvent message)
+        public void HandleAsync(HealthCheckFailedEvent message)
         {
             foreach (var notification in _notificationFactory.OnHealthIssueEnabled())
             {