Add debug logging for failed messages and add tps to response types

Author: LucHeart

SDK.CSharp.Live/LiveControlModels/LiveResponseType.cs

@@ -7,6 +7,8 @@ public enum LiveResponseType
 {
     Frame = 0,
 
+    TPS = 50,
+    
     DeviceNotConnected = 100,
     DeviceConnected = 101,
     ShockerNotFound = 150,

SDK.CSharp.Live/OpenShockLiveControlClient.cs

@@ -100,7 +100,7 @@ private async Task<OneOf<Success, NotFound, Shutdown, Reconnecting>> ConnectAsyn
 
         State = WebsocketConnectionState.Connecting;
 #if NETSTANDARD2_1
-      _currentConnectionClose?.Cancel();
+        _currentConnectionClose?.Cancel();
 #else
         if (_currentConnectionClose != null) await _currentConnectionClose.CancelAsync();
 #endif
@@ -213,7 +213,8 @@ await _clientWebSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Normal cl
                 message.Switch(wsRequest => { Run(HandleMessage(wsRequest)); },
                     failed =>
                     {
-                        _logger.LogWarning("Deserialization failed for websocket message {Exception}",
+                        _logger.LogWarning("Deserialization failed for websocket message [{Message}] \n\n {Exception}",
+                            failed.Message,
                             failed.Exception);
                     },
                     _ => { });
@@ -299,7 +300,7 @@ await QueueMessage(new BaseRequest<LiveRequestType>
 
                 Latency = latencyAnnounceResponse.OwnLatency;
                 break;
-            
+
             case LiveResponseType.DeviceNotConnected:
                 await OnDeviceNotConnected.Raise();
                 break;

SDK.CSharp.Live/SDK.CSharp.Live.csproj

@@ -8,8 +8,8 @@
         <AssemblyName>OpenShock.SDK.CSharp.Live</AssemblyName>
         <RootNamespace>OpenShock.SDK.CSharp.Live</RootNamespace>
         <Company>OpenShock</Company>
-        <AssemblyVersion>0.0.16</AssemblyVersion>
-        <Version>0.0.16</Version>
+        <AssemblyVersion>0.0.17</AssemblyVersion>
+        <Version>0.0.17</Version>
         <Title>SDK.DotNet.Live</Title>
         <Authors>OpenShock</Authors>
         <Description>Extension for OpenShock.SDK.CSharp</Description>

SDK.CSharp.Live/Utils/JsonWebSocketUtils.cs

@@ -1,5 +1,6 @@
 using System.Buffers;
 using System.Net.WebSockets;
+using System.Text;
 using System.Text.Json;
 using Microsoft.IO;
 
@@ -8,7 +9,7 @@ namespace OpenShock.SDK.CSharp.Live.Utils;
 public static class JsonWebSocketUtils
 {
     private const uint MaxMessageSize = 512_000; // 512 000 bytes
-    
+
     public static readonly RecyclableMemoryStreamManager RecyclableMemory = new();
 
     public static async Task<OneOf.OneOf<T?, DeserializeFailed, WebsocketClosure>> ReceiveFullMessageAsyncNonAlloc<T>(
@@ -32,7 +33,7 @@ await socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closure during mess
                 }
 
                 if (buffer.Length + result.Count > MaxMessageSize) throw new MessageTooLongException();
-                
+
                 message.Write(buffer, 0, result.Count);
             } while (!result.EndOfMessage);
 
@@ -42,7 +43,11 @@ await socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closure during mess
             }
             catch (Exception e)
             {
-                return new DeserializeFailed { Exception = e };
+                return new DeserializeFailed
+                {
+                    Message = Encoding.UTF8.GetString(message.GetBuffer().AsSpan(0, bytes)),
+                    Exception = e
+                };
             }
         }
         finally
@@ -51,10 +56,12 @@ await socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closure during mess
         }
     }
 
-    public static Task SendFullMessage<T>(T obj, WebSocket socket, CancellationToken cancelToken, JsonSerializerOptions jsonSerializerOptions, int maxChunkSize = 256) =>
+    public static Task SendFullMessage<T>(T obj, WebSocket socket, CancellationToken cancelToken,
+        JsonSerializerOptions jsonSerializerOptions, int maxChunkSize = 256) =>
         SendFullMessageBytes(JsonSerializer.SerializeToUtf8Bytes(obj, jsonSerializerOptions), socket, cancelToken);
 
-    public static async Task SendFullMessageBytes(byte[] msg, WebSocket socket, CancellationToken cancelToken, int maxChunkSize = 256)
+    public static async Task SendFullMessageBytes(byte[] msg, WebSocket socket, CancellationToken cancelToken,
+        int maxChunkSize = 256)
     {
         var doneBytes = 0;
 
@@ -74,6 +81,7 @@ public static async Task SendFullMessageBytes(byte[] msg, WebSocket socket, Canc
 /// </summary>
 public readonly struct DeserializeFailed
 {
+    public required string Message { get; init; }
     public required Exception Exception { get; init; }
 }