Implemented Undertow

Author: JanHolger

pom.xml

@@ -68,6 +68,11 @@
             <artifactId>junit-jupiter-api</artifactId>
             <version>5.8.2</version>
         </dependency>
+        <dependency>
+            <groupId>io.undertow</groupId>
+            <artifactId>undertow-core</artifactId>
+            <version>2.2.13.Final</version>
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter-engine</artifactId>

src/main/java/org/javawebstack/httpserver/HTTPServer.java

@@ -4,7 +4,6 @@
 import org.javawebstack.abstractdata.NamingPolicy;
 import org.javawebstack.httpserver.adapter.IHTTPSocketServer;
 import org.javawebstack.httpserver.adapter.jetty.JettyHTTPSocketServer;
-import org.javawebstack.httpserver.adapter.simple.SimpleHTTPSocketServer;
 import org.javawebstack.httpserver.handler.*;
 import org.javawebstack.httpserver.router.DefaultRouteAutoInjector;
 import org.javawebstack.httpserver.router.Route;

src/main/java/org/javawebstack/httpserver/adapter/untertow/UndertowHTTPSocket.java

@@ -0,0 +1,112 @@
+package org.javawebstack.httpserver.adapter.untertow;
+
+import io.undertow.server.HttpServerExchange;
+import io.undertow.util.HeaderValues;
+import io.undertow.util.HttpString;
+import org.javawebstack.httpserver.HTTPMethod;
+import org.javawebstack.httpserver.HTTPStatus;
+import org.javawebstack.httpserver.adapter.IHTTPSocket;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class UndertowHTTPSocket implements IHTTPSocket {
+
+    private final HttpServerExchange exchange;
+
+    public UndertowHTTPSocket(HttpServerExchange exchange) {
+        this.exchange = exchange;
+    }
+
+    public InputStream getInputStream() throws IOException {
+        return exchange.getInputStream();
+    }
+
+    public OutputStream getOutputStream() throws IOException {
+        return exchange.getOutputStream();
+    }
+
+    public void close() throws IOException {
+        exchange.endExchange();
+    }
+
+    public boolean isClosed() {
+        return exchange.isComplete();
+    }
+
+    public IHTTPSocket setResponseStatus(int status, String message) {
+        exchange.setStatusCode(status);
+        return this;
+    }
+
+    public IHTTPSocket setResponseHeader(String name, String value) {
+        exchange.getResponseHeaders().put(new HttpString(name), value);
+        return this;
+    }
+
+    public IHTTPSocket addResponseHeader(String name, String value) {
+        exchange.getResponseHeaders().add(new HttpString(name), value);
+        return this;
+    }
+
+    public HTTPMethod getRequestMethod() {
+        return HTTPMethod.valueOf(exchange.getRequestMethod().toString());
+    }
+
+    public String getRequestPath() {
+        return exchange.getRequestPath();
+    }
+
+    public String getRequestQuery() {
+        return exchange.getQueryString();
+    }
+
+    public String getRequestVersion() {
+        return exchange.getProtocol().toString();
+    }
+
+    public Set<String> getRequestHeaderNames() {
+        return exchange.getRequestHeaders().getHeaderNames().stream().map(HttpString::toString).collect(Collectors.toSet());
+    }
+
+    public String getRequestHeader(String name) {
+        HeaderValues values = exchange.getRequestHeaders().get(name);
+        if(values == null)
+            return null;
+        return values.getFirst();
+    }
+
+    public List<String> getRequestHeaders(String name) {
+        HeaderValues values = exchange.getRequestHeaders().get(name);
+        if(values == null)
+            return Collections.emptyList();
+        return new ArrayList<>(values);
+    }
+
+    public int getResponseStatus() {
+        return exchange.getStatusCode();
+    }
+
+    public String getResponseStatusMessage() {
+        HTTPStatus status = HTTPStatus.byStatus(getResponseStatus());
+        if(status == null)
+            return null;
+        return status.getMessage();
+    }
+
+    public void writeHeaders() throws IOException {
+        exchange.getResponseSender().send("");
+    }
+
+    public String getRemoteAddress() {
+        return exchange.getSourceAddress().getAddress().getHostAddress();
+    }
+
+    public HttpServerExchange getExchange() {
+        return exchange;
+    }
+
+}

src/main/java/org/javawebstack/httpserver/adapter/untertow/UndertowHTTPSocketServer.java

@@ -0,0 +1,49 @@
+package org.javawebstack.httpserver.adapter.untertow;
+
+import io.undertow.Undertow;
+import org.javawebstack.httpserver.adapter.IHTTPSocketHandler;
+import org.javawebstack.httpserver.adapter.IHTTPSocketServer;
+
+import java.io.IOException;
+
+public class UndertowHTTPSocketServer implements IHTTPSocketServer {
+
+    private int port = 80;
+    private Undertow server;
+    private IHTTPSocketHandler handler;
+
+    public void setPort(int port) {
+        this.port = port;
+    }
+
+    public int getPort() {
+        return port;
+    }
+
+    public void start() throws IOException {
+        server = Undertow.builder()
+                .addHttpListener(port, "0.0.0.0")
+                .setHandler(httpServerExchange -> handler.handle(new UndertowHTTPSocket(httpServerExchange)))
+                .build();
+        server.start();
+    }
+
+    public void stop() {
+        server.stop();
+    }
+
+    public void join() {
+        try {
+            server.getWorker().awaitTermination();
+        } catch (InterruptedException e) {}
+    }
+
+    public void setHandler(IHTTPSocketHandler handler) {
+        this.handler = handler;
+    }
+
+    public boolean isWebSocketSupported() {
+        return false;
+    }
+
+}