import org.asamk.signal.manager.Manager;
import org.asamk.signal.manager.MultiAccountManager;
import org.asamk.signal.manager.api.Pair;
-import org.asamk.signal.manager.util.Utils;
import org.asamk.signal.util.Util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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);
return;
}
- if (!"application/json".equals(httpExchange.getRequestHeaders().getFirst("Content-Type"))) {
+ final var contentType = httpExchange.getRequestHeaders().getFirst("Content-Type");
+ if (contentType == null || !contentType.startsWith("application/json")) {
sendResponse(415, null, httpExchange);
return;
}
try {
final var queryString = httpExchange.getRequestURI().getQuery();
- final var query = queryString == null ? Map.<String, String>of() : Utils.getQueryMap(queryString);
+ final var query = queryString == null ? Map.<String, String>of() : Util.getQueryMap(queryString);
List<Manager> managers = getManagerFromQuery(query);
if (managers == null) {