Internal Report Viewer: host and use the the report viewer locally

cli/pom.xml

@@ -125,6 +125,12 @@
         </dependency>
     </dependencies>
     <build>
+        <resources>
+            <resource>
+                <targetPath>report-viewer</targetPath>
+                <directory>../report-viewer/dist</directory>
+            </resource>
+        </resources>
         <plugins>
             <plugin>
                 <artifactId>maven-jar-plugin</artifactId>
@@ -154,6 +160,42 @@
                     <finalName>jplag-${project.version}</finalName>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>exec-maven-plugin</artifactId>
+                <version>1.3.2</version>
+                <executions>
+                    <execution>
+                        <id>npm install</id>
+                        <goals>
+                            <goal>exec</goal>
+                        </goals>
+                        <phase>generate-resources</phase>
+                        <configuration>
+                            <executable>npm</executable>
+                            <workingDirectory>../report-viewer</workingDirectory>
+                            <arguments>
+                                <argument>install</argument>
+                            </arguments>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>npm build</id>
+                        <goals>
+                            <goal>exec</goal>
+                        </goals>
+                        <phase>generate-resources</phase>
+                        <configuration>
+                            <executable>npm</executable>
+                            <workingDirectory>../report-viewer</workingDirectory>
+                            <arguments>
+                                <argument>run</argument>
+                                <argument>build</argument>
+                            </arguments>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
 </project>

cli/src/main/java/de/jplag/cli/CLI.java

@@ -23,6 +23,7 @@
 import de.jplag.JPlagResult;
 import de.jplag.Language;
 import de.jplag.cli.logger.CollectedLoggerFactory;
+import de.jplag.cli.server.ReportViewer;
 import de.jplag.clustering.ClusteringOptions;
 import de.jplag.clustering.Preprocessing;
 import de.jplag.exceptions.ExitException;

cli/src/main/java/de/jplag/cli/server/ContentType.java

@@ -0,0 +1,14 @@
+package de.jplag.cli.server;
+
+public enum ContentType {
+    ;
+    private final String value;
+
+    ContentType(String value) {
+        this.value = value;
+    }
+
+    public String getValue() {
+        return value;
+    }
+}

cli/src/main/java/de/jplag/cli/server/HttpMethod.java

@@ -0,0 +1,26 @@
+package de.jplag.cli.server;
+
+public enum HttpMethod {
+    GET("GET"),
+    POST("POST");
+
+    private final String name;
+
+    HttpMethod(String name) {
+        this.name = name;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public static HttpMethod fromName(String name) {
+        for (HttpMethod value : HttpMethod.values()) {
+            if (value.name.equals(name)) {
+                return value;
+            }
+        }
+
+        return null;
+    }
+}

cli/src/main/java/de/jplag/cli/server/ReportViewer.java

@@ -0,0 +1,79 @@
+package de.jplag.cli.server;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetSocketAddress;
+
+import org.apache.commons.lang3.ArrayUtils;
+import org.apache.commons.lang3.tuple.Pair;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+
+public class ReportViewer implements HttpHandler {
+    private static final Logger logger = LoggerFactory.getLogger(ReportViewer.class);
+    private static final int SUCCESS_RESPONSE = 200;
+    private static final int METHOD_NOT_ALLOWED_RESPONSE = 405;
+    private static final int NOT_FOUND_RESPONSE = 404;
+
+    private final RoutingTree routingTree;
+
+    private HttpServer server;
+
+    public ReportViewer() {
+        this.routingTree = new RoutingTree();
+
+        this.routingTree.insertRouting(new RoutingPath(""), new RoutingResources("report-viewer"));
+    }
+
+    public int start() throws IOException {
+        if (server != null) {
+            throw new IllegalStateException("Server already started");
+        }
+        server = HttpServer.create(new InetSocketAddress(0), 0);
+        server.createContext("/", this);
+        server.setExecutor(null);
+        server.start();
+
+        return server.getAddress().getPort();
+    }
+
+    public void stop() {
+        server.stop(0);
+    }
+
+    public void handle(HttpExchange exchange) throws IOException {
+        if (!exchange.getRequestMethod().equals("GET")) {
+            exchange.sendResponseHeaders(METHOD_NOT_ALLOWED_RESPONSE, 0);
+            exchange.getResponseBody().close();
+            return;
+        }
+
+        RoutingPath path = new RoutingPath(exchange.getRequestURI().getPath());
+        Pair<RoutingPath, Routing> resolved = this.routingTree.resolveRouting(path);
+        HttpMethod method = HttpMethod.fromName(exchange.getRequestMethod());
+
+        if (resolved == null || !ArrayUtils.contains(resolved.getRight().allowedMethods(), method)) {
+            exchange.sendResponseHeaders(NOT_FOUND_RESPONSE, 0);
+            exchange.close();
+            return;
+        }
+
+        logger.debug("Serving {}", path);
+
+        Pair<InputStream, ContentType> data = resolved.getRight().fetchData(resolved.getLeft(), exchange, this);
+
+        if (data.getRight() != null) {
+            exchange.getResponseHeaders().set("Content-Type", data.getRight().getValue());
+        }
+        exchange.sendResponseHeaders(SUCCESS_RESPONSE, 0);
+
+        data.getLeft().transferTo(exchange.getResponseBody());
+        exchange.getResponseBody().flush();
+        exchange.getResponseBody().close();
+        data.getLeft().close();
+    }
+}

cli/src/main/java/de/jplag/cli/server/Routing.java

@@ -0,0 +1,15 @@
+package de.jplag.cli.server;
+
+import java.io.InputStream;
+
+import org.apache.commons.lang3.tuple.Pair;
+
+import com.sun.net.httpserver.HttpExchange;
+
+public interface Routing {
+    default HttpMethod[] allowedMethods() {
+        return new HttpMethod[] {HttpMethod.GET};
+    }
+
+    Pair<InputStream, ContentType> fetchData(RoutingPath subPath, HttpExchange request, ReportViewer viewer);
+}

cli/src/main/java/de/jplag/cli/server/RoutingPath.java

@@ -0,0 +1,49 @@
+package de.jplag.cli.server;
+
+public class RoutingPath {
+    private final String[] components;
+    private final int offset;
+
+    public RoutingPath(String path) {
+        this.components = path.split("/");
+        this.offset = 0;
+    }
+
+    private RoutingPath(String[] components, int offset) {
+        this.components = components;
+        this.offset = offset;
+    }
+
+    public String head() {
+        return components[offset];
+    }
+
+    public RoutingPath tail() {
+        if (!hasTail()) {
+            throw new IllegalStateException("Routing path is done.");
+        }
+
+        return new RoutingPath(this.components, this.offset + 1);
+    }
+
+    public boolean hasTail() {
+        return this.components.length > this.offset;
+    }
+
+    public boolean isEmpty() {
+        return this.offset == this.components.length;
+    }
+
+    public String asPath() {
+        StringBuilder builder = new StringBuilder();
+
+        for (int i = this.offset; i < this.components.length; i++) {
+            if (i > this.offset) {
+                builder.append("/");
+            }
+            builder.append(this.components[i]);
+        }
+
+        return builder.toString();
+    }
+}

cli/src/main/java/de/jplag/cli/server/RoutingResources.java

@@ -0,0 +1,35 @@
+package de.jplag.cli.server;
+
+import java.io.InputStream;
+
+import org.apache.commons.lang3.tuple.Pair;
+
+import com.sun.net.httpserver.HttpExchange;
+
+public class RoutingResources implements Routing {
+    private String prefix;
+
+    public RoutingResources(String prefix) {
+        this.prefix = prefix;
+
+        if (!this.prefix.startsWith("/")) {
+            this.prefix = "/" + this.prefix;
+        }
+
+        if (!this.prefix.endsWith("/")) {
+            this.prefix = this.prefix + "/";
+        }
+    }
+
+    @Override
+    public Pair<InputStream, ContentType> fetchData(RoutingPath subPath, HttpExchange request, ReportViewer viewer) {
+        String fullPath = this.prefix + subPath.asPath();
+        InputStream stream = this.getClass().getResourceAsStream(fullPath);
+
+        if (stream == null) {
+            return null;
+        }
+
+        return Pair.of(stream, null);
+    }
+}