From 0152603ddba4c30eafb31e64074fe466e7fca526 Mon Sep 17 00:00:00 2001 From: Jkorf Date: Wed, 16 Jul 2025 10:42:38 +0200 Subject: [PATCH] Added setting for whether or not to process unparsable websocket messages --- CryptoExchange.Net/Clients/SocketApiClient.cs | 5 +++++ CryptoExchange.Net/Sockets/SocketConnection.cs | 4 +--- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/CryptoExchange.Net/Clients/SocketApiClient.cs b/CryptoExchange.Net/Clients/SocketApiClient.cs index b1a9833..1ea2aa5 100644 --- a/CryptoExchange.Net/Clients/SocketApiClient.cs +++ b/CryptoExchange.Net/Clients/SocketApiClient.cs @@ -82,6 +82,11 @@ namespace CryptoExchange.Net.Clients /// protected bool AllowTopicsOnTheSameConnection { get; set; } = true; + /// + /// Whether to continue processing and forward unparsable messages to handlers + /// + protected internal bool ProcessUnparsableMessages { get; set; } = false; + /// public double IncomingKbps { diff --git a/CryptoExchange.Net/Sockets/SocketConnection.cs b/CryptoExchange.Net/Sockets/SocketConnection.cs index 3e2d174..b970edd 100644 --- a/CryptoExchange.Net/Sockets/SocketConnection.cs +++ b/CryptoExchange.Net/Sockets/SocketConnection.cs @@ -11,8 +11,6 @@ using System.Diagnostics; using CryptoExchange.Net.Clients; using CryptoExchange.Net.Logging.Extensions; using System.Threading; -using CryptoExchange.Net.Objects.Options; -using CryptoExchange.Net.Authentication; namespace CryptoExchange.Net.Sockets { @@ -475,7 +473,7 @@ namespace CryptoExchange.Net.Sockets _logger.ReceivedData(SocketId, originalData); } - if (!accessor.IsValid) + if (!accessor.IsValid && !ApiClient.ProcessUnparsableMessages) { _logger.FailedToParse(SocketId, result.Error!.Message); return;