Skip to content

Commit 7cae7e2

Browse files
Fix RequestConfiguration (#8514) (#8515)
Co-authored-by: Florian Bernd <[email protected]>
1 parent 8819cd3 commit 7cae7e2

File tree

4 files changed

+12
-14
lines changed

4 files changed

+12
-14
lines changed

src/Elastic.Clients.Elasticsearch/_Shared/Api/BulkRequest.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public partial class BulkRequest : IStreamSerializable
2525

2626
internal Request Self => this;
2727

28-
protected internal override IRequestConfiguration RequestConfig => RequestConfigSingleton;
28+
public override IRequestConfiguration RequestConfiguration => RequestConfigSingleton;
2929

3030
public BulkOperationsCollection? Operations { get; set; }
3131

src/Elastic.Clients.Elasticsearch/_Shared/Client/ElasticsearchClient.cs

+6-6
Original file line numberDiff line numberDiff line change
@@ -161,8 +161,8 @@ ValueTask<TResponse> SendRequest()
161161
var openTelemetryDataMutator = GetOpenTelemetryDataMutator<TRequest, TRequestParameters>(request, resolvedRouteValues);
162162

163163
return isAsync
164-
? new ValueTask<TResponse>(_transport.RequestAsync<TResponse>(endpointPath, postData, openTelemetryDataMutator, request.RequestConfig, cancellationToken))
165-
: new ValueTask<TResponse>(_transport.Request<TResponse>(endpointPath, postData, openTelemetryDataMutator, request.RequestConfig));
164+
? new ValueTask<TResponse>(_transport.RequestAsync<TResponse>(endpointPath, postData, openTelemetryDataMutator, request.RequestConfiguration, cancellationToken))
165+
: new ValueTask<TResponse>(_transport.Request<TResponse>(endpointPath, postData, openTelemetryDataMutator, request.RequestConfiguration));
166166
}
167167

168168
async ValueTask<TResponse> SendRequestWithProductCheck()
@@ -189,15 +189,15 @@ async ValueTask<TResponse> SendRequestWithProductCheckCore()
189189
// Attach product check header
190190

191191
// TODO: The copy constructor should accept null values
192-
var requestConfig = (request.RequestConfig is null)
192+
var requestConfig = (request.RequestConfiguration is null)
193193
? new RequestConfiguration()
194194
{
195195
ResponseHeadersToParse = new HeadersList("x-elastic-product")
196196
}
197-
: new RequestConfiguration(request.RequestConfig)
197+
: new RequestConfiguration(request.RequestConfiguration)
198198
{
199-
ResponseHeadersToParse = (request.RequestConfig.ResponseHeadersToParse is { Count: > 0 })
200-
? new HeadersList(request.RequestConfig.ResponseHeadersToParse, "x-elastic-product")
199+
ResponseHeadersToParse = (request.RequestConfiguration.ResponseHeadersToParse is { Count: > 0 })
200+
? new HeadersList(request.RequestConfiguration.ResponseHeadersToParse, "x-elastic-product")
201201
: new HeadersList("x-elastic-product")
202202
};
203203

src/Elastic.Clients.Elasticsearch/_Shared/Core/Request/PlainRequest.cs

-6
Original file line numberDiff line numberDiff line change
@@ -66,10 +66,4 @@ public string? SourceQueryString
6666
get => Q<string>("source");
6767
set => Q("source", value);
6868
}
69-
70-
/// <summary>
71-
/// Specify settings for this request alone, handy if you need a custom timeout or want to bypass sniffing, retries
72-
/// </summary>
73-
[JsonIgnore]
74-
public IRequestConfiguration? RequestConfiguration { get; set; }
7569
}

src/Elastic.Clients.Elasticsearch/_Shared/Core/Request/Request.cs

+5-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,11 @@ public abstract class Request
2020
internal Request()
2121
{ }
2222

23-
[JsonIgnore] protected internal virtual IRequestConfiguration? RequestConfig { get; set; }
23+
/// <summary>
24+
/// Specify settings for this request alone, handy if you need a custom timeout or want to bypass sniffing, retries
25+
/// </summary>
26+
[JsonIgnore]
27+
public virtual IRequestConfiguration? RequestConfiguration { get; set; }
2428

2529
/// <summary>
2630
/// The default HTTP method for the request which is based on the Elasticsearch Specification endpoint definition.

0 commit comments

Comments
 (0)