Add MainRestPlugin

codelibs · Nov 12, 2023 · 2ac50d0 · 2ac50d0
1 parent b9be910
commit 2ac50d0
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 0 deletions.
diff --git a/pom.xml b/pom.xml
@@ -296,6 +296,11 @@
 			<artifactId>transport-netty4</artifactId>
 			<version>${elasticsearch.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.codelibs.elasticsearch.module</groupId>
+			<artifactId>rest-root</artifactId>
+			<version>${elasticsearch.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>args4j</groupId>
 			<artifactId>args4j</artifactId>

diff --git a/src/main/java/org/codelibs/elasticsearch/runner/ElasticsearchClusterRunner.java b/src/main/java/org/codelibs/elasticsearch/runner/ElasticsearchClusterRunner.java
@@ -142,6 +142,7 @@ public class ElasticsearchClusterRunner implements Closeable {
             // "org.elasticsearch.repositories.azure.AzureRepositoryPlugin", //
             "org.elasticsearch.repositories.gcs.GoogleCloudStoragePlugin", //
             "org.elasticsearch.repositories.s3.S3RepositoryPlugin", //
+            "org.elasticsearch.rest.root.MainRestPlugin", //
             "org.elasticsearch.plugin.repository.url.URLRepositoryPlugin", //
             "org.elasticsearch.runtimefields.RuntimeFieldsCommonPlugin", //
             "org.elasticsearch.transport.netty4.Netty4Plugin", //

diff --git a/src/test/java/org/codelibs/elasticsearch/runner/ElasticsearchClusterRunnerTest.java b/src/test/java/org/codelibs/elasticsearch/runner/ElasticsearchClusterRunnerTest.java
@@ -206,6 +206,17 @@ public void test_runCluster() throws Exception {
         final Node node = runner.node();
 
         // http access
+        // root
+        try (CurlResponse curlResponse =
+                     EcrCurl.get(node, "/").execute()) {
+            final String content = curlResponse.getContentAsString();
+            assertNotNull(content);
+            assertTrue(content.contains("cluster_name"));
+            final Map<String, Object> map = curlResponse.getContent(EcrCurl.jsonParser());
+            assertNotNull(map);
+            assertEquals(clusterName, map.get("cluster_name").toString());
+        }
+
         // get
         try (CurlResponse curlResponse =
                 EcrCurl.get(node, "/_search").header("Content-Type", "application/json").param("q", "*:*").execute()) {