feat: allow users to provide a custom OkHttpClient

Accept a user-supplied OkHttpClient via new constructors on StreamHTTPClient
and StreamSDKClient. The SDK derives a new builder from the provided client
(preserving its connection pool, timeouts, proxy, SSL config, etc.) and adds
the required auth/logging/header interceptors on top.

Made-with: Cursor

Author: itsmeadi

src/main/java/io/getstream/services/framework/StreamHTTPClient.java

@@ -56,6 +56,14 @@ public StreamHTTPClient(@NotNull String apiKey, @NotNull String apiSecret) {
     setCredetials(apiKey, apiSecret);
   }
 
+  public StreamHTTPClient(
+      @NotNull String apiKey, @NotNull String apiSecret, @NotNull OkHttpClient httpClient) {
+    this.apiKey = apiKey;
+    this.apiSecret = apiSecret;
+    var jwtToken = buildJWT(apiSecret);
+    this.client = buildHTTPClient(jwtToken, httpClient.newBuilder());
+  }
+
   // default constructor using ENV or System properties
   // env vars have priority over system properties
   public StreamHTTPClient() {
@@ -120,7 +128,13 @@ private void setCredetials(@NotNull String apiKey, @NotNull String apiSecret) {
     this.apiKey = apiKey;
     this.apiSecret = apiSecret;
     var jwtToken = buildJWT(apiSecret);
-    this.client = buildHTTPClient(jwtToken);
+    this.client = buildHTTPClient(jwtToken, defaultHttpClientBuilder());
+  }
+
+  private OkHttpClient.Builder defaultHttpClientBuilder() {
+    return new OkHttpClient.Builder()
+        .connectionPool(new ConnectionPool(5, 59, TimeUnit.SECONDS))
+        .callTimeout(timeout, TimeUnit.MILLISECONDS);
   }
 
   private void readPropertiesAndEnv(Properties properties) {
@@ -159,11 +173,7 @@ private void readPropertiesAndEnv(Properties properties) {
     return HttpLoggingInterceptor.Level.valueOf(logLevel);
   }
 
-  private OkHttpClient buildHTTPClient(String jwtToken) {
-    OkHttpClient.Builder httpClient =
-        new OkHttpClient.Builder()
-            .connectionPool(new ConnectionPool(5, 59, TimeUnit.SECONDS))
-            .callTimeout(timeout, TimeUnit.MILLISECONDS);
+  private OkHttpClient buildHTTPClient(String jwtToken, OkHttpClient.Builder httpClient) {
     httpClient.interceptors().clear();
 
     HttpLoggingInterceptor loggingInterceptor =

src/main/java/io/getstream/services/framework/StreamSDKClient.java

@@ -2,6 +2,7 @@
 
 import io.getstream.services.*;
 import java.util.Properties;
+import okhttp3.OkHttpClient;
 import org.jetbrains.annotations.NotNull;
 
 public class StreamSDKClient extends CommonImpl implements Common {
@@ -19,6 +20,11 @@ public StreamSDKClient(Properties properties) {
     this(new StreamHTTPClient(properties));
   }
 
+  public StreamSDKClient(
+      @NotNull String apiKey, @NotNull String apiSecret, @NotNull OkHttpClient httpClient) {
+    this(new StreamHTTPClient(apiKey, apiSecret, httpClient));
+  }
+
   public StreamSDKClient(StreamHTTPClient httpClient) {
     super(httpClient);
     this.httpClient = httpClient;