RESP3

Author: mgravell

src/StackExchange.Redis/PhysicalConnection.Read.cs

@@ -309,6 +309,7 @@ private void OnResponseFrame(RespPrefix prefix, ReadOnlySpan<byte> frame, ref by
                 // out-of-band; pub/sub etc
                 if (OnOutOfBand(frame, ref lease))
                 {
+                    OnDetailLog($"out-of-band message, not dequeuing: {prefix}");
                     return;
                 }
                 break;

src/StackExchange.Redis/RespReaderExtensions.cs

@@ -22,6 +22,20 @@ public RedisValue ReadRedisValue()
             };
         }
 
+        public string DebugReadTruncatedString(int maxChars)
+        {
+            if (!reader.IsScalar) return "";
+            try
+            {
+                var s = reader.ReadString() ?? "";
+                return s.Length <= maxChars ? s : s.Substring(0, maxChars) + "...";
+            }
+            catch
+            {
+                return "";
+            }
+        }
+
         public RedisKey ReadRedisKey()
         {
             reader.DemandScalar();
@@ -30,12 +44,18 @@ public RedisKey ReadRedisKey()
 
         public string GetOverview()
         {
+            if (reader.Prefix is RespPrefix.None)
+            {
+                var copy = reader;
+                copy.MovePastBof();
+                return copy.Prefix is RespPrefix.None ? "(empty)" : copy.GetOverview();
+            }
             if (reader.IsNull) return "(null)";
 
             return reader.Prefix switch
             {
                 RespPrefix.SimpleString or RespPrefix.Integer or RespPrefix.SimpleError or RespPrefix.Double => $"{reader.Prefix}: {reader.ReadString()}",
-                _ when reader.IsScalar => $"{reader.Prefix}: {reader.ScalarLength()} bytes",
+                _ when reader.IsScalar => $"{reader.Prefix}: {reader.ScalarLength()} bytes, '{reader.DebugReadTruncatedString(16)}'",
                 _ when reader.IsAggregate => $"{reader.Prefix}: {reader.AggregateLength()} items",
                 _ => $"(unknown: {reader.Prefix})",
             };

src/StackExchange.Redis/ResultProcessor.cs

@@ -224,8 +224,8 @@ public static void SetException(Message? message, Exception ex)
         // true if ready to be completed (i.e. false if re-issued to another server)
         public virtual bool SetResult(PhysicalConnection connection, Message message, ref RespReader reader)
         {
-            connection.OnDetailLog($"(core result for {message.Command}, {reader.GetFirstPrefix()})");
             reader.MovePastBof();
+            connection.OnDetailLog($"(core result for {message.Command}, '{reader.GetOverview()}')");
             var bridge = connection.BridgeCouldBeNull;
             if (message is LoggingMessage logging)
             {

tests/StackExchange.Redis.Tests/BasicOpTests.cs

@@ -6,6 +6,7 @@
 
 namespace StackExchange.Redis.Tests;
 
+[RunPerProtocol]
 public class BasicOpsTests(ITestOutputHelper output, SharedConnectionFixture fixture) : TestBase(output, fixture)
 {
     [Fact]