Add Redirect method and refactor out compression/decompression logic for reuse

Author: jpreese

Titanium.Web.Proxy/Compression/CompressionFactory.cs

@@ -0,0 +1,20 @@
+namespace Titanium.Web.Proxy.Compression
+{
+    class CompressionFactory
+    {
+        public ICompression Create(string type)
+        {
+            switch (type)
+            {
+                case "gzip":
+                    return new GZipCompression();
+                case "deflate":
+                    return new DeflateCompression();
+                case "zlib":
+                    return new ZlibCompression();
+                default:
+                    return null;
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Compression/DeflateCompression.cs

@@ -0,0 +1,21 @@
+using System.IO;
+using System.IO.Compression;
+
+namespace Titanium.Web.Proxy.Compression
+{
+    class DeflateCompression : ICompression
+    {
+        public byte[] Compress(byte[] responseBody)
+        {
+            using (var ms = new MemoryStream())
+            {
+                using (var zip = new DeflateStream(ms, CompressionMode.Compress, true))
+                {
+                    zip.Write(responseBody, 0, responseBody.Length);
+                }
+
+                return ms.ToArray();
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Compression/GZipCompression.cs

@@ -0,0 +1,21 @@
+using Ionic.Zlib;
+using System.IO;
+
+namespace Titanium.Web.Proxy.Compression
+{
+    class GZipCompression : ICompression
+    {
+        public byte[] Compress(byte[] responseBody)
+        {
+            using (var ms = new MemoryStream())
+            {
+                using (var zip = new GZipStream(ms, CompressionMode.Compress, true))
+                {
+                    zip.Write(responseBody, 0, responseBody.Length);
+                }
+
+                return ms.ToArray();
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Compression/ICompression.cs

@@ -0,0 +1,7 @@
+namespace Titanium.Web.Proxy.Compression
+{
+    interface ICompression
+    {
+        byte[] Compress(byte[] responseBody);
+    }
+}

Titanium.Web.Proxy/Compression/ZlibCompression.cs

@@ -0,0 +1,21 @@
+using Ionic.Zlib;
+using System.IO;
+
+namespace Titanium.Web.Proxy.Compression
+{
+    class ZlibCompression : ICompression
+    {
+        public byte[] Compress(byte[] responseBody)
+        {
+            using (var ms = new MemoryStream())
+            {
+                using (var zip = new ZlibStream(ms, CompressionMode.Compress, true))
+                {
+                    zip.Write(responseBody, 0, responseBody.Length);
+                }
+
+                return ms.ToArray();
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Decompression/DecompressionFactory.cs

@@ -0,0 +1,20 @@
+namespace Titanium.Web.Proxy.Decompression
+{
+    class DecompressionFactory
+    {
+        public IDecompression Create(string type)
+        {
+            switch(type)
+            {
+                case "gzip":
+                    return new GZipDecompression();
+                case "deflate":
+                    return new DeflateDecompression();
+                case "zlib":
+                    return new ZlibDecompression();
+                default:
+                    return new DefaultDecompression();
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Decompression/DefaultDecompression.cs

@@ -0,0 +1,10 @@
+namespace Titanium.Web.Proxy.Decompression
+{
+    class DefaultDecompression : IDecompression
+    {
+        public byte[] Decompress(byte[] compressedArray)
+        {
+            return compressedArray;
+        }
+    }
+}

Titanium.Web.Proxy/Decompression/DeflateDecompression.cs

@@ -0,0 +1,29 @@
+using Ionic.Zlib;
+using System.IO;
+
+namespace Titanium.Web.Proxy.Decompression
+{
+    class DeflateDecompression : IDecompression
+    {
+        public byte[] Decompress(byte[] compressedArray)
+        {
+            var stream = new MemoryStream(compressedArray);
+
+            using (var decompressor = new DeflateStream(stream, CompressionMode.Decompress))
+            {
+                var buffer = new byte[ProxyServer.BUFFER_SIZE];
+
+                using (var output = new MemoryStream())
+                {
+                    int read;
+                    while ((read = decompressor.Read(buffer, 0, buffer.Length)) > 0)
+                    {
+                        output.Write(buffer, 0, read);
+                    }
+
+                    return output.ToArray();
+                }
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Decompression/GZipDecompression.cs

@@ -0,0 +1,25 @@
+using System.IO;
+using System.IO.Compression;
+
+namespace Titanium.Web.Proxy.Decompression
+{
+    class GZipDecompression : IDecompression
+    {
+        public byte[] Decompress(byte[] compressedArray)
+        {
+            using (var decompressor = new GZipStream(new MemoryStream(compressedArray), CompressionMode.Decompress))
+            {
+                var buffer = new byte[ProxyServer.BUFFER_SIZE];
+                using (var output = new MemoryStream())
+                {
+                    int read;
+                    while ((read = decompressor.Read(buffer, 0, buffer.Length)) > 0)
+                    {
+                        output.Write(buffer, 0, read);
+                    }
+                    return output.ToArray();
+                }
+            }
+        }
+    }
+}

Titanium.Web.Proxy/Decompression/IDecompression.cs

@@ -0,0 +1,9 @@
+using System.IO;
+
+namespace Titanium.Web.Proxy.Decompression
+{
+    interface IDecompression
+    {
+        byte[] Decompress(byte[] compressedArray);
+    }
+}