Skip to content

Commit 673072e

Browse files
committed
Provide some sensible defaults
1 parent e537e52 commit 673072e

File tree

37 files changed

+81
-103
lines changed

37 files changed

+81
-103
lines changed

modules/ingest-geoip/src/test/java/org/elasticsearch/ingest/geoip/DatabaseNodeServiceTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ private String mockSearches(String databaseName, int firstChunk, int lastChunk)
342342
}
343343

344344
SearchHits hits = SearchHits.unpooled(new SearchHit[] { hit }, new TotalHits(1, TotalHits.Relation.EQUAL_TO), 1f);
345-
SearchResponse searchResponse = SearchResponseUtils.success(hits);
345+
SearchResponse searchResponse = SearchResponseUtils.successfulResponse(hits);
346346
toRelease.add(searchResponse::decRef);
347347
@SuppressWarnings("unchecked")
348348
ActionFuture<SearchResponse> actionFuture = mock(ActionFuture.class);

modules/reindex/src/test/java/org/elasticsearch/reindex/AsyncBulkByScrollActionTests.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -575,8 +575,7 @@ protected RequestWrapper<?> buildRequest(Hit doc) {
575575
new TotalHits(0, TotalHits.Relation.EQUAL_TO),
576576
0
577577
);
578-
SearchResponse searchResponse = SearchResponseUtils.builder(hits)
579-
.numReducePhases(1)
578+
SearchResponse searchResponse = SearchResponseUtils.response(hits)
580579
.scrollId(scrollId())
581580
.shards(5, 4, 0)
582581
.tookInMillis(randomLong())

modules/reindex/src/test/java/org/elasticsearch/reindex/ClientScrollableHitSourceTests.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -167,8 +167,7 @@ private SearchResponse createSearchResponse() {
167167
new TotalHits(0, TotalHits.Relation.EQUAL_TO),
168168
0
169169
);
170-
return SearchResponseUtils.builder(hits)
171-
.numReducePhases(1)
170+
return SearchResponseUtils.response(hits)
172171
.scrollId(randomSimpleString(random(), 1, 10))
173172
.shards(5, 4, 0)
174173
.tookInMillis(randomLong())

qa/ccs-unavailable-clusters/src/javaRestTest/java/org/elasticsearch/search/CrossClusterSearchUnavailableClusterIT.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,9 @@ private static MockTransportService startTransport(
9999
EsExecutors.DIRECT_EXECUTOR_SERVICE,
100100
SearchRequest::new,
101101
(request, channel, task) -> {
102-
var searchResponse = SearchResponseUtils.success(SearchHits.empty(Lucene.TOTAL_HITS_EQUAL_TO_ZERO, Float.NaN));
102+
var searchResponse = SearchResponseUtils.successfulResponse(
103+
SearchHits.empty(Lucene.TOTAL_HITS_EQUAL_TO_ZERO, Float.NaN)
104+
);
103105
try {
104106
channel.sendResponse(searchResponse);
105107
} finally {

server/src/test/java/org/elasticsearch/action/search/ExpandSearchPhaseTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ public void testFailOneItemFailsEntirePhase() throws IOException {
174174
@Override
175175
void sendExecuteMultiSearch(MultiSearchRequest request, SearchTask task, ActionListener<MultiSearchResponse> listener) {
176176
assertTrue(executedMultiSearch.compareAndSet(false, true));
177-
SearchResponse searchResponse = SearchResponseUtils.success(collapsedHits);
177+
SearchResponse searchResponse = SearchResponseUtils.successfulResponse(collapsedHits);
178178
ActionListener.respondAndRelease(
179179
listener,
180180
new MultiSearchResponse(

server/src/test/java/org/elasticsearch/transport/RemoteClusterConnectionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ public static MockTransportService startTransport(
155155
} else {
156156
searchHits = SearchHits.empty(new TotalHits(0, TotalHits.Relation.EQUAL_TO), Float.NaN);
157157
}
158-
try (var searchResponseRef = ReleasableRef.of(SearchResponseUtils.success(searchHits))) {
158+
try (var searchResponseRef = ReleasableRef.of(SearchResponseUtils.successfulResponse(searchHits))) {
159159
channel.sendResponse(searchResponseRef.get());
160160
}
161161
}

test/framework/src/main/java/org/elasticsearch/search/SearchResponseUtils.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -78,12 +78,16 @@
7878
public enum SearchResponseUtils {
7979
;
8080

81-
public static SearchResponseBuilder builder(SearchHits hits) {
82-
return new SearchResponseBuilder().searchHits(hits);
81+
public static SearchResponseBuilder response() {
82+
return new SearchResponseBuilder();
8383
}
8484

85-
public static SearchResponse success(SearchHits hits) {
86-
return builder(hits).numReducePhases(1).shards(1, 1, 0).tookInMillis(100).build();
85+
public static SearchResponseBuilder response(SearchHits hits) {
86+
return new SearchResponseBuilder().searchHits(hits).numReducePhases(1).shards(1, 1, 0).tookInMillis(100);
87+
}
88+
89+
public static SearchResponse successfulResponse(SearchHits hits) {
90+
return response(hits).build();
8791
}
8892

8993
public static SearchResponse emptyWithTotalHits(

x-pack/plugin/async-search/src/test/java/org/elasticsearch/xpack/search/AsyncSearchTaskTests.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -473,10 +473,8 @@ private static SearchResponse newSearchResponse(
473473
int skippedShards,
474474
ShardSearchFailure... failures
475475
) {
476-
return SearchResponseUtils.builder(SearchHits.EMPTY_WITH_TOTAL_HITS)
477-
.numReducePhases(1)
476+
return SearchResponseUtils.response(SearchHits.EMPTY_WITH_TOTAL_HITS)
478477
.shards(totalShards, successfulShards, skippedShards)
479-
.tookInMillis(100)
480478
.shardFailures(failures)
481479
.build();
482480
}

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/indexing/AsyncTwoPhaseIndexerTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ protected void doNextSearch(long waitTimeInNanos, ActionListener<SearchResponse>
113113
return;
114114
}
115115

116-
ActionListener.respondAndRelease(nextPhase, SearchResponseUtils.success(SearchHits.EMPTY_WITH_TOTAL_HITS));
116+
ActionListener.respondAndRelease(nextPhase, SearchResponseUtils.successfulResponse(SearchHits.EMPTY_WITH_TOTAL_HITS));
117117
}
118118

119119
@Override
@@ -246,7 +246,7 @@ protected void doNextSearch(long waitTimeInNanos, ActionListener<SearchResponse>
246246
awaitForLatch();
247247
}
248248

249-
ActionListener.respondAndRelease(nextPhase, SearchResponseUtils.success(SearchHits.EMPTY_WITH_TOTAL_HITS));
249+
ActionListener.respondAndRelease(nextPhase, SearchResponseUtils.successfulResponse(SearchHits.EMPTY_WITH_TOTAL_HITS));
250250
}
251251

252252
@Override

x-pack/plugin/enrich/src/test/java/org/elasticsearch/xpack/enrich/EnrichCacheTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ private SearchResponse convertToSearchResponse(List<Map<String, ?>> searchRespon
181181
}
182182
}).toArray(SearchHit[]::new);
183183
SearchHits hits = SearchHits.unpooled(hitArray, null, 0);
184-
return SearchResponseUtils.builder(hits).numReducePhases(1).shards(5, 4, 0).tookInMillis(randomLong()).build();
184+
return SearchResponseUtils.response(hits).shards(5, 4, 0).tookInMillis(randomLong()).build();
185185
}
186186

187187
private BytesReference convertMapToJson(Map<String, ?> simpleMap) throws IOException {

0 commit comments

Comments
 (0)