diff --git a/Libraries/SPTarkov.Server.Core/Helpers/NotificationSendHelper.cs b/Libraries/SPTarkov.Server.Core/Helpers/NotificationSendHelper.cs index af7215f6..aae23e6e 100644 --- a/Libraries/SPTarkov.Server.Core/Helpers/NotificationSendHelper.cs +++ b/Libraries/SPTarkov.Server.Core/Helpers/NotificationSendHelper.cs @@ -50,7 +50,7 @@ public class NotificationSendHelper( if (logger.IsLogEnabled(LogLevel.Debug)) { logger.Debug( - $"Send message for {sessionID} websocket not available, queuing into profile" + $"Send message for {sessionID} websocket not available, queueing into profile" ); } notificationService.Add(sessionID, notificationMessage); diff --git a/Libraries/SPTarkov.Server.Core/Servers/Ws/SptWebSocketConnectionHandler.cs b/Libraries/SPTarkov.Server.Core/Servers/Ws/SptWebSocketConnectionHandler.cs index afeaca44..d9191362 100644 --- a/Libraries/SPTarkov.Server.Core/Servers/Ws/SptWebSocketConnectionHandler.cs +++ b/Libraries/SPTarkov.Server.Core/Servers/Ws/SptWebSocketConnectionHandler.cs @@ -163,6 +163,17 @@ public class SptWebSocketConnectionHandler( } } + public void SendMessageToAll(WsNotificationEvent output) + { + lock (_socketsLock) + { + foreach (var sessionID in _sockets.Keys) + { + SendMessage(sessionID, output); // this currently serializes for every socket, might want to separate into sending already serialized data + } + } + } + public void SendMessage(string sessionID, WsNotificationEvent output) { try