Feature: Repository Monitor

Subscribe to be notified of database changes.

Disco.BI/BI/Interop/SignalRHandlers/RepositoryMonitorNotifications.cs

@@ -0,0 +1,37 @@
+using Disco.Data.Repository.Monitor;
+using SignalR;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Disco.BI.Interop.SignalRHandlers
+{
+    public class RepositoryMonitorNotifications : PersistentConnection
+    {
+        public static void Initialize()
+        {
+            RepositoryMonitor.StreamAfterCommit.Subscribe(AfterCommit);
+        }
+
+        protected override System.Threading.Tasks.Task OnReceivedAsync(IRequest request, string connectionId, string data)
+        {
+            // Add to Group
+            if (!string.IsNullOrWhiteSpace(data) && data.StartsWith("/addToGroups:") && data.Length > 13)
+            {
+                var groups = data.Substring(13).Split(',');
+                foreach (var g in groups)
+                {
+                    this.Groups.Add(connectionId, g);
+                }
+            }
+            return base.OnReceivedAsync(request, connectionId, data);
+        }
+
+        private static void AfterCommit(RepositoryMonitorEvent e)
+        {
+            GlobalHost.ConnectionManager.GetConnectionContext<RepositoryMonitorNotifications>().Groups.Send(e.EntityType.Name, e);
+        }
+    }
+}