Add support for HashSet commands in Redis Transactions

Author: mythz

src/ServiceStack.Redis/Generic/RedisTypedCommandQueue.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using ServiceStack.Text;
 
 namespace ServiceStack.Redis.Generic
@@ -256,5 +257,48 @@ public void QueueCommand(Func<IRedisTypedClient<T>, List<T>> command, Action<Lis
             command(RedisClient);
         }
 
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<string>> command)
+        {
+            QueueCommand(command, null, null);
+        }
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback)
+        {
+            QueueCommand(command, onSuccessCallback, null);
+        }
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback, Action<Exception> onErrorCallback)
+        {
+            BeginQueuedCommand(new QueuedRedisTypedCommand<T>
+            {
+                MultiStringReturnCommand = r => command(r).ToList(),
+                OnSuccessMultiStringCallback = list => onSuccessCallback(list.ToHashSet()),
+                OnErrorCallback = onErrorCallback
+            });
+            command(RedisClient);
+        }
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<T>> command)
+        {
+            QueueCommand(command, null, null);
+        }
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<T>> command, Action<HashSet<T>> onSuccessCallback)
+        {
+            QueueCommand(command, onSuccessCallback, null);
+        }
+
+        public void QueueCommand(Func<IRedisTypedClient<T>, HashSet<T>> command, Action<HashSet<T>> onSuccessCallback, Action<Exception> onErrorCallback)
+        {
+            BeginQueuedCommand(new QueuedRedisTypedCommand<T>
+            {
+                MultiObjectReturnCommand = r => command(r).ToList(),
+                OnSuccessMultiTypeCallback = x => onSuccessCallback(x.ConvertAll(y => JsonSerializer.DeserializeFromString<T>(y)).ToHashSet()),
+                OnErrorCallback = onErrorCallback
+            });
+            command(RedisClient);
+        }
+
     }
 }

src/ServiceStack.Redis/Pipeline/RedisCommandQueue.cs

@@ -12,6 +12,7 @@
 
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using ServiceStack.Redis.Pipeline;
 
 namespace ServiceStack.Redis
@@ -225,6 +226,29 @@ public virtual void QueueCommand(Func<IRedisClient, List<string>> command, Actio
             command(RedisClient);
         }
 
+
+        public void QueueCommand(Func<IRedisClient, HashSet<string>> command)
+        {
+            QueueCommand(command, null, null);
+        }
+
+        public void QueueCommand(Func<IRedisClient, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback)
+        {
+            QueueCommand(command, onSuccessCallback, null);
+        }
+
+        public virtual void QueueCommand(Func<IRedisClient, HashSet<string>> command, Action<HashSet<string>> onSuccessCallback, Action<Exception> onErrorCallback)
+        {
+            BeginQueuedCommand(new QueuedRedisCommand
+            {
+                MultiStringReturnCommand = r => command(r).ToList(),
+                OnSuccessMultiStringCallback = list => onSuccessCallback(list.ToHashSet()),
+                OnErrorCallback = onErrorCallback
+            });
+            command(RedisClient);
+        }
+
+
         public void QueueCommand(Func<IRedisClient, Dictionary<string, string>> command)
         {
             QueueCommand(command, null, null);

tests/ServiceStack.Redis.Tests/RedisTransactionTests.cs

@@ -364,5 +364,22 @@ public void Can_call_Type_in_transaction()
                 {"zset", "zset" },
             }));
         }
+
+        [Test]
+        public void Can_call_HashSet_commands_in_transaction()
+        {
+            Redis.AddItemToSet("set", "ITEM 1");
+            Redis.AddItemToSet("set", "ITEM 2");
+            HashSet<string> result = null;
+
+            using (var trans = Redis.CreateTransaction())
+            {
+                trans.QueueCommand(r => r.GetAllItemsFromSet("set"), values => result = values);
+
+                trans.Commit();
+            }
+
+            Assert.That(result, Is.EquivalentTo(new[] { "ITEM 1", "ITEM 2" }));
+        }
     }
 }