TryRead for nullable long, tests on null value for StreamConsumerGroupInfo.Lag

Author: robhop

src/StackExchange.Redis/ResultProcessor.cs

@@ -2286,6 +2286,19 @@ internal static bool TryRead(Sequence<RawResult> pairs, in CommandBytes key, ref
                 }
                 return false;
             }
+            internal static bool TryRead(Sequence<RawResult> pairs, in CommandBytes key, ref long? value)
+            {
+                var len = pairs.Length / 2;
+                for (int i = 0; i < len; i++)
+                {
+                    if (pairs[i * 2].IsEqual(key) && pairs[(i * 2) + 1].TryGetInt64(out var tmp))
+                    {
+                        value = tmp;
+                        return true;
+                    }
+                }
+                return false;
+            }
 
             internal static bool TryRead(Sequence<RawResult> pairs, in CommandBytes key, ref int value)
             {
@@ -2348,7 +2361,8 @@ protected override StreamGroupInfo ParseItem(in RawResult result)
                 var arr = result.GetItems();
                 string? name = default, lastDeliveredId = default;
                 int consumerCount = default, pendingMessageCount = default;
-                long entriesRead = default, lag = default;
+                long entriesRead = default;
+                long? lag = default;
 
                 KeyValuePairParser.TryRead(arr, KeyValuePairParser.Name, ref name);
                 KeyValuePairParser.TryRead(arr, KeyValuePairParser.Consumers, ref consumerCount);

tests/StackExchange.Redis.Tests/StreamTests.cs

@@ -2042,4 +2042,43 @@ await db.StreamAddAsync(
         Assert.Equal(123, (int)obj!.id);
         Assert.Equal("test", (string)obj.name);
     }
+
+    [Fact]
+    public void StreamConsumerGroupInfoLagIsNull()
+    {
+        using var conn = Create(require: RedisFeatures.v5_0_0);
+
+        var db = conn.GetDatabase();
+        var key = Me();
+        const string groupName = "test_group",
+                     consumer = "consumer";
+
+        db.StreamCreateConsumerGroup(key, groupName);
+        db.StreamReadGroup(key, groupName, consumer, "0-0", 1);
+        db.StreamAdd(key, "field1", "value1");
+        db.StreamAdd(key, "field1", "value1");
+
+        var streamInfo = db.StreamInfo(key);
+        db.StreamDelete(key, new[] { streamInfo.LastEntry.Id });
+
+        Assert.Null(db.StreamGroupInfo(key)[0].Lag);
+    }
+
+    [Fact]
+    public void StreamConsumerGroupInfoLagIsTwo()
+    {
+        using var conn = Create(require: RedisFeatures.v5_0_0);
+
+        var db = conn.GetDatabase();
+        var key = Me();
+        const string groupName = "test_group",
+                     consumer = "consumer";
+
+        db.StreamCreateConsumerGroup(key, groupName);
+        db.StreamReadGroup(key, groupName, consumer, "0-0", 1);
+        db.StreamAdd(key, "field1", "value1");
+        db.StreamAdd(key, "field1", "value1");
+
+        Assert.Equal(2, db.StreamGroupInfo(key)[0].Lag);
+    }
 }