Push API

Author: tpeczek

.gitignore

@@ -221,6 +221,9 @@ UpgradeLog*.htm
 *.ldf
 *.ndf
 
+# SQLite files
+*.db
+
 # Business Intelligence projects
 *.rdl.data
 *.bim.layout

Demo.AspNetCore.PushNotifications.Services.Abstractions/Demo.AspNetCore.PushNotifications.Services.Abstractions.csproj

@@ -0,0 +1,7 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+</Project>

Demo.AspNetCore.PushNotifications.Services.Abstractions/IPushNotificationService.cs

@@ -0,0 +1,9 @@
+namespace Demo.AspNetCore.PushNotifications.Services.Abstractions
+{
+    public interface IPushNotificationService
+    {
+        string PublicKey { get; }
+
+        void SendNotification(PushSubscription subscription, string payload);
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Abstractions/IPushSubscriptionStore.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Threading.Tasks;
+
+namespace Demo.AspNetCore.PushNotifications.Services.Abstractions
+{
+    public interface IPushSubscriptionStore
+    {
+        Task StoreSubscriptionAsync(PushSubscription subscription);
+
+        Task DiscardSubscriptionAsync(string endpoint);
+
+        Task ForEachSubscriptionAsync(Action<PushSubscription> action);
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Abstractions/PushEncryptionKeyName.cs

@@ -0,0 +1,8 @@
+namespace Demo.AspNetCore.PushNotifications.Services.Abstractions
+{
+    public enum PushEncryptionKeyName
+    {
+        P256DH,
+        Auth
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Abstractions/PushNotificationServiceOptions.cs

@@ -0,0 +1,11 @@
+namespace Demo.AspNetCore.PushNotifications.Services.Abstractions
+{
+    public class PushNotificationServiceOptions
+    {
+        public string Subject { get; set; }
+
+        public string PublicKey { get; set; }
+
+        public string PrivateKey { get; set; }
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Abstractions/PushSubscription.cs

@@ -0,0 +1,43 @@
+using System.Collections.Generic;
+
+namespace Demo.AspNetCore.PushNotifications.Services.Abstractions
+{
+    public class PushSubscription
+    {
+        public string Endpoint { get; set; }
+
+        public IDictionary<string, string> Keys { get; set; }
+
+        public string GetKey(PushEncryptionKeyName keyName)
+        {
+            string key = null;
+
+            if (Keys != null)
+            {
+                string keyNameStringified = StringifyKeyName(keyName);
+
+                if (Keys.ContainsKey(keyNameStringified))
+                {
+                    key = Keys[keyNameStringified];
+                }
+            }
+
+            return key;
+        }
+
+        public void SetKey(PushEncryptionKeyName keyName, string key)
+        {
+            if (Keys == null)
+            {
+                Keys = new Dictionary<string, string>();
+            }
+
+            Keys[StringifyKeyName(keyName)] = key;
+        }
+
+        private string StringifyKeyName(PushEncryptionKeyName keyName)
+        {
+            return keyName.ToString().ToLowerInvariant();
+        }
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Sqlite/Demo.AspNetCore.PushNotifications.Services.Sqlite.csproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.Http.Abstractions" Version="2.0.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="2.0.1" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Demo.AspNetCore.PushNotifications.Services.Abstractions\Demo.AspNetCore.PushNotifications.Services.Abstractions.csproj" />
+  </ItemGroup>
+
+</Project>

Demo.AspNetCore.PushNotifications.Services.Sqlite/PushSubscriptionContext.cs

@@ -0,0 +1,47 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace Demo.AspNetCore.PushNotifications.Services.Sqlite
+{
+    internal class PushSubscriptionContext : DbContext
+    {
+        public class PushSubscription : Abstractions.PushSubscription
+        {
+            public string P256DH
+            {
+                get { return GetKey(Abstractions.PushEncryptionKeyName.P256DH); }
+
+                set { SetKey(Abstractions.PushEncryptionKeyName.P256DH, value); }
+            }
+
+            public string Auth
+            {
+                get { return GetKey(Abstractions.PushEncryptionKeyName.Auth); }
+
+                set { SetKey(Abstractions.PushEncryptionKeyName.Auth, value); }
+            }
+
+            public PushSubscription()
+            { }
+
+            public PushSubscription(Abstractions.PushSubscription subscription)
+            {
+                Endpoint = subscription.Endpoint;
+                Keys = subscription.Keys;
+            }
+        }
+
+        public DbSet<PushSubscription> Subscriptions { get; set; }
+
+        public PushSubscriptionContext(DbContextOptions<PushSubscriptionContext> options)
+            : base(options)
+        { }
+
+        protected override void OnModelCreating(ModelBuilder modelBuilder)
+        {
+            EntityTypeBuilder<PushSubscription> pushSubscriptionEntityTypeBuilder = modelBuilder.Entity<PushSubscription>();
+            pushSubscriptionEntityTypeBuilder.HasKey(e => e.Endpoint);
+            pushSubscriptionEntityTypeBuilder.Ignore(p => p.Keys);
+        }
+    }
+}

Demo.AspNetCore.PushNotifications.Services.Sqlite/SqliteApplicationBuilderExtensions.cs

@@ -0,0 +1,19 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Demo.AspNetCore.PushNotifications.Services.Sqlite
+{
+    public static class SqliteApplicationBuilderExtensions
+    {
+        public static IApplicationBuilder UseSqlitePushSubscriptionStore(this IApplicationBuilder app)
+        {
+            using (var serviceScope = app.ApplicationServices.GetRequiredService<IServiceScopeFactory>().CreateScope())
+            {
+                PushSubscriptionContext context = serviceScope.ServiceProvider.GetService<PushSubscriptionContext>();
+                context.Database.EnsureCreated();
+            }
+
+            return app;
+        }
+    }
+}