Add utility extensions for compressing and encoding payloads

Author: ethanhann

src/InEngine.Core/CommandExtensions.cs

@@ -0,0 +1,51 @@
+using System;
+using System.IO;
+using System.IO.Compression;
+using System.Text;
+using Newtonsoft.Json;
+
+namespace InEngine.Core
+{
+    public static class CommandExtensions
+    {
+        public static string EncodeCommend(this ICommand command)
+        {
+            return Convert.ToBase64String(JsonConvert.SerializeObject(command).Compress());
+        }
+
+        public static ICommand DecodeCommand(this string encodedCommand, Type type)
+        {
+            var decoded = Convert.FromBase64String(encodedCommand);
+            var uncompressed = decoded.Decompress();
+            return JsonConvert.DeserializeObject(uncompressed, type) as ICommand;
+        }
+
+        public static byte[] Compress(this string str)
+        {
+            var bytes = Encoding.UTF8.GetBytes(str);
+
+            using (var msi = new MemoryStream(bytes))
+            using (var mso = new MemoryStream())
+            {
+                using (var gs = new GZipStream(mso, CompressionMode.Compress))
+                {
+                    StreamCopy.FromTo(msi, gs);
+                }
+                return mso.ToArray();
+            }
+        }
+
+        public static string Decompress(this byte[] bytes)
+        {
+            using (var msi = new MemoryStream(bytes))
+            using (var mso = new MemoryStream())
+            {
+                using (var gs = new GZipStream(msi, CompressionMode.Decompress))
+                {
+                    StreamCopy.FromTo(gs, mso);
+                }
+                return Encoding.UTF8.GetString(mso.ToArray());
+            }
+        }
+    }
+}

src/InEngine.Core/StreamCopy.cs

@@ -0,0 +1,22 @@
+using System;
+using System.IO;
+using System.IO.Compression;
+using System.Text;
+
+namespace InEngine.Core
+{
+    public class StreamCopy
+    {
+        public static void FromTo(Stream src, Stream dest)
+        {
+            byte[] bytes = new byte[4096];
+
+            int cnt;
+
+            while ((cnt = src.Read(bytes, 0, bytes.Length)) != 0)
+            {
+                dest.Write(bytes, 0, cnt);
+            }
+        }
+    }
+}