Notifications (#75)

Support for browser notifications

Author: jgauffin

src/Server/Coderr.Server.Api/Core/Users/Commands/DeleteBrowserSubscription.cs

@@ -0,0 +1,9 @@
+namespace Coderr.Server.Api.Core.Users.Commands
+{
+    [Message]
+    public class DeleteBrowserSubscription
+    {
+        public int UserId { get; set; }
+        public string Endpoint { get; set; }
+    }
+}

src/Server/Coderr.Server.Api/Core/Users/Commands/StoreBrowserSubscription.cs

@@ -0,0 +1,17 @@
+namespace Coderr.Server.Api.Core.Users.Commands
+{
+    /// <summary>
+    /// https://tools.ietf.org/html/draft-ietf-webpush-encryption-08
+    /// </summary>
+    [Message]
+    public class StoreBrowserSubscription
+    {
+        public int UserId { get; set; }
+        public string Endpoint { get; set; }
+
+        public string PublicKey { get; set; }
+        public string AuthenticationSecret { get; set; }
+
+        public int? ExpirationTime { get; set; }
+    }
+}

src/Server/Coderr.Server.Api/Core/Users/Commands/UpdateNotifications.cs

@@ -16,11 +16,6 @@ public class UpdateNotifications
         /// </summary>
         public NotificationState NotifyOnNewIncidents { get; set; }
 
-        /// <summary>
-        ///     How to notify when a new report is created (receive an exception)
-        /// </summary>
-        public NotificationState NotifyOnNewReport { get; set; }
-
         /// <summary>
         ///     How to notify user when a peak is detected
         /// </summary>
@@ -36,6 +31,7 @@ public class UpdateNotifications
         /// </summary>
         public NotificationState NotifyOnUserFeedback { get; set; }
 
+        
         /// <summary>
         ///     User that configured its settings.
         /// </summary>

src/Server/Coderr.Server.Api/Core/Users/NotificationSettings.cs

@@ -12,11 +12,6 @@ public class NotificationSettings
         /// </summary>
         public NotificationState NotifyOnNewIncidents { get; set; }
 
-        /// <summary>
-        ///     How to notify when a new report is created (receive an exception)
-        /// </summary>
-        public NotificationState NotifyOnNewReport { get; set; }
-
         /// <summary>
         ///     How to notify user when a peak is detected
         /// </summary>

src/Server/Coderr.Server.Api/Core/Users/NotificationState.cs

@@ -8,21 +8,26 @@ public enum NotificationState
         /// <summary>
         ///     Use global setting
         /// </summary>
-        UseGlobalSetting,
+        UseGlobalSetting = 1,
 
         /// <summary>
         ///     Do not notify
         /// </summary>
-        Disabled,
+        Disabled = 2,
 
         /// <summary>
         ///     By cellphone (text message)
         /// </summary>
-        Cellphone,
+        Cellphone = 3,
 
         /// <summary>
         ///     By email
         /// </summary>
-        Email
+        Email = 4,
+
+        /// <summary>
+        /// Use browser/desktop notifications.
+        /// </summary>
+        BrowserNotification = 5
     }
 }

src/Server/Coderr.Server.App/Core/Notifications/Commands/DeleteBrowserSubscriptionHandler.cs

@@ -0,0 +1,21 @@
+using System.Threading.Tasks;
+using Coderr.Server.Api.Core.Users.Commands;
+using DotNetCqs;
+
+namespace Coderr.Server.App.Core.Notifications.Commands
+{
+    internal class DeleteBrowserSubscriptionHandler : IMessageHandler<DeleteBrowserSubscription>
+    {
+        private readonly INotificationsRepository _repository;
+
+        public DeleteBrowserSubscriptionHandler(INotificationsRepository repository)
+        {
+            _repository = repository;
+        }
+
+        public async Task HandleAsync(IMessageContext context, DeleteBrowserSubscription message)
+        {
+            await _repository.DeleteBrowserSubscription(message.UserId, message.Endpoint);
+        }
+    }
+}

src/Server/Coderr.Server.App/Core/Notifications/Commands/StoreBrowserSubscriptionHandler.cs

@@ -0,0 +1,34 @@
+using System;
+using System.Threading.Tasks;
+using Coderr.Server.Abstractions.Security;
+using Coderr.Server.Api.Core.Users.Commands;
+using Coderr.Server.Domain.Modules.UserNotifications;
+using DotNetCqs;
+
+namespace Coderr.Server.App.Core.Notifications.Commands
+{
+    internal class StoreBrowserSubscriptionHandler : IMessageHandler<StoreBrowserSubscription>
+    {
+        private readonly INotificationsRepository _notificationsRepository;
+
+        public StoreBrowserSubscriptionHandler(INotificationsRepository notificationsRepository)
+        {
+            _notificationsRepository = notificationsRepository;
+        }
+
+        public async Task HandleAsync(IMessageContext context, StoreBrowserSubscription message)
+        {
+            var subscription = new BrowserSubscription
+            {
+                AccountId = context.Principal.GetAccountId(),
+                AuthenticationSecret = message.AuthenticationSecret,
+                Endpoint = message.Endpoint,
+                PublicKey = message.PublicKey,
+                ExpiresAtUtc = message.ExpirationTime == null
+                    ? (DateTime?) null
+                    : DateTime.UtcNow.AddMilliseconds(message.ExpirationTime.Value)
+            };
+            await _notificationsRepository.Save(subscription);
+        }
+    }
+}

src/Server/Coderr.Server.App/Core/Notifications/INotificationsRepository.cs

@@ -2,12 +2,13 @@
 using System.Collections.Generic;
 using System.Diagnostics.CodeAnalysis;
 using System.Threading.Tasks;
+using Coderr.Server.Api.Core.Users.Commands;
 using Coderr.Server.Domain.Modules.UserNotifications;
 
 namespace Coderr.Server.App.Core.Notifications
 {
     /// <summary>
-    ///     Repository for notification settings
+    ///     Repository for managing notification settings
     /// </summary>
     public interface INotificationsRepository
     {
@@ -45,5 +46,8 @@ public interface INotificationsRepository
         /// <returns>task</returns>
         /// <exception cref="ArgumentNullException">notificationSettings</exception>
         Task UpdateAsync(UserNotificationSettings notificationSettings);
+
+        Task Save(BrowserSubscription message);
+        Task DeleteBrowserSubscription(int accountId, string endpoint);
     }
 }

src/Server/Coderr.Server.App/Core/Reports/Config/ReportConfig.cs

@@ -1,7 +1,5 @@
 using System.Collections.Generic;
 using Coderr.Server.Abstractions.Config;
-using Coderr.Server.Infrastructure.Configuration;
-//using Coderr.Server.ReportAnalyzer.Abstractions.ErrorReports;
 
 namespace Coderr.Server.App.Core.Reports.Config
 {

src/Server/Coderr.Server.App/Core/Reports/Jobs/DeleteReportsBelowReportLimit.cs

@@ -1,6 +1,4 @@
-using System;
 using System.Data;
-using System.Diagnostics;
 using Coderr.Server.Abstractions.Boot;
 using Coderr.Server.Abstractions.Config;
 using Coderr.Server.App.Core.Reports.Config;