C#: Add command batch tests.

csharp/tests/Valkey.Glide.IntegrationTests/BatchTestUtils.cs

@@ -0,0 +1,44 @@
+// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+
+using Valkey.Glide.Pipeline;
+
+using gs = Valkey.Glide.GlideString;
+
+namespace Valkey.Glide.IntegrationTests;
+
+internal class BatchTestUtils
+{
+    public static List<(object? expected, string test)> CreateStringTest(IBatch batch, bool isAtomic)
+    {
+        List<(object? expected, string test)> testData = [];
+        string prefix = isAtomic ? "{stringKey}-" : "";
+        string key1 = $"{prefix}1-{Guid.NewGuid()}";
+
+        string value1 = $"value-1-{Guid.NewGuid()}";
+
+        _ = batch.Set(key1, value1);
+        testData.Add(("OK", "Set(key1, value1)"));
+        _ = batch.Get(key1);
+        testData.Add((new gs(value1), "Get(key1)"));
+
+        return testData;
+    }
+
+    public static TheoryData<BatchTestData> GetTestClientWithAtomic =>
+        [.. TestConfiguration.TestClients.SelectMany(r => new[] { true, false }.SelectMany(isAtomic =>
+            new BatchTestData[] {
+                new("String commands", r.Data, CreateStringTest, isAtomic),
+            }))];
+}
+
+internal delegate List<(object? expected, string test)> BatchTestDataProvider(IBatch batch, bool isAtomic);
+
+internal record BatchTestData(string TestName, BaseClient Client, BatchTestDataProvider TestDataProvider, bool IsAtomic)
+{
+    public string TestName = TestName;
+    public BaseClient Client = Client;
+    public BatchTestDataProvider TestDataProvider = TestDataProvider;
+    public bool IsAtomic = IsAtomic;
+
+    public override string? ToString() => $"{TestName} {Client} IsAtomic = {IsAtomic}";
+}

csharp/tests/Valkey.Glide.IntegrationTests/SharedCommandTests.cs

@@ -1,5 +1,7 @@
 // Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
 
+using Valkey.Glide.Pipeline;
+
 namespace Valkey.Glide.IntegrationTests;
 
 public class SharedCommandTests(TestConfiguration config)
@@ -46,4 +48,35 @@ public async Task GetReturnsEmptyString(BaseClient client)
         string value = string.Empty;
         await GetAndSetValues(client, key, value);
     }
+
+    [Theory(DisableDiscoveryEnumeration = true)]
+    [MemberData(nameof(BatchTestUtils.GetTestClientWithAtomic), MemberType = typeof(BatchTestUtils))]
+    internal async Task BatchTest(BatchTestData testData)
+    {
+        IBatch batch = testData.Client is GlideClient ? new Batch(testData.IsAtomic) : new ClusterBatch(testData.IsAtomic);
+        List<(object? expected, string test)> expectedInfo = testData.TestDataProvider(batch, testData.IsAtomic);
+
+        object?[] actualResult = testData.Client switch
+        {
+            GlideClient client => (await client.Exec((Batch)batch, true))!,
+            GlideClusterClient client => (await client.Exec((ClusterBatch)batch, true))!,
+            _ => throw new NotImplementedException()
+        };
+
+        Assert.Equal(expectedInfo.Count, actualResult.Length);
+        List<string> failedChecks = [];
+        for (int i = 0; i < actualResult.Length; i++)
+        {
+            try
+            {
+                // TODO use assertDeepEquals
+                Assert.Equal(expectedInfo[i].expected, actualResult[i]);
+            }
+            catch (Exception e)
+            {
+                failedChecks.Add($"{expectedInfo[i].test} failed: {e.Message}");
+            }
+        }
+        Assert.Empty(failedChecks);
+    }
 }