Skip to content

Commit 5cc34b4

Browse files
Remove deadcode in request interceptors (#90055)
Nothing to see here! This just removes deadcode that is been guarded by version checks which don't apply anymore.
1 parent 6e4d8bf commit 5cc34b4

File tree

3 files changed

+3
-26
lines changed

3 files changed

+3
-26
lines changed

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/authz/interceptor/SearchRequestInterceptor.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
package org.elasticsearch.xpack.security.authz.interceptor;
88

99
import org.elasticsearch.ElasticsearchSecurityException;
10-
import org.elasticsearch.Version;
1110
import org.elasticsearch.action.ActionListener;
1211
import org.elasticsearch.action.IndicesRequest;
1312
import org.elasticsearch.action.search.SearchRequest;
@@ -25,7 +24,6 @@
2524

2625
public class SearchRequestInterceptor extends FieldAndDocumentLevelSecurityRequestInterceptor {
2726

28-
public static final Version VERSION_SHARD_SEARCH_INTERCEPTOR = Version.V_7_11_2;
2927
private final ClusterService clusterService;
3028

3129
public SearchRequestInterceptor(ThreadPool threadPool, XPackLicenseState licenseState, ClusterService clusterService) {
@@ -40,10 +38,7 @@ void disableFeatures(
4038
ActionListener<Void> listener
4139
) {
4240
final SearchRequest request = (SearchRequest) indicesRequest;
43-
// The 7.11.2 version check is needed because request caching has a bug related to DLS/FLS
44-
// versions before 7.11.2. It is fixed by #69505. See also ESA-2021-08.
45-
// TODO: The version check can be removed in 8.0 because 7.last will have support for request caching with DLS/FLS
46-
if (clusterService.state().nodes().getMinNodeVersion().before(VERSION_SHARD_SEARCH_INTERCEPTOR) || hasRemoteIndices(request)) {
41+
if (hasRemoteIndices(request)) {
4742
request.requestCache(false);
4843
}
4944

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/authz/interceptor/ShardSearchRequestInterceptor.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,6 @@
2121
import java.io.IOException;
2222
import java.util.Map;
2323

24-
import static org.elasticsearch.xpack.security.authz.interceptor.SearchRequestInterceptor.VERSION_SHARD_SEARCH_INTERCEPTOR;
25-
2624
public class ShardSearchRequestInterceptor extends FieldAndDocumentLevelSecurityRequestInterceptor {
2725

2826
private static final Logger logger = LogManager.getLogger(ShardSearchRequestInterceptor.class);
@@ -41,12 +39,7 @@ void disableFeatures(
4139
ActionListener<Void> listener
4240
) {
4341
final ShardSearchRequest request = (ShardSearchRequest) indicesRequest;
44-
// The 7.11.2 version check is needed because request caching has a bug related to DLS/FLS
45-
// versions before 7.11.2. It is fixed by #69505. See also ESA-2021-08.
46-
// TODO: The version check can be removed in 8.0 because 7.last will have support for request caching with DLS/FLS
47-
if (clusterService.state().nodes().getMinNodeVersion().before(VERSION_SHARD_SEARCH_INTERCEPTOR)) {
48-
request.requestCache(false);
49-
} else if (dlsUsesStoredScripts(request, indexAccessControlByIndex)) {
42+
if (dlsUsesStoredScripts(request, indexAccessControlByIndex)) {
5043
logger.debug("Disable shard search request cache because DLS queries use stored scripts");
5144
request.requestCache(false);
5245
}

x-pack/plugin/security/src/test/java/org/elasticsearch/xpack/security/authz/interceptor/SearchRequestInterceptorTests.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -66,19 +66,8 @@ private void configureMinMondeVersion(Version version) {
6666
when(discoveryNodes.getMinNodeVersion()).thenReturn(version);
6767
}
6868

69-
public void testRequestCacheWillBeDisabledWhenMinNodeVersionIsBeforeShardSearchInterceptor() {
70-
configureMinMondeVersion(VersionUtils.randomVersionBetween(random(), Version.V_7_0_0, Version.V_7_11_1));
71-
final SearchRequest searchRequest = mock(SearchRequest.class);
72-
when(searchRequest.indices()).thenReturn(randomArray(0, 3, String[]::new, () -> randomAlphaOfLengthBetween(3, 8)));
73-
when(searchRequest.source()).thenReturn(SearchSourceBuilder.searchSource());
74-
final PlainActionFuture<Void> future = new PlainActionFuture<>();
75-
interceptor.disableFeatures(searchRequest, Map.of(), future);
76-
future.actionGet();
77-
verify(searchRequest).requestCache(false);
78-
}
79-
8069
public void testRequestCacheWillBeDisabledWhenSearchRemoteIndices() {
81-
configureMinMondeVersion(VersionUtils.randomVersionBetween(random(), Version.V_7_11_2, Version.CURRENT));
70+
configureMinMondeVersion(VersionUtils.randomVersion(random()));
8271
final SearchRequest searchRequest = mock(SearchRequest.class);
8372
when(searchRequest.source()).thenReturn(SearchSourceBuilder.searchSource());
8473
final String[] localIndices = randomArray(0, 3, String[]::new, () -> randomAlphaOfLengthBetween(3, 8));

0 commit comments

Comments
 (0)