Resolving merge request #13

Author: esPPB

cSharp/Api-ng-sample-code/Api-ng-sample-code/Json/JsonConvert.cs

@@ -4,6 +4,7 @@
 using System.Text;
 using System.IO;
 using Newtonsoft.Json;
+using System.IO.Compression;
 
 
 namespace Api_ng_sample_code.Json
@@ -16,7 +17,35 @@ public static JsonResponse<T> Import<T>(TextReader reader)
             var jsonResponse = reader.ReadToEnd();
             return Deserialize<JsonResponse<T>>(jsonResponse);
         }
+        public static JsonResponse<T> ImportGzip<T>(Stream reader)
+        {
+            var jsonResponse = decompress(reader);
+            return Deserialize<JsonResponse<T>>(jsonResponse);
+        }
 
+        public static string decompress(Stream reader)
+        {
+            using (GZipStream stream = new GZipStream(reader, CompressionMode.Decompress))
+            {
+                const int size = 4096;
+                byte[] buffer = new byte[size];
+                using (MemoryStream memory = new MemoryStream())
+                {
+                    int count = 0;
+                    do
+                    {
+                        count = stream.Read(buffer, 0, size);
+                        if (count > 0)
+                        {
+                            memory.Write(buffer, 0, count);
+                        }
+                    }
+                    while (count > 0);
+                    return System.Text.ASCIIEncoding.ASCII.GetString(memory.ToArray());
+                }
+
+            }
+        }
         public static T Deserialize<T>(string json)
         {
             return Newtonsoft.Json.JsonConvert.DeserializeObject<T>(json);

cSharp/Api-ng-sample-code/Api-ng-sample-code/JsonRpcClient.cs

@@ -164,17 +164,35 @@ public T Invoke<T>(string method, IDictionary<string, object> args = null)
 
             using (WebResponse response = GetWebResponse(request))
             using (Stream stream = response.GetResponseStream())
-            using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
             {
-                var jsonResponse = JsonConvert.Import<T>(reader);
-               // Console.WriteLine("\nGot Response: " + JsonConvert.Serialize<JsonResponse<T>>(jsonResponse));
-                if (jsonResponse.HasError)
+                if (response.ContentEncoding.ToLower() == "gzip")
                 {
-                    throw ReconstituteException(jsonResponse.Error);
+                    var jsonResponse = JsonConvert.ImportGzip<T>(stream);
+                    Console.WriteLine("\nGot Response: " + JsonConvert.Serialize<JsonResponse<T>>(jsonResponse));
+                    if (jsonResponse.HasError)
+                    {
+                        throw ReconstituteException(jsonResponse.Error);
+                    }
+                    else
+                    {
+                        return jsonResponse.Result;
+                    }
                 }
                 else
                 {
-                    return jsonResponse.Result;
+                    using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
+                    {
+                        var jsonResponse = JsonConvert.Import<T>(reader);
+                        Console.WriteLine("\nGot Response: " + JsonConvert.Serialize<JsonResponse<T>>(jsonResponse));
+                        if (jsonResponse.HasError)
+                        {
+                            throw ReconstituteException(jsonResponse.Error);
+                        }
+                        else
+                        {
+                            return jsonResponse.Result;
+                        }
+                    }
                 }
             }
         }