Skip to content

Commit b25efd6

Browse files
stevejgordongithub-actions[bot]
authored andcommitted
Avoid simplifying scroll IDs on responses (#6480)
* Update to latest schema * Don't simplify ScrollId on responses
1 parent 0b32a1c commit b25efd6

File tree

13 files changed

+35
-45
lines changed

13 files changed

+35
-45
lines changed

src/Elastic.Clients.Elasticsearch/Common/Infer/IndexName/IndexName.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@ private IndexName(string index, Type type, string cluster = null)
3535
Cluster = cluster;
3636
}
3737

38-
public string Cluster { get; }
39-
public string Name { get; }
40-
public Type Type { get; }
38+
internal string Cluster { get; }
39+
internal string Name { get; }
40+
internal Type Type { get; }
4141

4242
internal string DebugDisplay => Type == null ? Name : $"{nameof(IndexName)} for typeof: {Type?.Name}";
4343

src/Elastic.Clients.Elasticsearch/Common/UrlParameters/Username/Username.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class Username : IEquatable<Username>, IUrlParameter
1515
{
1616
public Username(string name) => Value = name?.Trim();
1717

18-
internal string Value { get; }
18+
public string Value { get; }
1919

2020
private string DebugDisplay => Value;
2121

@@ -25,7 +25,7 @@ public class Username : IEquatable<Username>, IUrlParameter
2525

2626
string IUrlParameter.GetString(ITransportConfiguration? settings) => Value;
2727

28-
public override string ToString() => DebugDisplay;
28+
public override string ToString() => Value;
2929

3030
public static implicit operator Username(string name) => name.IsNullOrEmpty() ? null : new Username(name);
3131

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public sealed partial class ScrollResponse<TDocument> : ElasticsearchResponseBas
5858

5959
[JsonInclude]
6060
[JsonPropertyName("_scroll_id")]
61-
public string? ScrollId { get; init; }
61+
public Elastic.Clients.Elasticsearch.ScrollId? ScrollId { get; init; }
6262

6363
[JsonInclude]
6464
[JsonPropertyName("_shards")]

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public sealed partial class SearchResponse<TDocument> : ElasticsearchResponseBas
5858

5959
[JsonInclude]
6060
[JsonPropertyName("_scroll_id")]
61-
public string? ScrollId { get; init; }
61+
public Elastic.Clients.Elasticsearch.ScrollId? ScrollId { get; init; }
6262

6363
[JsonInclude]
6464
[JsonPropertyName("_shards")]

src/Elastic.Clients.Elasticsearch/_Generated/Types/AsyncSearch/AsyncSearch.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public partial class AsyncSearch<TDocument>
3232

3333
[JsonInclude]
3434
[JsonPropertyName("_scroll_id")]
35-
public string? ScrollId { get; init; }
35+
public Elastic.Clients.Elasticsearch.ScrollId? ScrollId { get; init; }
3636

3737
[JsonInclude]
3838
[JsonPropertyName("_shards")]

src/Elastic.Clients.Elasticsearch/_Generated/Types/Enums/Enums.Security.g.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,8 @@ public enum ClusterPrivilege
151151
Monitor,
152152
[EnumMember(Value = "manage_watcher")]
153153
ManageWatcher,
154+
[EnumMember(Value = "manage_user_profile")]
155+
ManageUserProfile,
154156
[EnumMember(Value = "manage_transform")]
155157
ManageTransform,
156158
[EnumMember(Value = "manage_token")]
@@ -232,6 +234,8 @@ public override ClusterPrivilege Read(ref Utf8JsonReader reader, Type typeToConv
232234
return ClusterPrivilege.Monitor;
233235
case "manage_watcher":
234236
return ClusterPrivilege.ManageWatcher;
237+
case "manage_user_profile":
238+
return ClusterPrivilege.ManageUserProfile;
235239
case "manage_transform":
236240
return ClusterPrivilege.ManageTransform;
237241
case "manage_token":
@@ -327,6 +331,9 @@ public override void Write(Utf8JsonWriter writer, ClusterPrivilege value, JsonSe
327331
case ClusterPrivilege.ManageWatcher:
328332
writer.WriteStringValue("manage_watcher");
329333
return;
334+
case ClusterPrivilege.ManageUserProfile:
335+
writer.WriteStringValue("manage_user_profile");
336+
return;
330337
case ClusterPrivilege.ManageTransform:
331338
writer.WriteStringValue("manage_transform");
332339
return;

src/Elastic.Clients.Elasticsearch/_Generated/Types/Migration/MigrationFeature.g.cs

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -29,17 +29,5 @@ public partial class MigrationFeature
2929
[JsonInclude]
3030
[JsonPropertyName("feature_name")]
3131
public string FeatureName { get; init; }
32-
33-
[JsonInclude]
34-
[JsonPropertyName("indices")]
35-
public IReadOnlyCollection<Elastic.Clients.Elasticsearch.Migration.MigrationFeatureIndexInfo> Indices { get; init; }
36-
37-
[JsonInclude]
38-
[JsonPropertyName("migration_status")]
39-
public Elastic.Clients.Elasticsearch.Migration.MigrationStatus MigrationStatus { get; init; }
40-
41-
[JsonInclude]
42-
[JsonPropertyName("minimum_index_version")]
43-
public string MinimumIndexVersion { get; init; }
4432
}
4533
}

src/Elastic.Clients.Elasticsearch/_Generated/Types/ResponseBody.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public partial class ResponseBody<TDocument>
3232

3333
[JsonInclude]
3434
[JsonPropertyName("_scroll_id")]
35-
public string? ScrollId { get; init; }
35+
public Elastic.Clients.Elasticsearch.ScrollId? ScrollId { get; init; }
3636

3737
[JsonInclude]
3838
[JsonPropertyName("_shards")]

tests/Tests/AsyncSearch/AsyncSearchApiTests.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,8 @@ public AsyncSearchApiTests(ReadOnlyCluster cluster, EndpointUsage usage) : base(
9494
u.Calls<GetAsyncSearchRequestDescriptor<Project>, GetAsyncSearchRequest, GetAsyncSearchResponse<Project>>(
9595
v => new GetAsyncSearchRequest(v),
9696
(v, d) => d,
97-
(v, c, f) => c.AsyncSearch.Get<Project>(v, f),
98-
(v, c, f) => c.AsyncSearch.GetAsync<Project>(v, f),
97+
(v, c, f) => c.AsyncSearch.Get(v, f),
98+
(v, c, f) => c.AsyncSearch.GetAsync(v, f),
9999
(v, c, r) => c.AsyncSearch.Get<Project>(r),
100100
(v, c, r) => c.AsyncSearch.GetAsync<Project>(r),
101101
uniqueValueSelector: values => values.ExtendedValue<string>("id")
@@ -120,6 +120,8 @@ public AsyncSearchApiTests(ReadOnlyCluster cluster, EndpointUsage usage) : base(
120120
public async Task AsyncSearchSubmitResponse() => await Assert<AsyncSearchSubmitResponse<Project>>(SubmitStep, r =>
121121
{
122122
r.ShouldBeValid();
123+
r.Id.Should().NotBeNullOrEmpty();
124+
// TODO - MORE ASSERTIONS
123125
r.Response.Should().NotBeNull();
124126
r.Response.Took.Should().BeGreaterOrEqualTo(0);
125127
});

tests/Tests/Common/Infer/Indices/IndicesTests.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,11 +108,12 @@ public async Task Serializes_All_Correctly()
108108
}
109109

110110
[U]
111-
public async void Deserializes_All_Correctly()
111+
public void Deserializes_All_Correctly()
112112
{
113113
const string json = @"{""indices"":""_all""}";
114114
var obj = DeserializeJsonString<TestThing>(json);
115-
await Verifier.Verify(obj);
115+
obj.Indices.Should().HaveCount(1);
116+
obj.Indices.First().Name.Should().Be("_all");
116117
}
117118

118119
[U]

tests/Tests/Serialization/Documents/MGetSerialization.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,9 @@ public async Task DeserializesError()
2525
var error = search.Docs.First().Item2;
2626
error.Should().NotBeNull();
2727

28-
await Verifier.Verify(error);
28+
error.Id.Should().Be("1001");
29+
error.Index.Should().Be("devs");
30+
31+
await Verifier.Verify(error.Error);
2932
}
3033
}

tests/Tests/_VerifySnapshots/IndicesSerializationTests.Deserializes_All_Correctly.verified.txt

Lines changed: 0 additions & 7 deletions
This file was deleted.
Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,10 @@
11
{
2-
Id: 1001,
3-
Index: devs,
4-
Error: {
5-
Reason: routing is required for [devs]/[1001],
6-
RootCause: [
7-
{
8-
Reason: routing is required for [devs]/[1001],
9-
Type: routing_missing_exception
10-
}
11-
],
12-
Type: routing_missing_exception
13-
}
2+
Reason: routing is required for [devs]/[1001],
3+
RootCause: [
4+
{
5+
Reason: routing is required for [devs]/[1001],
6+
Type: routing_missing_exception
7+
}
8+
],
9+
Type: routing_missing_exception
1410
}

0 commit comments

Comments
 (0)