Implement proper deserialization of EsqlQueryResponse

src/Elastic.Clients.Elasticsearch.Shared/Api/Esql/EsqlQueryRequest.cs

@@ -0,0 +1,66 @@
+// Licensed to Elasticsearch B.V under one or more agreements.
+// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information.
+
+using System.IO;
+using System.Runtime.CompilerServices;
+using System.Threading;
+using System.Threading.Tasks;
+
+using Elastic.Transport;
+
+namespace Elastic.Clients.Elasticsearch.Esql;
+
+internal sealed class EsqlResponseBuilder : CustomResponseBuilder
+{
+	public override object DeserializeResponse(Serializer serializer, ApiCallDetails response, Stream stream)
+	{
+		var bytes = stream switch
+		{
+			MemoryStream ms => ms.ToArray(),
+			_ => BytesFromStream(stream)
+		};
+
+		return new EsqlQueryResponse { Data = bytes };
+
+		[MethodImpl(MethodImplOptions.AggressiveInlining)]
+		static byte[] BytesFromStream(Stream stream)
+		{
+			using var binaryReader = new BinaryReader(stream);
+
+			return binaryReader.ReadBytes((int)stream.Length);
+		}
+	}
+
+	public override async Task<object> DeserializeResponseAsync(Serializer serializer, ApiCallDetails response, Stream stream,
+		CancellationToken ctx = new CancellationToken())
+	{
+		var bytes = stream switch
+		{
+			MemoryStream ms => ms.ToArray(),
+			_ => await BytesFromStreamAsync(stream, ctx).ConfigureAwait(false)
+		};
+
+		return new EsqlQueryResponse { Data = bytes };
+
+		[MethodImpl(MethodImplOptions.AggressiveInlining)]
+		static async Task<byte[]> BytesFromStreamAsync(Stream stream, CancellationToken cancellationToken)
+		{
+			using var ms = new MemoryStream();
+#if NETSTANDARD2_1_OR_GREATER || NET6_0_OR_GREATER
+			await stream.CopyToAsync(ms, cancellationToken).ConfigureAwait(false);
+#else
+			await stream.CopyToAsync(ms).ConfigureAwait(false);
+#endif
+
+			return ms.ToArray();
+		}
+	}
+}
+
+public sealed partial class EsqlQueryRequestParameters
+{
+	private static readonly EsqlResponseBuilder ResponseBuilder = new();
+
+	public EsqlQueryRequestParameters() => CustomResponseBuilder = ResponseBuilder;
+}

src/Elastic.Clients.Elasticsearch.Shared/Api/Esql/EsqlQueryResponse.cs

@@ -0,0 +1,10 @@
+// Licensed to Elasticsearch B.V under one or more agreements.
+// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information.
+
+namespace Elastic.Clients.Elasticsearch.Esql;
+
+public sealed partial class EsqlQueryResponse
+{
+	public byte[] Data { get; init; }
+}

src/Elastic.Clients.Elasticsearch/_Generated/Api/AsyncSearch/AsyncSearchStatusRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.AsyncSearch;
 
-public sealed class AsyncSearchStatusRequestParameters : RequestParameters
+public sealed partial class AsyncSearchStatusRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/AsyncSearch/DeleteAsyncSearchRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.AsyncSearch;
 
-public sealed class DeleteAsyncSearchRequestParameters : RequestParameters
+public sealed partial class DeleteAsyncSearchRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/AsyncSearch/GetAsyncSearchRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.AsyncSearch;
 
-public sealed class GetAsyncSearchRequestParameters : RequestParameters
+public sealed partial class GetAsyncSearchRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Specifies how long the async search should be available in the cluster.<br/>When not specified, the `keep_alive` set with the corresponding submit async request will be used.<br/>Otherwise, it is possible to override the value and extend the validity of the request.<br/>When this period expires, the search, if still running, is cancelled.<br/>If the search is completed, its saved results are deleted.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/AsyncSearch/SubmitAsyncSearchRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.AsyncSearch;
 
-public sealed class SubmitAsyncSearchRequestParameters : RequestParameters
+public sealed partial class SubmitAsyncSearchRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes `_all` string or when no indices have been specified)</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/BulkRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class BulkRequestParameters : RequestParameters
+public sealed partial class BulkRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>ID of the pipeline to use to preprocess incoming documents.<br/>If the index has a default ingest pipeline specified, then setting the value to `_none` disables the default ingest pipeline for this request.<br/>If a final pipeline is configured it will always run, regardless of the value of this parameter.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/ClearScrollRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class ClearScrollRequestParameters : RequestParameters
+public sealed partial class ClearScrollRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/ClosePointInTimeRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class ClosePointInTimeRequestParameters : RequestParameters
+public sealed partial class ClosePointInTimeRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Cluster/AllocationExplainRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Cluster;
 
-public sealed class AllocationExplainRequestParameters : RequestParameters
+public sealed partial class AllocationExplainRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If true, returns information about disk usage and shard sizes.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Cluster/ClusterStatsRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Cluster;
 
-public sealed class ClusterStatsRequestParameters : RequestParameters
+public sealed partial class ClusterStatsRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `true`, returns settings in flat format.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Cluster/GetClusterSettingsRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Cluster;
 
-public sealed class GetClusterSettingsRequestParameters : RequestParameters
+public sealed partial class GetClusterSettingsRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `true`, returns settings in flat format.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Cluster/HealthRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Cluster;
 
-public sealed class HealthRequestParameters : RequestParameters
+public sealed partial class HealthRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Whether to expand wildcard expression to concrete indices that are open, closed or both.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Cluster/PendingTasksRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Cluster;
 
-public sealed class PendingTasksRequestParameters : RequestParameters
+public sealed partial class PendingTasksRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `true`, the request retrieves information from the local node only.<br/>If `false`, information is retrieved from the master node.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/CountRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class CountRequestParameters : RequestParameters
+public sealed partial class CountRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `false`, the request returns an error if any wildcard expression, index alias, or `_all` value targets only missing or closed indices.<br/>This behavior applies even if the request targets other open indices.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/CreateRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class CreateRequestParameters : RequestParameters
+public sealed partial class CreateRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>ID of the pipeline to use to preprocess incoming documents.<br/>If the index has a default ingest pipeline specified, then setting the value to `_none` disables the default ingest pipeline for this request.<br/>If a final pipeline is configured it will always run, regardless of the value of this parameter.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/DanglingIndices/ListDanglingIndicesRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.DanglingIndices;
 
-public sealed class ListDanglingIndicesRequestParameters : RequestParameters
+public sealed partial class ListDanglingIndicesRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/DeleteByQueryRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class DeleteByQueryRequestParameters : RequestParameters
+public sealed partial class DeleteByQueryRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `false`, the request returns an error if any wildcard expression, index alias, or `_all` value targets only missing or closed indices.<br/>This behavior applies even if the request targets other open indices.<br/>For example, a request targeting `foo*,bar*` returns an error if an index starts with `foo` but no index starts with `bar`.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/DeleteByQueryRethrottleRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class DeleteByQueryRethrottleRequestParameters : RequestParameters
+public sealed partial class DeleteByQueryRethrottleRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>The throttle for this request in sub-requests per second.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/DeleteRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class DeleteRequestParameters : RequestParameters
+public sealed partial class DeleteRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Only perform the operation if the document has this primary term.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/DeleteScriptRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class DeleteScriptRequestParameters : RequestParameters
+public sealed partial class DeleteScriptRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Period to wait for a connection to the master node.<br/>If no response is received before the timeout expires, the request fails and returns an error.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Enrich/DeletePolicyRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Enrich;
 
-public sealed class DeletePolicyRequestParameters : RequestParameters
+public sealed partial class DeletePolicyRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Enrich/EnrichStatsRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Enrich;
 
-public sealed class EnrichStatsRequestParameters : RequestParameters
+public sealed partial class EnrichStatsRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Enrich/ExecutePolicyRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Enrich;
 
-public sealed class ExecutePolicyRequestParameters : RequestParameters
+public sealed partial class ExecutePolicyRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If `true`, the request blocks other enrich policy execution requests until complete.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Enrich/GetPolicyRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Enrich;
 
-public sealed class GetPolicyRequestParameters : RequestParameters
+public sealed partial class GetPolicyRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Enrich/PutPolicyRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Enrich;
 
-public sealed class PutPolicyRequestParameters : RequestParameters
+public sealed partial class PutPolicyRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Eql/EqlDeleteRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Eql;
 
-public sealed class EqlDeleteRequestParameters : RequestParameters
+public sealed partial class EqlDeleteRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Eql/EqlGetRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Eql;
 
-public sealed class EqlGetRequestParameters : RequestParameters
+public sealed partial class EqlGetRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Period for which the search and its results are stored on the cluster.<br/>Defaults to the keep_alive value set by the search’s EQL search API request.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/Eql/EqlSearchRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Eql;
 
-public sealed class EqlSearchRequestParameters : RequestParameters
+public sealed partial class EqlSearchRequestParameters : RequestParameters
 {
 	public bool? AllowNoIndices { get => Q<bool?>("allow_no_indices"); set => Q("allow_no_indices", value); }
 	public ICollection<Elastic.Clients.Elasticsearch.ExpandWildcard>? ExpandWildcards { get => Q<ICollection<Elastic.Clients.Elasticsearch.ExpandWildcard>?>("expand_wildcards"); set => Q("expand_wildcards", value); }

src/Elastic.Clients.Elasticsearch/_Generated/Api/Eql/GetEqlStatusRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Eql;
 
-public sealed class GetEqlStatusRequestParameters : RequestParameters
+public sealed partial class GetEqlStatusRequestParameters : RequestParameters
 {
 }
 

src/Elastic.Clients.Elasticsearch/_Generated/Api/Esql/EsqlQueryRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch.Esql;
 
-public sealed class EsqlQueryRequestParameters : RequestParameters
+public sealed partial class EsqlQueryRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>The character to use between values within a CSV row. Only valid for the CSV format.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/ExistsRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class ExistsRequestParameters : RequestParameters
+public sealed partial class ExistsRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Specifies the node or shard the operation should be performed on.<br/>Random by default.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/ExistsSourceRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class ExistsSourceRequestParameters : RequestParameters
+public sealed partial class ExistsSourceRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Specifies the node or shard the operation should be performed on.<br/>Random by default.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/ExplainRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class ExplainRequestParameters : RequestParameters
+public sealed partial class ExplainRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Analyzer to use for the query string.<br/>This parameter can only be used when the `q` query string parameter is specified.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/FieldCapsRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class FieldCapsRequestParameters : RequestParameters
+public sealed partial class FieldCapsRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>If false, the request returns an error if any wildcard expression, index alias,<br/>or `_all` value targets only missing or closed indices. This behavior applies even if the request targets other open indices. For example, a request<br/>targeting `foo*,bar*` returns an error if an index starts with foo but no index starts with bar.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/GetRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class GetRequestParameters : RequestParameters
+public sealed partial class GetRequestParameters : RequestParameters
 {
 	/// <summary>
 	/// <para>Specifies the node or shard the operation should be performed on. Random by default.</para>

src/Elastic.Clients.Elasticsearch/_Generated/Api/GetScriptContextRequest.g.cs

@@ -29,7 +29,7 @@
 
 namespace Elastic.Clients.Elasticsearch;
 
-public sealed class GetScriptContextRequestParameters : RequestParameters
+public sealed partial class GetScriptContextRequestParameters : RequestParameters
 {
 }