diff options
author | ritchie <ritchie@gmx.at> | 2015-09-11 07:53:51 +0200 |
---|---|---|
committer | ritchie <ritchie@gmx.at> | 2015-09-11 07:53:51 +0200 |
commit | 029d66622c19af4a17ef4e47598f5f9038f9c3cf (patch) | |
tree | 2204492fb8782ca592516a549c9af1f9934d4028 /core | |
parent | 4344efd565b3ad079eff4780619a964c86ac0b11 (diff) | |
parent | 6c4d9f5a060c8621cfd1cb3c9132d2bfaecaabd3 (diff) | |
download | nanohttpd-029d66622c19af4a17ef4e47598f5f9038f9c3cf.tar.gz |
Merge branch 'vnnv-Nanolets_Condensed_in_a_single_file'
Diffstat (limited to 'core')
6 files changed, 94 insertions, 26 deletions
diff --git a/core/src/main/java/fi/iki/elonen/NanoHTTPD.java b/core/src/main/java/fi/iki/elonen/NanoHTTPD.java index 7992650..d75c762 100644 --- a/core/src/main/java/fi/iki/elonen/NanoHTTPD.java +++ b/core/src/main/java/fi/iki/elonen/NanoHTTPD.java @@ -1801,21 +1801,21 @@ public abstract class NanoHTTPD { /** * Create a response with unknown length (using HTTP 1.1 chunking). */ - public Response newChunkedResponse(IStatus status, String mimeType, InputStream data) { + public static Response newChunkedResponse(IStatus status, String mimeType, InputStream data) { return new Response(status, mimeType, data, -1); } /** * Create a response with known length. */ - public Response newFixedLengthResponse(IStatus status, String mimeType, InputStream data, long totalBytes) { + public static Response newFixedLengthResponse(IStatus status, String mimeType, InputStream data, long totalBytes) { return new Response(status, mimeType, data, totalBytes); } /** * Create a text response with known length. */ - public Response newFixedLengthResponse(IStatus status, String mimeType, String txt) { + public static Response newFixedLengthResponse(IStatus status, String mimeType, String txt) { if (txt == null) { return newFixedLengthResponse(status, mimeType, new ByteArrayInputStream(new byte[0]), 0); } else { @@ -1833,7 +1833,7 @@ public abstract class NanoHTTPD { /** * Create a text response with known length. */ - public Response newFixedLengthResponse(String msg) { + public static Response newFixedLengthResponse(String msg) { return newFixedLengthResponse(Status.OK, NanoHTTPD.MIME_HTML, msg); } diff --git a/core/src/main/java/fi/iki/elonen/util/ServerRunner.java b/core/src/main/java/fi/iki/elonen/util/ServerRunner.java new file mode 100644 index 0000000..c8d22d4 --- /dev/null +++ b/core/src/main/java/fi/iki/elonen/util/ServerRunner.java @@ -0,0 +1,75 @@ +package fi.iki.elonen.util; + +/* + * #%L + * NanoHttpd-Webserver + * %% + * Copyright (C) 2012 - 2015 nanohttpd + * %% + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, this + * list of conditions and the following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above copyright notice, + * this list of conditions and the following disclaimer in the documentation + * and/or other materials provided with the distribution. + * + * 3. Neither the name of the nanohttpd nor the names of its contributors + * may be used to endorse or promote products derived from this software without + * specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, + * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF + * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE + * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED + * OF THE POSSIBILITY OF SUCH DAMAGE. + * #L% + */ + +import java.io.IOException; +import java.util.logging.Level; +import java.util.logging.Logger; + +import fi.iki.elonen.NanoHTTPD; + +public class ServerRunner { + + /** + * logger to log to. + */ + private static final Logger LOG = Logger.getLogger(ServerRunner.class.getName()); + + public static void executeInstance(NanoHTTPD server) { + try { + server.start(); + } catch (IOException ioe) { + System.err.println("Couldn't start server:\n" + ioe); + System.exit(-1); + } + + System.out.println("Server started, Hit Enter to stop.\n"); + + try { + System.in.read(); + } catch (Throwable ignored) { + } + + server.stop(); + System.out.println("Server stopped.\n"); + } + + public static <T extends NanoHTTPD> void run(Class<T> serverClass) { + try { + executeInstance(serverClass.newInstance()); + } catch (Exception e) { + ServerRunner.LOG.log(Level.SEVERE, "Cound nor create server", e); + } + } +} diff --git a/core/src/test/java/fi/iki/elonen/HttpDeleteRequestTest.java b/core/src/test/java/fi/iki/elonen/HttpDeleteRequestTest.java index 87b3782..8ce49e1 100644 --- a/core/src/test/java/fi/iki/elonen/HttpDeleteRequestTest.java +++ b/core/src/test/java/fi/iki/elonen/HttpDeleteRequestTest.java @@ -42,8 +42,7 @@ public class HttpDeleteRequestTest extends HttpServerTest { @Test public void testDeleteRequestThatDoesntSendBackResponseBody_EmptyString() throws Exception { - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, ""); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, ""); ByteArrayOutputStream outputStream = invokeServer("DELETE " + HttpServerTest.URI + " HTTP/1.1"); @@ -61,8 +60,7 @@ public class HttpDeleteRequestTest extends HttpServerTest { @Test public void testDeleteRequestThatDoesntSendBackResponseBody_NullInputStream() throws Exception { - this.testServer.response = new NanoHTTPD(0) { - }.newChunkedResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, (InputStream) null); + this.testServer.response = NanoHTTPD.newChunkedResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, (InputStream) null); ByteArrayOutputStream outputStream = invokeServer("DELETE " + HttpServerTest.URI + " HTTP/1.1"); @@ -80,8 +78,7 @@ public class HttpDeleteRequestTest extends HttpServerTest { @Test public void testDeleteRequestThatDoesntSendBackResponseBody_NullString() throws Exception { - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, (String) null); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NO_CONTENT, NanoHTTPD.MIME_HTML, (String) null); ByteArrayOutputStream outputStream = invokeServer("DELETE " + HttpServerTest.URI + " HTTP/1.1"); @@ -99,8 +96,7 @@ public class HttpDeleteRequestTest extends HttpServerTest { @Test public void testDeleteRequestThatSendsBackResponseBody_Accepted() throws Exception { - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(NanoHTTPD.Response.Status.ACCEPTED, "application/xml", "<body />"); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.ACCEPTED, "application/xml", "<body />"); ByteArrayOutputStream outputStream = invokeServer("DELETE " + HttpServerTest.URI + " HTTP/1.1"); @@ -119,8 +115,7 @@ public class HttpDeleteRequestTest extends HttpServerTest { @Test public void testDeleteRequestThatSendsBackResponseBody_Success() throws Exception { - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(NanoHTTPD.Response.Status.OK, "application/xml", "<body />"); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.OK, "application/xml", "<body />"); ByteArrayOutputStream outputStream = invokeServer("DELETE " + HttpServerTest.URI + " HTTP/1.1"); diff --git a/core/src/test/java/fi/iki/elonen/HttpGetRequestTest.java b/core/src/test/java/fi/iki/elonen/HttpGetRequestTest.java index de1285f..e1a6b8b 100644 --- a/core/src/test/java/fi/iki/elonen/HttpGetRequestTest.java +++ b/core/src/test/java/fi/iki/elonen/HttpGetRequestTest.java @@ -168,8 +168,7 @@ public class HttpGetRequestTest extends HttpServerTest { @Test public void testOutputOfServeSentBackToClient() throws Exception { String responseBody = "Success!"; - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(responseBody); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(responseBody); ByteArrayOutputStream outputStream = invokeServer("GET " + HttpServerTest.URI + " HTTP/1.1"); String[] expected = { diff --git a/core/src/test/java/fi/iki/elonen/HttpHeadRequestTest.java b/core/src/test/java/fi/iki/elonen/HttpHeadRequestTest.java index 8baf22d..4eb3147 100644 --- a/core/src/test/java/fi/iki/elonen/HttpHeadRequestTest.java +++ b/core/src/test/java/fi/iki/elonen/HttpHeadRequestTest.java @@ -48,8 +48,7 @@ public class HttpHeadRequestTest extends HttpServerTest { public void setUp() { super.setUp(); String responseBody = "Success!"; - this.testServer.response = new NanoHTTPD(0) { - }.newFixedLengthResponse(responseBody); + this.testServer.response = NanoHTTPD.newFixedLengthResponse(responseBody); } @Test diff --git a/core/src/test/java/fi/iki/elonen/integration/GZipIntegrationTest.java b/core/src/test/java/fi/iki/elonen/integration/GZipIntegrationTest.java index 4b95481..a278406 100644 --- a/core/src/test/java/fi/iki/elonen/integration/GZipIntegrationTest.java +++ b/core/src/test/java/fi/iki/elonen/integration/GZipIntegrationTest.java @@ -81,7 +81,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void contentEncodingShouldBeAddedToFixedLengthResponses() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); HttpResponse response = httpclient.execute(request); @@ -93,7 +93,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void contentEncodingShouldBeAddedToChunkedResponses() throws IOException { InputStream data = new ByteArrayInputStream("This is a test".getBytes("UTF-8")); - testServer.response = testServer.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", data); + testServer.response = NanoHTTPD.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", data); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); HttpResponse response = httpclient.execute(request); @@ -104,7 +104,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void shouldFindCorrectAcceptEncodingAmongMany() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "deflate,gzip"); HttpResponse response = httpclient.execute(request); @@ -115,7 +115,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void contentLengthShouldBeRemovedFromZippedResponses() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); HttpResponse response = httpclient.execute(request); @@ -125,7 +125,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void fixedLengthContentIsEncodedProperly() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); @@ -135,7 +135,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void chunkedContentIsEncodedProperly() throws IOException { InputStream data = new ByteArrayInputStream("This is a test".getBytes("UTF-8")); - testServer.response = testServer.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", data); + testServer.response = NanoHTTPD.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", data); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); @@ -144,7 +144,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void noGzipWithoutAcceptEncoding() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); HttpGet request = new HttpGet("http://localhost:8192/"); HttpResponse response = httpclient.execute(request); Header contentEncoding = response.getFirstHeader("content-encoding"); @@ -154,7 +154,7 @@ public class GZipIntegrationTest extends IntegrationTestBase<GZipIntegrationTest @Test public void contentShouldNotBeGzippedIfContentLengthIsAddedManually() throws IOException { - testServer.response = testServer.newFixedLengthResponse("This is a test"); + testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); testServer.response.addHeader("Content-Length", "" + ("This is a test".getBytes("UTF-8").length)); HttpGet request = new HttpGet("http://localhost:8192/"); request.addHeader("Accept-encoding", "gzip"); |