Hard coding token

Author: jonathan-buttner

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/HttpClient.java

@@ -8,6 +8,7 @@
 package org.elasticsearch.xpack.inference.external.http;
 
 import org.apache.http.HttpResponse;
+import org.apache.http.client.UserTokenHandler;
 import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.protocol.HttpClientContext;
 import org.apache.http.concurrent.FutureCallback;
@@ -36,6 +37,8 @@
  * Provides a wrapper around a {@link CloseableHttpAsyncClient} to move the responses to a separate thread for processing.
  */
 public class HttpClient implements Closeable {
+    public static final String USER_TOKEN = "token";
+
     private static final Logger logger = LogManager.getLogger(HttpClient.class);
 
     enum Status {
@@ -71,6 +74,13 @@ private static CloseableHttpAsyncClient createAsyncClient(
         // The apache client will be shared across all connections because it can be expensive to create it
         // so we don't want to support cookies to avoid accidental authentication for unauthorized users
         clientBuilder.disableCookieManagement();
+        var userTokenHandler = new UserTokenHandler() {
+            public Object getUserToken(HttpContext context) {
+                return USER_TOKEN;
+            }
+
+        };
+        clientBuilder.setUserTokenHandler(userTokenHandler);
         // clientBuilder.disableConnectionState();
 
         /*

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/retry/RetryingHttpSender.java

@@ -32,6 +32,7 @@
 
 import static org.elasticsearch.core.Strings.format;
 import static org.elasticsearch.xpack.inference.InferencePlugin.UTILITY_THREAD_POOL_NAME;
+import static org.elasticsearch.xpack.inference.external.http.HttpClient.USER_TOKEN;
 
 public class RetryingHttpSender implements RequestSender {
 
@@ -214,7 +215,7 @@ public void send(
         ActionListener<InferenceServiceResults> listener
     ) {
         var context = HttpClientContext.create();
-        context.setUserToken("token");
+        context.setUserToken(USER_TOKEN);
         var retrier = new InternalRetrier(logger, request, context, hasRequestTimedOutFunction, responseHandler, listener);
         retrier.run();
     }