From b042f8b29b3514b7ca8ec8e2f7ff3a0f9fbe0e55 Mon Sep 17 00:00:00 2001
From: Andy Stark <andrew.stark@redis.com>
Date: Tue, 22 Apr 2025 14:50:03 +0100
Subject: [PATCH 1/2] DOC-4560 started trans/pipe examples

---
 tests/Doc/PipeTransExample.cs | 124 ++++++++++++++++++++++++++++++++++
 1 file changed, 124 insertions(+)
 create mode 100644 tests/Doc/PipeTransExample.cs

diff --git a/tests/Doc/PipeTransExample.cs b/tests/Doc/PipeTransExample.cs
new file mode 100644
index 00000000..e6154186
--- /dev/null
+++ b/tests/Doc/PipeTransExample.cs
@@ -0,0 +1,124 @@
+// EXAMPLE: pipe_trans_tutorial
+using NRedisStack;
+using StackExchange.Redis;
+//REMOVE_START
+using NRedisStack.Tests;
+using System.Threading.Tasks;
+
+namespace Doc;
+[Collection("DocsTests")]
+//REMOVE_END
+public class PipeTransExample
+// REMOVE_START
+: AbstractNRedisStackTest, IDisposable
+// REMOVE_END
+{
+    // REMOVE_START
+    public PipeTransExample(EndpointsFixture fixture) : base(fixture) { }
+
+    [SkippableFact]
+    // REMOVE_END
+    public async Task run()
+    {
+        //REMOVE_START
+        // This is needed because we're constructing ConfigurationOptions in the test before calling GetConnection
+        SkipIfTargetConnectionDoesNotExist(EndpointsFixture.Env.Standalone);
+        var _ = GetCleanDatabase(EndpointsFixture.Env.Standalone);
+        //REMOVE_END
+        var muxer = ConnectionMultiplexer.Connect("localhost:6379");
+        var db = muxer.GetDatabase();
+        // REMOVE_START
+        db.KeyDelete(new RedisKey[] {
+            "counter:1", "counter:2", "counter:3",
+            "seat:0", "seat:1", "seat:2", "seat:3", "seat:4",
+            "customer:39182",
+            "Details"
+        });
+        // REMOVE_END
+
+        // STEP_START basic_pipe
+        var pipeline = new Pipeline(db);
+        
+        for (int i = 0; i < 5; i++) {
+            pipeline.Db.StringSetAsync($"seat:{i}", $"#{i}");
+        }
+        pipeline.Execute();
+
+        var resp1 = db.StringGet("seat:0");
+        Console.WriteLine(resp1); // >>> #0
+
+        var resp2 = db.StringGet("seat:3");
+        Console.WriteLine(resp2); // >>> #3
+
+        var resp3 = db.StringGet("seat:4");
+        Console.WriteLine(resp2); // >>> #4
+        // STEP_END
+        // REMOVE_START
+        Assert.Equal("#0", resp1);
+        Assert.Equal("#3", resp2);
+        Assert.Equal("#4", resp3);
+        // REMOVE_END
+
+        // STEP_START basic_trans
+        var trans = new Transaction(db);
+
+        trans.Db.StringIncrementAsync("counter:1", 1);
+        trans.Db.StringIncrementAsync("counter:2", 2);
+        trans.Db.StringIncrementAsync("counter:3", 3);
+
+        trans.Execute();
+
+        var resp4 = db.StringGet("counter:1");
+        Console.WriteLine(resp4); // >>> 1
+
+        var resp5 = db.StringGet("counter:2");
+        Console.WriteLine(resp5); // >>> 2
+
+        var resp6 = db.StringGet("counter:3");
+        Console.WriteLine(resp6);  // >>> 3
+        // STEP_END
+        // REMOVE_START
+        Assert.Equal("1", resp4);
+        Assert.Equal("2", resp5);
+        Assert.Equal("3", resp6);
+        // REMOVE_END
+        
+        // STEP_START trans_watch
+        var watchedTrans = new Transaction(db);
+
+        watchedTrans.AddCondition(Condition.KeyNotExists("customer:39182"));
+
+        watchedTrans.Db.HashSetAsync(
+            "customer:39182",
+            new HashEntry[]{
+                new HashEntry("name", "David"),
+                new HashEntry("age", "27")
+            }
+        );
+
+        bool succeeded = watchedTrans.Execute();
+        Console.WriteLine(succeeded); // >>> true
+        // STEP_END
+        // REMOVE_START
+        Assert.True(succeeded);
+        // REMOVE_END
+
+        // STEP_START when_condition
+        bool resp7 = db.HashSet("Details", "SerialNumber", "12345");
+        Console.WriteLine(resp7); // >>> true
+
+        db.HashSet("Details", "SerialNumber", "12345A", When.NotExists);
+        string resp8 = db.HashGet("Details", "SerialNumber");
+        Console.WriteLine(resp8); // >>> 12345
+
+        db.HashSet("Details", "SerialNumber", "12345A");
+        string resp9 = db.HashGet("Details", "SerialNumber");
+        Console.WriteLine(resp9); // >>> 12345A
+        // STEP_END
+        // REMOVE_START
+        Assert.True(resp7);
+        Assert.Equal("12345", resp8);
+        Assert.Equal("12345A", resp9);
+        // REMOVE_END
+    }
+}
\ No newline at end of file

From 7ba27e643c0ab437d86be38f0b09a6f195b4d918 Mon Sep 17 00:00:00 2001
From: Andy Stark <andrew.stark@redis.com>
Date: Fri, 2 May 2025 12:20:39 +0100
Subject: [PATCH 2/2] DOC-4560 added testable trans/pipe examples

---
 tests/Doc/PipeTransExample.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/tests/Doc/PipeTransExample.cs b/tests/Doc/PipeTransExample.cs
index e6154186..2ad8b949 100644
--- a/tests/Doc/PipeTransExample.cs
+++ b/tests/Doc/PipeTransExample.cs
@@ -3,7 +3,6 @@
 using StackExchange.Redis;
 //REMOVE_START
 using NRedisStack.Tests;
-using System.Threading.Tasks;
 
 namespace Doc;
 [Collection("DocsTests")]
@@ -38,8 +37,9 @@ public async Task run()
 
         // STEP_START basic_pipe
         var pipeline = new Pipeline(db);
-        
-        for (int i = 0; i < 5; i++) {
+
+        for (int i = 0; i < 5; i++)
+        {
             pipeline.Db.StringSetAsync($"seat:{i}", $"#{i}");
         }
         pipeline.Execute();
@@ -82,7 +82,7 @@ public async Task run()
         Assert.Equal("2", resp5);
         Assert.Equal("3", resp6);
         // REMOVE_END
-        
+
         // STEP_START trans_watch
         var watchedTrans = new Transaction(db);