New Methods added:

>> API.Utility.GZipCompress to compress a string  with GZip
>> API.Utility.GZipCompress to decompress a string with GZip
API.MemCacheD enhanced to compress/decompress cached data

Author: lorenzobruni

rls/API.Library.dll

@@ -1,10 +1,9 @@
-using System;
-using System.Configuration;
+using Enyim.Caching;
+using Enyim.Caching.Memcached;
+using System;
 using System.Collections.Generic;
+using System.Configuration;
 using System.Dynamic;
-using Newtonsoft.Json;
-using Enyim.Caching;
-using Enyim.Caching.Memcached;
 
 namespace API
 {
@@ -333,13 +332,18 @@ private static bool Store(string key, MemCachedD_Value value, TimeSpan validFor,
             try
             {
                 // The value must be serialised
-                string serializedValue = Utility.JsonSerialize_IgnoreLoopingReference(value);
+                string cacheSerialised = Utility.JsonSerialize_IgnoreLoopingReference(value);
+                Log.Instance.Info("Cache Size Serialised (Byte): " + cacheSerialised.Length * sizeof(Char));
+
+                // The value must be compressed
+                string cacheCompressed = Utility.GZipCompress(cacheSerialised);
+                Log.Instance.Info("Cache Size Compressed (Byte): " + cacheCompressed.Length * sizeof(Char));
 
                 bool isStored = false;
 
                 // Fix the MemCacheD issue with bad Windows' compiled version: use validFor instead of expiresAt
                 // validFor and expiresAt match each other
-                isStored = MemcachedClient.Store(StoreMode.Set, key, serializedValue, validFor);
+                isStored = MemcachedClient.Store(StoreMode.Set, key, cacheCompressed, validFor);
 
                 // Store Value by Key
                 if (isStored)
@@ -550,12 +554,18 @@ private static MemCachedD_Value Get(string key)
 
             try
             {
-                // Get serialised cache by Key
-                string cacheSerialised = MemcachedClient.Get<string>(key);
+                // Get the compressed cache by Key
+                string cacheCompressed = MemcachedClient.Get<string>(key);
 
-                if (!String.IsNullOrEmpty(cacheSerialised))
+                if (!String.IsNullOrEmpty(cacheCompressed))
                 {
                     Log.Instance.Info("Cache found: " + key);
+                    Log.Instance.Info("Cache Size Compressed (Byte): " + cacheCompressed.Length * sizeof(Char));
+
+                    // Decompress the cache
+                    string cacheSerialised = Utility.GZipDecompress(cacheCompressed);
+                    Log.Instance.Info("Cache Size Serialised (Byte): " + cacheSerialised.Length * sizeof(Char));
+
                     // The value must be deserialised
                     dynamic cache = Utility.JsonDeserialize_IgnoreLoopingReference(cacheSerialised);
 
@@ -829,4 +839,4 @@ public MemCachedD_Value()
             data = null;
         }
     }
-}
+}

rls/API.Library.pdb

@@ -1,14 +1,16 @@
-using System.Reflection;
-using log4net;
-using System.Text;
-using System.Security.Cryptography;
+using log4net;
+using Newtonsoft.Json;
 using System;
+using System.Collections.Specialized;
 using System.Configuration;
-using System.Net;
+using System.IO;
+using System.IO.Compression;
 using System.Linq;
+using System.Net;
 using System.Net.Sockets;
-using Newtonsoft.Json;
-using System.Collections.Specialized;
+using System.Reflection;
+using System.Security.Cryptography;
+using System.Text;
 using System.Web;
 
 namespace API
@@ -230,6 +232,47 @@ public static string DecodeBase64ToUTF8(string data)
             }
         }
 
+        /// <summary>
+        /// Compress a UTF8 input string into Base64
+        /// </summary>
+        /// <param name="inputUTF8"></param>
+        /// <returns></returns>
+        public static string GZipCompress(string inputUTF8)
+        {
+            var byteInput = Encoding.UTF8.GetBytes(inputUTF8);
+
+            using (var msInput = new MemoryStream(byteInput))
+            using (var msOutput = new MemoryStream())
+            {
+                using (var stream = new GZipStream(msOutput, CompressionMode.Compress))
+                {
+                    msInput.CopyTo(stream);
+                }
+
+                return Convert.ToBase64String(msOutput.ToArray());
+            }
+        }
+
+        /// <summary>
+        /// Decompress a Base64 input string into UTF8
+        /// </summary>
+        /// <param name="inputBase64"></param>
+        /// <returns></returns>
+        public static string GZipDecompress(string inputBase64)
+        {
+            byte[] byteInput = Convert.FromBase64String(inputBase64);
+
+            using (var msInput = new MemoryStream(byteInput))
+            using (var msOutput = new MemoryStream())
+            {
+                using (var stream = new GZipStream(msInput, CompressionMode.Decompress))
+                {
+                    stream.CopyTo(msOutput);
+                }
+
+                return Encoding.UTF8.GetString(msOutput.ToArray());
+            }
+        }
         #endregion
     }
-}
+}

src/API.Library/Entities/MemCacheD.cs

@@ -32,8 +32,8 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("3.0.4.0")]
-[assembly: AssemblyFileVersion("3.0.4.0")]
+[assembly: AssemblyVersion("3.0.5.0")]
+[assembly: AssemblyFileVersion("3.0.5.0")]
 
 // Configure log4net using the Web.config file by default
 [assembly: log4net.Config.XmlConfigurator(Watch = true)]

src/API.Library/Entities/Utility.cs

@@ -71,9 +71,9 @@
     <CodeAnalysisRuleSet>MinimumRecommendedRules.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
   <ItemGroup>
-    <Reference Include="API.Library, Version=3.0.4.0, Culture=neutral, processorArchitecture=MSIL">
+    <Reference Include="API.Library, Version=3.0.5.0, Culture=neutral, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\packages\API.Library.3.0.4\API.Library.dll</HintPath>
+      <HintPath>..\packages\API.Library.3.0.5\API.Library.dll</HintPath>
     </Reference>
     <Reference Include="Enyim.Caching, Version=2.16.0.0, Culture=neutral, PublicKeyToken=cec98615db04012e, processorArchitecture=MSIL">
       <HintPath>..\packages\EnyimMemcached.2.16.0\lib\net35\Enyim.Caching.dll</HintPath>