SimpleHttpExchange tests

Author: Katsute

src/test/java/simplehttpexchange/SimpleHttpExchangeCookieSessionTests.java

@@ -12,11 +12,11 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.atomic.AtomicReference;
 
-public class SimpleHttpExchangeCookieSessionTests {
+public final class SimpleHttpExchangeCookieSessionTests {
 
     @Test
-    public void testSession() throws IOException, ExecutionException, InterruptedException{
-        final int port = 20004;
+    public final void testSession() throws IOException, ExecutionException, InterruptedException{
+        final int port = 8080;
 
         final SimpleHttpServer server = SimpleHttpServer.create(port);
         final AtomicReference<SimpleHttpExchange> exchangeRef = new AtomicReference<>();
@@ -48,7 +48,6 @@ public void testSession() throws IOException, ExecutionException, InterruptedExc
         client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
             .thenApply(HttpResponse::body).get();
 
-
         // exchange
 
         final SimpleHttpExchange exchange = exchangeRef.get();

src/test/java/simplehttpexchange/SimpleHttpExchangeGetPostTests.java

@@ -12,11 +12,11 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.atomic.AtomicReference;
 
-public class SimpleHttpExchangeReadTests {
+public final class SimpleHttpExchangeReadTests {
 
     @Test
-    public void read() throws IOException, InterruptedException, ExecutionException{
-        final int port = 20001;
+    public final void read() throws IOException, InterruptedException, ExecutionException{
+        final int port = 8080;
 
         final SimpleHttpServer server = SimpleHttpServer.create(port);
         final AtomicReference<SimpleHttpExchange> exchangeRef = new AtomicReference<>();

src/test/java/simplehttpexchange/SimpleHttpExchangeReadTests.java

@@ -0,0 +1,56 @@
+package simplehttpexchange.io;
+
+import com.kttdevelopment.simplehttpserver.*;
+import com.kttdevelopment.simplehttpserver.var.RequestMethod;
+import com.sun.net.httpserver.HttpContext;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.atomic.AtomicReference;
+
+public final class SimpleHttpExchangeGetTest {
+
+    @Test
+    public final void get() throws IOException, ExecutionException, InterruptedException{
+        final int port = 8080;
+
+        final SimpleHttpServer server = SimpleHttpServer.create(port);
+        final AtomicReference<SimpleHttpExchange> exchangeRef = new AtomicReference<>();
+        final AtomicReference<String> exchangeResponse = new AtomicReference<>();
+        final SimpleHttpHandler handler = exchange -> {
+            exchangeRef.set(exchange);
+            exchangeResponse.set(exchange.toString());
+            exchange.send(exchange.toString());
+        };
+
+        final String context = "";
+        final AtomicReference<HttpContext> contextRef = new AtomicReference<>();
+        contextRef.set(server.createContext(context,handler));
+        server.start();
+
+        final String queryKey = "test", queryValue = "value";
+        final String url = "http://localhost:" + port + context + '?' + queryKey + '=' + queryValue;
+
+        HttpRequest request = HttpRequest.newBuilder()
+            .uri(URI.create(url))
+            .GET()
+            .build();
+
+        final String response = HttpClient.newHttpClient().sendAsync(request, HttpResponse.BodyHandlers.ofString())
+            .thenApply(HttpResponse::body).get();
+
+        Assert.assertEquals("Response body did not match response sent", exchangeResponse.get(), response);
+
+        // exchange
+        final SimpleHttpExchange exchange = exchangeRef.get();
+
+        Assert.assertEquals("Client request method did not match exchange request method (GET)", RequestMethod.GET, exchange.getRequestMethod());
+        Assert.assertTrue("Exchange was missing client GET map", exchange.hasGet());
+        Assert.assertEquals("Exchange GET did not match client GET", queryValue, exchange.getGetMap().get(queryKey));
+    }
+
+}

src/test/java/simplehttpexchange/io/SimpleHttpExchangeGetTest.java

@@ -0,0 +1,75 @@
+package simplehttpexchange.io;
+
+import com.kttdevelopment.simplehttpserver.*;
+import com.kttdevelopment.simplehttpserver.var.RequestMethod;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.*;
+import java.util.Map;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.atomic.AtomicReference;
+
+public final class SimpleHttpExchangeMultipartFormTest {
+
+    @SuppressWarnings({"rawtypes", "StringBufferReplaceableByString", "SpellCheckingInspection"})
+    @Test
+    public final void postMultipartFormData() throws IOException, ExecutionException, InterruptedException{
+        final int port = 8080;
+
+        final SimpleHttpServer server = SimpleHttpServer.create(port);
+        final AtomicReference<SimpleHttpExchange> exchangeRef = new AtomicReference<>();
+        final AtomicReference<String> exchangeResponse = new AtomicReference<>();
+        final SimpleHttpHandler handler = exchange -> {
+            exchangeRef.set(exchange);
+            exchangeResponse.set(exchange.toString());
+            exchange.send(exchange.toString());
+        };
+
+        final String context = "";
+        server.createContext(context,handler);
+        server.start();
+
+        final String boundary = "d74496d66958873e";
+
+        final String url = "http://localhost:" + port + context ;
+
+        final String key = "key", value = "value";
+        final String fkey = "fileKey", filename = "fileName.txt", fvalue = "fileValue";
+
+        final StringBuilder OUT = new StringBuilder();
+        OUT.append("--------------------------").append(boundary).append("\r\n");
+        OUT.append("Content-Disposition: ").append("form-data; ").append("name=\"").append(key).append('\"').append("\r\n\r\n");
+        OUT.append(value).append("\r\n");
+        OUT.append("--------------------------").append(boundary).append("\r\n");
+        OUT.append("Content-Disposition: ").append("form-data; ").append("name=\"").append(fkey).append("\"; ");
+        OUT.append("filename=\"").append(filename).append('\"').append('\n');
+        OUT.append("Content-Type: ").append("text/plain").append("\r\n\r\n");
+        OUT.append(fvalue).append("\r\n");
+        OUT.append("--------------------------").append(boundary).append("--");
+
+        final HttpRequest request = HttpRequest.newBuilder()
+            .uri(URI.create(url))
+            .header("Content-type","multipart/form-data; boundary=" + boundary)
+            .POST(HttpRequest.BodyPublishers.ofString(OUT.toString()))
+            .build();
+
+        HttpClient.newHttpClient().sendAsync(request, HttpResponse.BodyHandlers.ofString())
+            .thenApply(HttpResponse::body).get();
+
+        // exchange
+        final SimpleHttpExchange exchange = exchangeRef.get();
+
+        Assert.assertEquals("Client request method did not match exchange request method (POST)", RequestMethod.POST,exchange.getRequestMethod());
+        Assert.assertTrue("Exchange was missing client POST map", exchange.hasPost());
+
+        Assert.assertEquals("Client form value did not match server value",value, ((Map) exchange.getPostMap().get(key)).get("value"));
+        Assert.assertEquals("Client file name did not match server value",filename, ((Map) ((Map) ((Map) ((Map) exchange.getPostMap().get(fkey)).get("headers")).get("Content-Disposition")).get("parameters")).get("filename"));
+        Assert.assertEquals("Client file value did not match server value",fvalue, ((Map) exchange.getPostMap().get(fkey)).get("value"));
+
+        server.stop();
+    }
+
+}

src/test/java/simplehttpexchange/io/SimpleHttpExchangeMultipartFormTest.java

@@ -0,0 +1,56 @@
+package simplehttpexchange.io;
+
+import com.kttdevelopment.simplehttpserver.*;
+import com.kttdevelopment.simplehttpserver.var.RequestMethod;
+import com.sun.net.httpserver.HttpContext;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.atomic.AtomicReference;
+
+public final class SimpleHttpExchangePostTest {
+
+    @Test
+    public void postSimple() throws IOException, ExecutionException, InterruptedException{
+        final int port = 20003;
+
+        final SimpleHttpServer server = SimpleHttpServer.create(port);
+        final AtomicReference<SimpleHttpExchange> exchangeRef = new AtomicReference<>();
+        final AtomicReference<String> exchangeResponse = new AtomicReference<>();
+        final SimpleHttpHandler handler = exchange -> {
+            exchangeRef.set(exchange);
+            exchangeResponse.set(exchange.toString());
+            exchange.send(exchange.toString());
+        };
+
+        final String context = "";
+        final AtomicReference<HttpContext> contextRef = new AtomicReference<>();
+        contextRef.set(server.createContext(context,handler));
+        server.start();
+
+        final String queryKey = "test", queryValue = "value";
+        final String url = "http://localhost:" + port + context ;
+
+        final HttpRequest request = HttpRequest.newBuilder()
+            .uri(URI.create(url))
+            .POST(HttpRequest.BodyPublishers.ofString(queryKey + '=' + queryValue))
+            .build();
+
+        HttpClient.newHttpClient().sendAsync(request, HttpResponse.BodyHandlers.ofString())
+            .thenApply(HttpResponse::body).get();
+
+        // exchange
+        final SimpleHttpExchange exchange = exchangeRef.get();
+
+        Assert.assertEquals("Client request method did not match exchange request method (POST)", RequestMethod.POST, exchange.getRequestMethod());
+        Assert.assertTrue("Exchange was missing client POST map", exchange.hasPost());
+        Assert.assertEquals("Exchange POST did not match client POST", queryValue, exchange.getPostMap().get(queryKey));
+
+        server.stop();
+    }
+
+}