From a8c58e95ff942a2dc17946d206111f8df44ff5f3 Mon Sep 17 00:00:00 2001 From: CWX Date: Sun, 26 Jan 2025 16:48:53 +0000 Subject: [PATCH] finish off notificationService --- Libraries/Core/Services/NotificationService.cs | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/Libraries/Core/Services/NotificationService.cs b/Libraries/Core/Services/NotificationService.cs index 27c25554..b1c91755 100644 --- a/Libraries/Core/Services/NotificationService.cs +++ b/Libraries/Core/Services/NotificationService.cs @@ -8,19 +8,22 @@ public class NotificationService { protected Dictionary> _messageQueue = new(); - public Dictionary> GetMessageQueue() + public Dictionary> GetMessageQueue() { - throw new NotImplementedException(); + return _messageQueue; } - public List GetMessageFromQueue(string sessionId) + public List? GetMessageFromQueue(string sessionId) { - throw new NotImplementedException(); + return _messageQueue.GetValueOrDefault(sessionId); } public void UpdateMessageOnQueue(string sessionId, List value) { - throw new NotImplementedException(); + if (_messageQueue.ContainsKey(sessionId)) + { + _messageQueue[sessionId] = value; + } } public bool Has(string sessionID) @@ -33,7 +36,9 @@ public class NotificationService /// public WsNotificationEvent Pop(string sessionID) { - throw new NotImplementedException(); + var result = Get(sessionID).First(); + Get(sessionID).Remove(result); + return result; } ///