From d838d3377fd8b7cb924d5a0e5fdf8692177bcee5 Mon Sep 17 00:00:00 2001 From: Jkorf Date: Wed, 5 Aug 2026 13:13:48 +0200 Subject: [PATCH] Updated logging unhandled websocket message --- .../Logging/Extensions/SocketConnectionLoggingExtension.cs | 6 +++--- CryptoExchange.Net/Sockets/Default/SocketConnection.cs | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/CryptoExchange.Net/Logging/Extensions/SocketConnectionLoggingExtension.cs b/CryptoExchange.Net/Logging/Extensions/SocketConnectionLoggingExtension.cs index c85d3ab0..636f9a9b 100644 --- a/CryptoExchange.Net/Logging/Extensions/SocketConnectionLoggingExtension.cs +++ b/CryptoExchange.Net/Logging/Extensions/SocketConnectionLoggingExtension.cs @@ -180,7 +180,7 @@ namespace CryptoExchange.Net.Logging.Extensions _receivedMessageNotMatchedToAnyListener = LoggerMessage.Define( LogLevel.Warning, new EventId(2029, "ReceivedMessageNotMatchedToAnyListener"), - "[Sckt {SocketId}] received message not matched to any listener. TypeIdentifier: {TypeIdentifier}, ListenId: {ListenId}, current listeners: [{ListenIds}]"); + "[Sckt {SocketId}] received message not matched to any listener. TypeIdentifier: {TypeIdentifier}, TopicFilter: {ListenId}, registered TopicFilters for type: [{TopicFilters}]"); _failedToParse = LoggerMessage.Define( LogLevel.Warning, @@ -326,9 +326,9 @@ namespace CryptoExchange.Net.Logging.Extensions _sendingData(logger, socketId, requestId, data, null); } - public static void ReceivedMessageNotMatchedToAnyListener(this ILogger logger, int socketId, string typeIdentifier, string listenId, string listenIds) + public static void ReceivedMessageNotMatchedToAnyListener(this ILogger logger, int socketId, string typeIdentifier, string topicFilter, string topicFilters) { - _receivedMessageNotMatchedToAnyListener(logger, socketId, typeIdentifier, listenId, listenIds, null); + _receivedMessageNotMatchedToAnyListener(logger, socketId, typeIdentifier, topicFilter, topicFilters, null); } public static void SendingByteData(this ILogger logger, int socketId, int requestId, int length) diff --git a/CryptoExchange.Net/Sockets/Default/SocketConnection.cs b/CryptoExchange.Net/Sockets/Default/SocketConnection.cs index 1353fc75..5a593fe9 100644 --- a/CryptoExchange.Net/Sockets/Default/SocketConnection.cs +++ b/CryptoExchange.Net/Sockets/Default/SocketConnection.cs @@ -607,7 +607,7 @@ namespace CryptoExchange.Net.Sockets.Default SocketId, typeIdentifier, topicFilter!, - string.Join(",", _listeners.Select(x => string.Join(",", x.MessageRouter.Routes.Where(x => x.TypeIdentifier == typeIdentifier).Select(x => x.TopicFilter != null ? string.Join(",", x.TopicFilter) : "[null]"))))); + string.Join(",", _listeners.SelectMany(x => x.MessageRouter.Routes.Where(x => x.TypeIdentifier == typeIdentifier).Select(x => x.TopicFilter ?? "[null]")))); } } }