Class Server

src/main/java/fielded/webserver/Server.java:23–362

import java.net.InetSocketAddress;
import java.net.SocketException;
import java.security.KeyStore;
import java.util.*;
import java.util.concurrent.*;
import java.util.function.Predicate;
import java.util.function.Supplier;

public class Server {

    public static final String FIELD_FILESYSTEM = "/field/";
    Map<String, String> fixedResources = new HashMap<String, String>();
    Set<String> documentRoots = new LinkedHashSet<String>();

    public final NanoHTTPD server;
    public final WebSocketServer webSocketServer;

    Deque<Handler> handlers = new LinkedList<>();
    List<URIHandler> uriHandlers = new ArrayList<>();

    BiMap<String, WebSocket> knownSockets = HashBiMap.create();
    public final int port;
    public final int websocketPort;


    public interface Handler {
        // handle gets called in the main thread
        Object handle(Server server, WebSocket from, String address, Object payload);
    }

    public interface HandlerInMainThread extends Handler {
        default boolean will(Server server, WebSocket from, String address, Object payload) {
            return true;
        }
    }

    public interface URIHandler {
        NanoHTTPD.Response serve(String uri, NanoHTTPD.Method method, Map<String, String> headers, Map<String, String> parms, Map<String, String> files);
    }

    long uniq = 0;

    static public ThreadLocal<WebSocket> currentWebSocket = new ThreadLocal();


    public int getWebsocketPort() {
        return websocketPort;
    }

    public int getPort() {
        return port;
    }


    public Server(int port, int websocketPort) throws IOException {
        this.port = port;
        this.websocketPort = websocketPort;
        server = new NanoHTTPD(port) {
            @Override
            Response serve(String uri, Method method, Map<String, String> headers, Map<String, String> parms, Map<String, String> files) {