honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add a flag to allow and disable sites (http.disable_sites)

This commit is contained in:
kimchy 2011-05-28 19:04:46 +03:00
parent 94434a7522
commit 3025205063
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/elasticsearch/src/main/java/org/elasticsearch/http/HttpServer.java
View File

@ -49,6 +49,8 @@ public class HttpServer extends AbstractLifecycleComponent<HttpServer> {
private final TransportNodesInfoAction nodesInfoAction; private final TransportNodesInfoAction nodesInfoAction;
private final boolean disableSites;
@Inject public HttpServer(Settings settings, Environment environment, HttpServerTransport transport, @Inject public HttpServer(Settings settings, Environment environment, HttpServerTransport transport,
RestController restController, TransportNodesInfoAction nodesInfoAction) { RestController restController, TransportNodesInfoAction nodesInfoAction) {
super(settings); super(settings);
@ -57,6 +59,8 @@ public class HttpServer extends AbstractLifecycleComponent<HttpServer> {
this.restController = restController; this.restController = restController;
this.nodesInfoAction = nodesInfoAction; this.nodesInfoAction = nodesInfoAction;
this.disableSites = componentSettings.getAsBoolean("disable_sites", false);
transport.httpServerAdapter(new Dispatcher(this)); transport.httpServerAdapter(new Dispatcher(this));
} }
@ -107,6 +111,10 @@ public class HttpServer extends AbstractLifecycleComponent<HttpServer> {
} }
private void handlePluginSite(HttpRequest request, HttpChannel channel) { private void handlePluginSite(HttpRequest request, HttpChannel channel) {
if (disableSites) {
channel.sendResponse(new StringRestResponse(FORBIDDEN));
return;
}
if (request.method() != RestRequest.Method.GET) { if (request.method() != RestRequest.Method.GET) {
channel.sendResponse(new StringRestResponse(FORBIDDEN)); channel.sendResponse(new StringRestResponse(FORBIDDEN));
return; return;