From 371684e5108fdde086c4ede4fafcebd74c95d27b Mon Sep 17 00:00:00 2001 From: John Cardinal Date: Thu, 16 Jul 2020 23:48:56 +0000 Subject: [PATCH] --- server/AyaNova/biz/NotifyEventProcessor.cs | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/server/AyaNova/biz/NotifyEventProcessor.cs b/server/AyaNova/biz/NotifyEventProcessor.cs index 167403e8..6bb52d97 100644 --- a/server/AyaNova/biz/NotifyEventProcessor.cs +++ b/server/AyaNova/biz/NotifyEventProcessor.cs @@ -83,10 +83,15 @@ namespace AyaNova.Biz } - //check subscriptions for event and send accordingly - var subs = ct.NotifySubscription.Where(z => z.EventType == eventType) - - + //check subscriptions for event and send accordingly to each user + var subs = await ct.NotifySubscription.Where(z => z.EventType == eventType).ToListAsync(); + foreach (var sub in subs) + { + NotifyEvent n = new NotifyEvent() { EventType = eventType, UserId = sub.UserId, Message = message, SubscriptionId = sub.Id }; + await ct.NotifyEvent.AddAsync(n); + } + if (subs.Count > 0) + await ct.SaveChangesAsync(); } }