Start adding a rest test

Author: alex-spies

x-pack/plugin/esql/qa/server/single-node/build.gradle

@@ -6,6 +6,7 @@ apply plugin: 'elasticsearch.internal-test-artifact'
 dependencies {
   javaRestTestImplementation project(xpackModule('esql:qa:testFixtures'))
   javaRestTestImplementation project(xpackModule('esql:qa:server'))
+  javaRestTestImplementation project(xpackModule('esql:tools'))
   yamlRestTestImplementation project(xpackModule('esql:qa:server'))
 
   javaRestTestImplementation('org.apache.arrow:arrow-vector:16.1.0')

x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/RestEsqlIT.java

@@ -17,26 +17,34 @@
 import org.elasticsearch.client.ResponseException;
 import org.elasticsearch.common.io.Streams;
 import org.elasticsearch.common.settings.Settings;
+import org.elasticsearch.common.xcontent.XContentHelper;
 import org.elasticsearch.test.ListMatcher;
 import org.elasticsearch.test.MapMatcher;
 import org.elasticsearch.test.TestClustersThreadFilter;
 import org.elasticsearch.test.cluster.ElasticsearchCluster;
 import org.elasticsearch.test.cluster.LogType;
+import org.elasticsearch.xcontent.XContentBuilder;
 import org.elasticsearch.xcontent.XContentType;
+import org.elasticsearch.xcontent.json.JsonXContent;
 import org.elasticsearch.xpack.esql.qa.rest.RestEsqlTestCase;
 import org.hamcrest.Matchers;
 import org.junit.Assert;
 import org.junit.ClassRule;
 
+import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
 
+import static org.elasticsearch.xpack.esql.tools.ProfileParser.parseProfile;
 import static org.elasticsearch.test.ListMatcher.matchesList;
 import static org.elasticsearch.test.MapMatcher.assertMap;
 import static org.elasticsearch.test.MapMatcher.matchesMap;
@@ -330,6 +338,22 @@ public void testProfile() throws IOException {
         }
     }
 
+    public void testProfileParsing() throws IOException {
+        indexTimestampData(1);
+
+        RequestObjectBuilder builder = requestObjectBuilder().query(fromIndex() + " | stats avg(value)");
+        builder.profile(true);
+        Map<String, Object> result = runEsql(builder);
+
+        ByteArrayOutputStream os = new ByteArrayOutputStream();
+        try (XContentBuilder jsonOutputBuilder = new XContentBuilder(JsonXContent.jsonXContent, os)) {
+            parseProfile(result, jsonOutputBuilder);
+        }
+        String parsedProfile = os.toString(Charset.defaultCharset());
+
+        assertFalse(true);
+    }
+
     public void testProfileOrdinalsGroupingOperator() throws IOException {
         assumeTrue("requires pragmas", Build.current().isSnapshot());
         indexTimestampData(1);

x-pack/plugin/esql/tools/build.gradle

@@ -3,6 +3,7 @@ apply plugin: 'elasticsearch.java'
 dependencies {
   implementation project(":libs:x-content")
   implementation project(':libs:logging')
+  // Required for log4j, there's probably a more direct way to depend on it.
   implementation project(':test:framework')
 }
 

x-pack/plugin/esql/tools/src/main/java/org/elasticsearch/xpack/esql/tools/ProfileParser.java

@@ -65,7 +65,7 @@ public static void main(String[] args) throws IOException {
      * out to be tricky to use.
      */
     @SuppressWarnings("unchecked")
-    private static void parseProfile(Map<String, Object> parsedQueryResponseWithProfile, XContentBuilder outputBuilder) throws IOException {
+    public static void parseProfile(Map<String, Object> parsedQueryResponseWithProfile, XContentBuilder outputBuilder) throws IOException {
         Map<String, Object> profile = (Map<String, Object>) parsedQueryResponseWithProfile.get("profile");
         List<Map<String, Object>> drivers = (List<Map<String, Object>>) profile.get("drivers");