add TokenInjectionException

Author: kanat

src/main/java/io/getstream/chat/java/services/framework/UserTokenCallRewriter.java

@@ -1,5 +1,6 @@
 package io.getstream.chat.java.services.framework;
 
+import io.getstream.chat.java.services.framework.internal.TokenInjectionException;
 import okhttp3.Call;
 import okhttp3.Request;
 import org.jetbrains.annotations.NotNull;
@@ -36,10 +37,13 @@ public Object invoke(Object proxy, Method method, Object[] args) throws Throwabl
       return injectTokenIntoCall((retrofit2.Call<?>) result);
     }
 
-    return result;
+    // All service methods must return Call<?> for token injection
+    throw new TokenInjectionException(
+      "Method " + method.getName() + " on " + delegate.getClass().getName() + 
+      " did not return retrofit2.Call<?>. User token injection requires all service methods to return Call<?>.");
   }
 
-  private retrofit2.Call<?> injectTokenIntoCall(retrofit2.Call<?> originalCall) {
+  private retrofit2.Call<?> injectTokenIntoCall(retrofit2.Call<?> originalCall) throws TokenInjectionException {
     retrofit2.Call<?> clonedCall = originalCall.clone();
 
     try {
@@ -67,11 +71,11 @@ private retrofit2.Call<?> injectTokenIntoCall(retrofit2.Call<?> originalCall) {
       return clonedCall;
     } catch (NoSuchFieldException e) {
       // If Retrofit's internal structure changes, provide clear error message
-      throw new RuntimeException(
+      throw new TokenInjectionException(
         "Retrofit internal structure changed. Field 'rawCall' not found in " + 
         clonedCall.getClass().getName() + ". Update client implementation.", e);
     } catch (IllegalAccessException e) {
-      throw new RuntimeException("Failed to inject token into call", e);
+      throw new TokenInjectionException("Failed to inject token into call", e);
     }
   }
 }

src/main/java/io/getstream/chat/java/services/framework/internal/TokenInjectionException.java

@@ -0,0 +1,18 @@
+package io.getstream.chat.java.services.framework.internal;
+
+/**
+ * Thrown when user token injection into a request fails.
+ * This can happen if:
+ * - A service method doesn't return retrofit2.Call<?>
+ * - Retrofit's internal structure changes and reflection fails
+ */
+public class TokenInjectionException extends Exception {
+  public TokenInjectionException(String message) {
+    super(message);
+  }
+  
+  public TokenInjectionException(String message, Throwable cause) {
+    super(message, cause);
+  }
+}
+

src/test/java/io/getstream/chat/java/CustomTest.java

@@ -1,11 +1,16 @@
 package io.getstream.chat.java;
 
+import io.getstream.chat.java.exceptions.StreamException;
+import io.getstream.chat.java.models.Thread;
 import io.getstream.chat.java.models.User;
 import io.getstream.chat.java.services.UserService;
 import io.getstream.chat.java.services.framework.DefaultClient;
 import org.junit.jupiter.api.Test;
 import java.lang.management.ManagementFactory;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.concurrent.TimeUnit;
+import java.util.function.Consumer;
 
 public class CustomTest {
 
@@ -20,10 +25,17 @@ void customTest() throws Exception {
 
   @Test
   void userReqTest() throws Exception {
-    var userId = "admin";
-    var userToken = User.createToken(userId, null, null);
-    var response = User.list().filterCondition("id", userId).withUserToken(userToken).request();
-    System.out.println("\n!.!.! " + response + "\n");
+    var userIds = List.of( "admin", "MWRYXIHURH", "SRLOTCPYQS", "IOEXOFYTRH", "RIOPOIGMDQ", "XUXJMHTNOI", "QQASWMJEQI");
+
+    for (var userId : userIds) {
+      var userToken = User.createToken(userId, null, null);
+      User.list().filterCondition("id", userId).withUserToken(userToken).requestAsync(
+          userListResponse -> System.out.println("\n!.!.! " + userListResponse + "\n"),
+          e -> {}
+      );
+    }
+
+    java.lang.Thread.sleep(10000);
   }
 
   @Test