added dbo in notifications filters; made hub connection tracker thread safe

Luticate2.Utils/Business/LuCrudBusiness.cs

@@ -23,6 +23,12 @@ namespace Luticate2.Utils.Business
 
         protected virtual string EntityType { get; set; }
 
+        protected virtual Func<string, TDboRead, bool> NotifyCreateFilter { get; set; }
+
+        protected virtual Func<string, TDboRead, TDboRead, bool> NotifyUpdateFilter { get; set; }
+
+        protected virtual Func<string, TDboRead, bool> NotifyDeleteFilter { get; set; }
+
         protected LuCrudBusiness(TDataAccess dataAccess, LuNotificationsBusiness notificationsBusiness)
         {
             DataAccess = dataAccess;
@@ -87,7 +93,8 @@ namespace Luticate2.Utils.Business
             var newEntity = DataAccess.AddDbo(res.Data);
             if (newEntity)
             {
-                _notificationsBusiness.NotifyCreate(EntityType, newEntity.Data);
+                _notificationsBusiness.NotifyCreate(EntityType, newEntity.Data,
+                    s => NotifyCreateFilter(s, newEntity.Data));
                 return LuResult<T>.Ok(returnFunc(newEntity.Data));
             }
             return newEntity.To<T>();
@@ -153,7 +160,8 @@ namespace Luticate2.Utils.Business
             var editedEntity = DataAccess.EditSingleByIdDbo(id, obj.Data);
             if (editedEntity)
             {
-                _notificationsBusiness.NotifyUpdate(EntityType, originalEntity.Data, editedEntity.Data);
+                _notificationsBusiness.NotifyUpdate(EntityType, originalEntity.Data, editedEntity.Data,
+                    s => NotifyUpdateFilter(s, originalEntity.Data, editedEntity.Data));
                 return LuResult<T>.Ok(returnFunc(editedEntity.Data));
             }
             return editedEntity.To<T>();
@@ -182,7 +190,8 @@ namespace Luticate2.Utils.Business
             var res = DataAccess.DeleteSingleById(id, returnFunc);
             if (res)
             {
-                _notificationsBusiness.NotifyDelete(EntityType, originalEntity.Data);
+                _notificationsBusiness.NotifyDelete(EntityType, originalEntity.Data,
+                    s => NotifyDeleteFilter(s, originalEntity.Data));
             }
             return res;
         }

Luticate2.Utils/Hubs/LuHubConnectionTracker.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Threading;
 
 namespace Luticate2.Utils.Hubs
 {
@@ -7,8 +8,11 @@ namespace Luticate2.Utils.Hubs
     {
         protected IDictionary<string, IList<string>> ConnectionIds { get; set; }
 
+        protected Mutex Mutex;
+
         public LuHubConnectionTracker()
         {
+            Mutex = new Mutex();
             ConnectionIds = new Dictionary<string, IList<string>>();
         }
 
@@ -21,7 +25,9 @@ namespace Luticate2.Utils.Hubs
 
         public void Add(string name, string id)
         {
+            Mutex.WaitOne();
             GetReal(name).Add(id);
+            Mutex.ReleaseMutex();
         }
 
         public void Add(Type type, string id)
@@ -43,7 +49,9 @@ namespace Luticate2.Utils.Hubs
 
         public void Remove(string name, string id)
         {
+            Mutex.WaitOne();
             GetReal(name).Remove(id);
+            Mutex.ReleaseMutex();
         }
 
         public void Remove(Type type, string id)
@@ -74,7 +82,10 @@ namespace Luticate2.Utils.Hubs
 
         public IList<string> Get(string name)
         {
-            return new List<string>(GetReal(name));
+            Mutex.WaitOne();
+            var copy = new List<string>(GetReal(name));
+            Mutex.ReleaseMutex();
+            return copy;
         }
 
         public IList<string> Get(Type type)