X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/e5a67d6ce1312fe118e99b8bc8fb2f55ed1dbcf2..6b04197eaabda1bc2785308faf7ba62b3f45062b:/src/main/java/org/asamk/signal/http/HttpServerHandler.java diff --git a/src/main/java/org/asamk/signal/http/HttpServerHandler.java b/src/main/java/org/asamk/signal/http/HttpServerHandler.java index 39e7f51e..b888464e 100644 --- a/src/main/java/org/asamk/signal/http/HttpServerHandler.java +++ b/src/main/java/org/asamk/signal/http/HttpServerHandler.java @@ -54,7 +54,7 @@ public class HttpServerHandler { logger.info("Starting server on " + address.toString()); final var server = HttpServer.create(address, 0); - server.setExecutor(Executors.newFixedThreadPool(10)); + server.setExecutor(Executors.newCachedThreadPool()); server.createContext("/api/v1/rpc", this::handleRpcEndpoint); server.createContext("/api/v1/events", this::handleEventsEndpoint); @@ -201,22 +201,22 @@ public class HttpServerHandler { } private List getManagerFromQuery(final Map query) { - List managers; if (m != null) { - managers = List.of(m); - } else { + return List.of(m); + } + if (c != null) { final var account = query.get("account"); if (account == null || account.isEmpty()) { - managers = c.getManagers(); + return c.getManagers(); } else { final var manager = c.getManager(account); if (manager == null) { return null; } - managers = List.of(manager); + return List.of(manager); } } - return managers; + return List.of(); } private List> subscribeReceiveHandlers(