Add new API to read unstructured complex type responses

Author: mythz

src/ServiceStack.Redis/RedisDataExtensions.cs

@@ -0,0 +1,20 @@
+using System.Collections.Generic;
+
+namespace ServiceStack.Redis
+{
+    public static class RedisDataExtensions
+    {
+         public static RedisText ToRedisText(this RedisData data)
+         {
+             var to = new RedisText();
+
+             if (data.Data != null)
+                 to.Text = data.Data.FromUtf8Bytes();
+
+             if (data.Children != null)
+                 to.Children = data.Children.ConvertAll(x => x.ToRedisText());
+
+             return to;
+         }
+    }
+}

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -10,6 +10,7 @@
 //
 
 using System;
+using System.Collections.Generic;
 using System.Diagnostics;
 using System.Globalization;
 using System.IO;
@@ -114,6 +115,9 @@ private void Connect()
                 if (db != 0)
                     SendExpectSuccess(Commands.Select, db.ToUtf8Bytes());
 
+                if (Client != null)
+                    SendExpectSuccess(Commands.Client, Commands.SetName, Client.ToUtf8Bytes());
+
                 try
                 {
                     if (ServerVersionNumber == 0)
@@ -527,6 +531,19 @@ protected object[] SendExpectDeeplyNestedMultiData(params byte[][] cmdWithBinary
             return ReadDeeplyNestedMultiData();
         }
 
+        protected RedisData SendExpectComplexResponse(params byte[][] cmdWithBinaryArgs)
+        {
+            if (!SendCommand(cmdWithBinaryArgs))
+                throw CreateConnectionError();
+
+            if (Pipeline != null)
+            {
+                throw new NotSupportedException("Pipeline is not supported.");
+            }
+
+            return ReadComplexResponse();
+        }
+
         protected void Log(string fmt, params object[] args)
         {
             log.DebugFormat("{0}", string.Format(fmt, args).Trim());
@@ -802,6 +819,47 @@ private object ReadDeeplyNestedMultiDataItem()
             throw CreateResponseError("Unknown reply on multi-request: " + c + s);
         }
 
+        internal RedisData ReadComplexResponse()
+        {
+            int c = SafeReadByte();
+            if (c == -1)
+                throw CreateResponseError("No more data");
+
+            var s = ReadLine();
+            if (log.IsDebugEnabled)
+                Log("R: {0}", s);
+
+            switch (c)
+            {
+                case '$':
+                    return new RedisData {
+                        Data = ParseSingleLine(string.Concat(char.ToString((char) c), s))
+                    };
+
+                case '-':
+                    throw CreateResponseError(s.StartsWith("ERR") ? s.Substring(4) : s);
+
+                case '*':
+                    int count;
+                    if (int.TryParse(s, out count))
+                    {
+                        var ret = new RedisData { Children = new List<RedisData>() };
+                        for (var i = 0; i < count; i++)
+                        {
+                            ret.Children.Add(ReadComplexResponse());
+                        }
+
+                        return ret;
+                    }
+                    break;
+
+                default:
+                    return new RedisData { Data = s.ToUtf8Bytes() };
+            }
+
+            throw CreateResponseError("Unknown reply on multi-request: " + c + s);
+        }
+
         internal int ReadMultiDataResultCount()
         {
             int c = SafeReadByte();