Skip to content

Commit f44a8c1

Browse files
github-actions[bot]stevejgordon
github-actions[bot]
and
stevejgordon
authored
Update to Elastic.Transport 0.4.2 (#6958) (#6959)
Co-authored-by: Steve Gordon <sgordon@hotmail.co.uk>
1 parent 699e3ba commit f44a8c1

39 files changed

+128
-125
lines changed

‎benchmarks/Benchmarks/packages.lock.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@
6767
},
6868
"Elastic.Transport": {
6969
"type": "Transitive",
70-
"resolved": "0.4.0",
71-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
70+
"resolved": "0.4.2",
71+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
7272
"dependencies": {
7373
"Microsoft.CSharp": "4.7.0",
7474
"System.Buffers": "4.5.1",
@@ -1195,7 +1195,7 @@
11951195
"elastic.clients.elasticsearch": {
11961196
"type": "Project",
11971197
"dependencies": {
1198-
"Elastic.Transport": "[0.4.0, )"
1198+
"Elastic.Transport": "[0.4.2, )"
11991199
}
12001200
}
12011201
}

‎benchmarks/Profiling/packages.lock.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,8 @@
3131
},
3232
"Elastic.Transport": {
3333
"type": "Transitive",
34-
"resolved": "0.4.0",
35-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
34+
"resolved": "0.4.2",
35+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
3636
"dependencies": {
3737
"Microsoft.CSharp": "4.7.0",
3838
"System.Buffers": "4.5.1",
@@ -131,7 +131,7 @@
131131
"elastic.clients.elasticsearch": {
132132
"type": "Project",
133133
"dependencies": {
134-
"Elastic.Transport": "[0.4.0, )"
134+
"Elastic.Transport": "[0.4.2, )"
135135
}
136136
}
137137
}

‎src/Elastic.Clients.Elasticsearch.JsonNetSerializer/packages.lock.json

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@
3737
},
3838
"Elastic.Transport": {
3939
"type": "Transitive",
40-
"resolved": "0.4.0",
41-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
40+
"resolved": "0.4.2",
41+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
4242
"dependencies": {
4343
"Microsoft.CSharp": "4.7.0",
4444
"System.Buffers": "4.5.1",
@@ -143,7 +143,7 @@
143143
"elastic.clients.elasticsearch": {
144144
"type": "Project",
145145
"dependencies": {
146-
"Elastic.Transport": "[0.4.0, )"
146+
"Elastic.Transport": "[0.4.2, )"
147147
}
148148
}
149149
},
@@ -183,8 +183,8 @@
183183
},
184184
"Elastic.Transport": {
185185
"type": "Transitive",
186-
"resolved": "0.4.0",
187-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
186+
"resolved": "0.4.2",
187+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
188188
"dependencies": {
189189
"Microsoft.CSharp": "4.7.0",
190190
"System.Buffers": "4.5.1",
@@ -332,7 +332,7 @@
332332
"elastic.clients.elasticsearch": {
333333
"type": "Project",
334334
"dependencies": {
335-
"Elastic.Transport": "[0.4.0, )"
335+
"Elastic.Transport": "[0.4.2, )"
336336
}
337337
}
338338
},
@@ -381,8 +381,8 @@
381381
},
382382
"Elastic.Transport": {
383383
"type": "Transitive",
384-
"resolved": "0.4.0",
385-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
384+
"resolved": "0.4.2",
385+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
386386
"dependencies": {
387387
"Microsoft.CSharp": "4.7.0",
388388
"System.Buffers": "4.5.1",
@@ -529,7 +529,7 @@
529529
"elastic.clients.elasticsearch": {
530530
"type": "Project",
531531
"dependencies": {
532-
"Elastic.Transport": "[0.4.0, )"
532+
"Elastic.Transport": "[0.4.2, )"
533533
}
534534
}
535535
},
@@ -569,8 +569,8 @@
569569
},
570570
"Elastic.Transport": {
571571
"type": "Transitive",
572-
"resolved": "0.4.0",
573-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
572+
"resolved": "0.4.2",
573+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
574574
"dependencies": {
575575
"Microsoft.CSharp": "4.7.0",
576576
"System.Buffers": "4.5.1",
@@ -709,7 +709,7 @@
709709
"elastic.clients.elasticsearch": {
710710
"type": "Project",
711711
"dependencies": {
712-
"Elastic.Transport": "[0.4.0, )"
712+
"Elastic.Transport": "[0.4.2, )"
713713
}
714714
}
715715
},
@@ -749,8 +749,8 @@
749749
},
750750
"Elastic.Transport": {
751751
"type": "Transitive",
752-
"resolved": "0.4.0",
753-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
752+
"resolved": "0.4.2",
753+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
754754
"dependencies": {
755755
"Microsoft.CSharp": "4.7.0",
756756
"System.Buffers": "4.5.1",
@@ -849,7 +849,7 @@
849849
"elastic.clients.elasticsearch": {
850850
"type": "Project",
851851
"dependencies": {
852-
"Elastic.Transport": "[0.4.0, )"
852+
"Elastic.Transport": "[0.4.2, )"
853853
}
854854
}
855855
},
@@ -889,8 +889,8 @@
889889
},
890890
"Elastic.Transport": {
891891
"type": "Transitive",
892-
"resolved": "0.4.0",
893-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
892+
"resolved": "0.4.2",
893+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
894894
"dependencies": {
895895
"Microsoft.CSharp": "4.7.0",
896896
"System.Buffers": "4.5.1",
@@ -989,7 +989,7 @@
989989
"elastic.clients.elasticsearch": {
990990
"type": "Project",
991991
"dependencies": {
992-
"Elastic.Transport": "[0.4.0, )"
992+
"Elastic.Transport": "[0.4.2, )"
993993
}
994994
}
995995
}

‎src/Elastic.Clients.Elasticsearch/Api/BulkResponse.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public partial class BulkResponse
2020
? Enumerable.Empty<ResponseItem>()
2121
: Items.Where(i => !i.IsValid);
2222

23-
public override bool IsValid => base.IsValid && !Errors && !ItemsWithErrors.HasAny();
23+
public override bool IsValidResponse => base.IsValidResponse && !Errors && !ItemsWithErrors.HasAny();
2424

2525
protected override void DebugIsValid(StringBuilder sb)
2626
{

‎src/Elastic.Clients.Elasticsearch/Client/ElasticsearchResponseBaseExtensions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,5 +8,5 @@ namespace Elastic.Clients.Elasticsearch;
88

99
public static class ElasticsearchResponseExtensions
1010
{
11-
public static bool IsSuccess(this ElasticsearchResponse response) => response.ApiCallDetails is not null && response.ApiCallDetails.Success;
11+
public static bool IsSuccess(this ElasticsearchResponse response) => response.ApiCallDetails is not null && response.ApiCallDetails.HasSuccessfulStatusCode;
1212
}

‎src/Elastic.Clients.Elasticsearch/Core/ElasticsearchClientProductRegistration.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ public ElasticsearchClientProductRegistration(Type markerType) : base(markerType
1616
public static ElasticsearchClientProductRegistration DefaultForElasticsearchClientsElasticsearch { get; } = new(typeof(ElasticsearchClient));
1717

1818
/// <summary>
19-
/// Elastic.Clients.Elasticsearch handles 404 in its <see cref="ElasticsearchResponse.IsValid" />, we do not want the low level client throwing
19+
/// Elastic.Clients.Elasticsearch handles 404 in its <see cref="ElasticsearchResponse.IsValidResponse" />, we do not want the low level client throwing
2020
/// exceptions
2121
/// when <see cref="ITransportConfiguration.ThrowExceptions" /> is enabled for 404's. The client is in charge of
2222
/// composing paths
@@ -33,7 +33,7 @@ public override bool TryGetServerErrorReason<TResponse>(TResponse response, [Not
3333
{
3434
if (response is not ElasticsearchResponse r)
3535
return base.TryGetServerErrorReason(response, out reason);
36-
reason = r.ServerError?.Error?.ToString();
36+
reason = r.ElasticsearchServerError?.Error?.ToString();
3737
return !string.IsNullOrEmpty(reason);
3838
}
3939
}

‎src/Elastic.Clients.Elasticsearch/Elastic.Clients.Elasticsearch.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
<Nullable>annotations</Nullable>
1818
</PropertyGroup>
1919
<ItemGroup>
20-
<PackageReference Include="Elastic.Transport" Version="0.4.0" />
20+
<PackageReference Include="Elastic.Transport" Version="0.4.2" />
2121
<PackageReference Include="Microsoft.VisualStudio.Threading.Analyzers" Version="17.3.44">
2222
<PrivateAssets>all</PrivateAssets>
2323
<IncludeAssets>runtime; build; native; contentfiles; analyzers</IncludeAssets>

‎src/Elastic.Clients.Elasticsearch/Helpers/BulkAllObservable.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ private void RefreshOnCompleted()
109109

110110
var refresh = _client.Indices.Refresh(request);
111111

112-
if (!refresh.IsValid)
112+
if (!refresh.IsValidResponse)
113113
throw Throw($"Refreshing after all documents have indexed failed", refresh);
114114
}
115115

@@ -155,7 +155,7 @@ private async Task<BulkAllResponse> BulkAsync(IList<T> buffer, long page, int ba
155155
_compositeCancelToken.ThrowIfCancellationRequested();
156156
_bulkResponseCallback?.Invoke(response);
157157

158-
if (!response.ApiCallDetails.Success)
158+
if (!response.ApiCallDetails.HasSuccessfulStatusCode)
159159
return await HandleBulkRequestAsync(buffer, page, backOffRetries, response).ConfigureAwait(false);
160160

161161
var retryableDocuments = new List<T>();

‎src/Elastic.Clients.Elasticsearch/Types/Documents/MultiSearch/MultiSearchRequest.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ namespace Elastic.Clients.Elasticsearch;
99

1010
public partial class MultiSearchResponse<TDocument>
1111
{
12-
public override bool IsValid => base.IsValid && (Responses?.All(b => b.Item1 is not null && b.Item1.Status == 200) ?? true);
12+
public override bool IsValidResponse => base.IsValidResponse && (Responses?.All(b => b.Item1 is not null && b.Item1.Status == 200) ?? true);
1313

1414
[JsonIgnore]
1515
public int TotalResponses => Responses.HasAny() ? Responses.Count() : 0;

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/ExistsResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch;
2626
public sealed partial class ExistsResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/ExistsSourceResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch;
2626
public sealed partial class ExistsSourceResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/IndexManagement/ExistsAliasResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch.IndexManagement;
2626
public sealed partial class ExistsAliasResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/IndexManagement/ExistsIndexTemplateResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch.IndexManagement;
2626
public sealed partial class ExistsIndexTemplateResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/IndexManagement/ExistsResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch.IndexManagement;
2626
public sealed partial class ExistsResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/_Generated/Api/IndexManagement/ExistsTemplateResponse.g.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@
2525
namespace Elastic.Clients.Elasticsearch.IndexManagement;
2626
public sealed partial class ExistsTemplateResponse : ElasticsearchResponse
2727
{
28-
public bool Exists => ApiCallDetails is { Success: true, HttpStatusCode: 200 };
28+
public bool Exists => ApiCallDetails is { HasSuccessfulStatusCode: true, HttpStatusCode: 200 };
2929
}

‎src/Elastic.Clients.Elasticsearch/packages.lock.json

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@
2222
},
2323
"Elastic.Transport": {
2424
"type": "Direct",
25-
"requested": "[0.4.0, )",
26-
"resolved": "0.4.0",
27-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
25+
"requested": "[0.4.2, )",
26+
"resolved": "0.4.2",
27+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
2828
"dependencies": {
2929
"Microsoft.CSharp": "4.7.0",
3030
"System.Buffers": "4.5.1",
@@ -163,9 +163,9 @@
163163
},
164164
"Elastic.Transport": {
165165
"type": "Direct",
166-
"requested": "[0.4.0, )",
167-
"resolved": "0.4.0",
168-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
166+
"requested": "[0.4.2, )",
167+
"resolved": "0.4.2",
168+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
169169
"dependencies": {
170170
"Microsoft.CSharp": "4.7.0",
171171
"System.Buffers": "4.5.1",
@@ -347,9 +347,9 @@
347347
},
348348
"Elastic.Transport": {
349349
"type": "Direct",
350-
"requested": "[0.4.0, )",
351-
"resolved": "0.4.0",
352-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
350+
"requested": "[0.4.2, )",
351+
"resolved": "0.4.2",
352+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
353353
"dependencies": {
354354
"Microsoft.CSharp": "4.7.0",
355355
"System.Buffers": "4.5.1",
@@ -539,9 +539,9 @@
539539
},
540540
"Elastic.Transport": {
541541
"type": "Direct",
542-
"requested": "[0.4.0, )",
543-
"resolved": "0.4.0",
544-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
542+
"requested": "[0.4.2, )",
543+
"resolved": "0.4.2",
544+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
545545
"dependencies": {
546546
"Microsoft.CSharp": "4.7.0",
547547
"System.Buffers": "4.5.1",
@@ -714,9 +714,9 @@
714714
},
715715
"Elastic.Transport": {
716716
"type": "Direct",
717-
"requested": "[0.4.0, )",
718-
"resolved": "0.4.0",
719-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
717+
"requested": "[0.4.2, )",
718+
"resolved": "0.4.2",
719+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
720720
"dependencies": {
721721
"Microsoft.CSharp": "4.7.0",
722722
"System.Buffers": "4.5.1",
@@ -849,9 +849,9 @@
849849
},
850850
"Elastic.Transport": {
851851
"type": "Direct",
852-
"requested": "[0.4.0, )",
853-
"resolved": "0.4.0",
854-
"contentHash": "4uqaeeZOboqs8nSvYnQXnGOSTyPo4SvV4NH3o+Ls3OEV1d9VipYS09/8/DcmcklK7hWuQXhrdsQd1b6Vi0a//w==",
852+
"requested": "[0.4.2, )",
853+
"resolved": "0.4.2",
854+
"contentHash": "umDR9uAzO8KPgb96O6llqN7DIv7oqATB4MPr3UrDCJ6Su+l7KJhB7lwItf/cw727e1jKTG9QEqkW6tBGjYoe4w==",
855855
"dependencies": {
856856
"Microsoft.CSharp": "4.7.0",
857857
"System.Buffers": "4.5.1",

‎src/Playground/Program.cs

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,17 +8,21 @@
88
using Elastic.Transport;
99
using Moq;
1010
using Playground;
11-
using CreateResponse = Elastic.Clients.Elasticsearch.IndexManagement.CreateResponse;
11+
using CreateIndexResponse = Elastic.Clients.Elasticsearch.IndexManagement.CreateResponse;
1212

1313
// const string IndexName = "stock-demo-v1";
1414

15-
var mockedResponse = ResponseFactory.CreateResponse(new CreateResponse { Acknowledged = true, Index = "testing", ShardsAcknowledged = true }, 200);
15+
var createResponse = new CreateIndexResponse { Acknowledged = true, Index = "testing", ShardsAcknowledged = true };
16+
var mockedResponse = TestableResponseFactory.CreateSuccessfulResponse(createResponse, 201);
1617

1718
var mockedClient = Mock.Of<ElasticsearchClient>(e =>
1819
e.Indices.Create<It.IsAnyType>() == mockedResponse);
1920

2021
var testResponse = mockedClient.Indices.Create<Person>();
2122

23+
if (testResponse.IsValidResponse)
24+
Console.WriteLine("SUCCESS");
25+
2226
// ALTERNATIVE
2327

2428
var stubbedClient = new TestableElasticsearchClient();
@@ -291,6 +295,6 @@ public class TestableElasticsearchClient : ElasticsearchClient
291295

292296
public class TestIndicesNamespace : IndicesNamespacedClient
293297
{
294-
public override CreateResponse Create<TDocument>() =>
295-
ResponseFactory.CreateResponse(new CreateResponse { Acknowledged = true, Index = "testing", ShardsAcknowledged = true }, 200);
298+
public override CreateIndexResponse Create<TDocument>() =>
299+
TestableResponseFactory.CreateSuccessfulResponse(new CreateIndexResponse { Acknowledged = true, Index = "testing", ShardsAcknowledged = true }, 201);
296300
}

0 commit comments

Comments
 (0)