fix: add interceptor for the HttpAsyncClientBuilder.

Author: SvitlanaKovalova1

src/main/java/org/folio/search/configuration/OpensearchRestClientConfiguration.java

@@ -34,8 +34,11 @@
 import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManager;
 import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder;
 import org.apache.hc.client5.http.ssl.ClientTlsStrategyBuilder;
+import org.apache.hc.core5.http.EntityDetails;
 import org.apache.hc.core5.http.HttpHost;
+import org.apache.hc.core5.http.HttpRequest;
 import org.apache.hc.core5.http.nio.ssl.TlsStrategy;
+import org.apache.hc.core5.http.protocol.HttpContext;
 import org.apache.hc.core5.util.Timeout;
 import org.folio.search.configuration.opensearch.RestClientBuilderCustomizer;
 import org.folio.search.configuration.properties.OpensearchProperties;
@@ -44,7 +47,6 @@
 import org.opensearch.client.RestHighLevelClient;
 import org.springframework.beans.factory.ObjectProvider;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.PropertyMapper;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -59,7 +61,6 @@ RestClientBuilderCustomizer defaultRestClientBuilderCustomizer(OpensearchPropert
   }
 
   @Bean
-  @ConditionalOnMissingBean(RestClientBuilder.class)
   RestClientBuilder opensearchRestClientBuilder(ObjectProvider<RestClientBuilderCustomizer> builderCustomizers,
                                                 OpensearchProperties properties) {
     HttpHost[] hosts = properties.getUris().stream().map(this::createHttpHost).toArray(HttpHost[]::new);
@@ -128,6 +129,14 @@ static class DefaultRestClientBuilderCustomizer implements RestClientBuilderCust
     public void customize(HttpAsyncClientBuilder builder) {
       builder.setDefaultCredentialsProvider(new PropertiesCredentialsProvider(this.properties));
       builder.setConnectionManager(getPoolingAsyncClientConnectionManager());
+
+      builder.addRequestInterceptorFirst((HttpRequest request, EntityDetails entityDetails, HttpContext context) -> {
+        var uri = request.getRequestUri();
+        if (uri.contains("cluster_manager_timeout")) {
+          var newUri = uri.replaceAll("[&?]?cluster_manager_timeout=[^&]*", "");
+          request.setPath(newUri);
+        }
+      });
     }
 
     @Override