github/Ombi
1
0
Fork 0
mirror of https://github.com/Ombi-app/Ombi.git synced 2025-07-07 13:41:13 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added Pushbullet notifications #8

Browse source
This commit is contained in:
tidusjar 2016-03-17 14:34:55 +00:00
parent b9a886d5dc
commit f046c5d39b
20 changed files with 534 additions and 61 deletions
Download patch file Download diff file Expand all files Collapse all files

12
PlexRequests.Services/Notification/NotificationService.cs
View file

@ -27,10 +27,16 @@
using System.Collections.Generic;
using System.Threading;
using NLog;
using PlexRequests.Helpers;
namespace PlexRequests.Services.Notification
{
public static class NotificationService
{
private static Logger Log = LogManager.GetCurrentClassLogger();
public static Dictionary<string, INotification> Observers { get; }
static NotificationService()
@ -40,6 +46,8 @@ namespace PlexRequests.Services.Notification
public static void Publish(string title, string requester)
{
Log.Trace("Notifying all observers: ");
Log.Trace(Observers.DumpJson());
foreach (var observer in Observers)
{
var notification = observer.Value;
@ -54,9 +62,11 @@ namespace PlexRequests.Services.Notification
public static void Subscribe(INotification notification)
{
Log.Trace("Subscribing Observer {0}", notification.NotificationName);
INotification notificationValue;
if (Observers.TryGetValue(notification.NotificationName, out notificationValue))
{
Log.Trace("Observer {0} already exists", notification.NotificationName);
// Observer already exists
return;
}
@ -66,9 +76,11 @@ namespace PlexRequests.Services.Notification
public static void UnSubscribe(INotification notification)
{
Log.Trace("Unsubscribing Observer {0}", notification.NotificationName);
INotification notificationValue;
if (!Observers.TryGetValue(notification.NotificationName, out notificationValue))
{
Log.Trace("Observer {0} doesn't exist to Unsubscribe", notification.NotificationName);
// Observer doesn't exists
return;
}