Merge pull request #45 from peet/gzip

Added support to deflate gzip compressed responses

src/main/java/us/monoid/web/AbstractResource.java

@@ -8,6 +8,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.logging.Logger;
+import java.util.zip.GZIPInputStream;
 
 /**
  * Abstract base class for all resource handlers you want to use with Resty.
@@ -31,15 +32,26 @@ public AbstractResource(Option... options) {
 	void fill(URLConnection anUrlConnection) throws IOException {
 		urlConnection = anUrlConnection;
 		try {
-			inputStream = anUrlConnection.getInputStream();
+			if ("gzip".equals(anUrlConnection.getContentEncoding())) {
+				inputStream = new GZIPInputStream(anUrlConnection.getInputStream());
+			}
+			else {
+				inputStream = anUrlConnection.getInputStream();
+			}
 		} catch (IOException e) {
 			// Per http://docs.oracle.com/javase/1.5.0/docs/guide/net/http-keepalive.html
 			// (comparable documentation exists for later java versions)
 			// if an HttpURLConnection was used clear the errorStream and close it
 			// so that keep alive can keep doing its work
 			if (anUrlConnection instanceof HttpURLConnection) {
 				HttpURLConnection conn = (HttpURLConnection) anUrlConnection;
-				InputStream es = new BufferedInputStream(conn.getErrorStream());
+				InputStream es;
+				if ("gzip".equals(conn.getContentEncoding())) {
+					es = new BufferedInputStream(new GZIPInputStream(conn.getErrorStream()));
+				}
+				else {
+					es = new BufferedInputStream(conn.getErrorStream());
+				}
 
 				ByteArrayOutputStream baos = new ByteArrayOutputStream();
 				try {

src/test/java/compression/test/CompressionTest.java

@@ -0,0 +1,31 @@
+package compression.test;
+
+import org.junit.Test;
+import us.monoid.web.Resty;
+
+import java.io.IOException;
+
+import static org.junit.Assert.assertTrue;
+
+/**
+ * Test that Resty deflates a compressed stream if gzip'd content is requested via the Accept-Encoding header
+ */
+public class CompressionTest {
+
+	@Test
+	public void testResponseDeflated() throws IOException {
+		// no compression
+		Resty r = new Resty();
+		String responseBody = r.text("http://www.whatsmyip.org/http-compression-test/").toString();
+		assertTrue("response body expected to contain message that NOT compressed",
+			responseBody.contains("No, Your Browser is Not Requesting Compressed Content"));
+
+		// with compression
+		r = new Resty();
+		r.withHeader("Accept-Encoding", "gzip");
+		responseBody = r.text("http://www.whatsmyip.org/http-compression-test/").toString();
+		assertTrue("response body expected to contain message that it WAS compressed",
+			responseBody.contains("Yes, Your Browser is Requesting Compressed Content"));
+	}
+
+}