live api client does not support socket proxy

[alinemeng]

I want to access LiveApi through a SOCKS or HTTP proxy service, but currently there's no way to configure a proxy. The proxy configured via ProxyOptions under the existing ClientOptions isn't being used by the WebSocket connection.

[hemasekhar-p]

Hi @alinemeng, Thank you for bringing this to our attention. I have attempted to reproduce this issue locally, but have been unsuccessful. Could you please provide more details, such as a sample executable code snippet, any error logs you are encountering, the SDK version, and the specific model you are using? This information would be greatly appreciated and assist us in our investigation.

[alinemeng]

gradle config
implementation 'com.google.genai:google-genai:1.35.0'
code

try (Client client = Client.builder()
        .clientOptions(ClientOptions.builder()
                .proxyOptions(ProxyOptions.builder()
                        // Use Clash's local proxy server.
                        // However, the proxy settings do not take effect.
                        .host("127.0.0.1")
                        .port(7890)
                        .build())
                .build())
        .httpOptions(HttpOptions.builder()
                .apiVersion("v1")
                .build())
        .build()) {
    CompletableFuture<AsyncSession> connect = client.async.live.connect(
            "gemini-2.5-flash-native-audio-preview-12-2025",
            LiveConnectConfig.builder()
                    .responseModalities(Modality.Known.AUDIO)
                    .build()
    );
    connect.get();
} catch (Exception e) {
    e.printStackTrace();
}

console out

Error during live session: Operation timed out
java.net.ConnectException: Operation timed out
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:579)
	at java.base/sun.nio.ch.Net.connect(Net.java:568)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:593)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at org.java_websocket.client.WebSocketClient.run(WebSocketClient.java:491)
	at java.base/java.lang.Thread.run(Thread.java:842)
Live session closed with code: -1 and reason: Operation timed out
java.util.concurrent.ExecutionException: java.net.ConnectException: Operation timed out
	at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
	at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
	at com.m.s.learning.Main.main(Main.java:27)
Caused by: java.net.ConnectException: Operation timed out
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:579)
	at java.base/sun.nio.ch.Net.connect(Net.java:568)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:593)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at org.java_websocket.client.WebSocketClient.run(WebSocketClient.java:491)
	at java.base/java.lang.Thread.run(Thread.java:842)

Caused by: java.net.ConnectException: Operation timed out

My environment can only access Google through Clash.

[alinemeng]

I tried modifying the source code from version 1.35.0, and after the modification, the proxy configuration issue was resolved.

Below is the git patch I applied:

Subject: [PATCH] modify
---
Index: src/main/java/com/google/genai/AsyncLive.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/src/main/java/com/google/genai/AsyncLive.java b/src/main/java/com/google/genai/AsyncLive.java
--- a/src/main/java/com/google/genai/AsyncLive.java	(revision efae0eda4dee228a51071413f518697cd20272b0)
+++ b/src/main/java/com/google/genai/AsyncLive.java	(date 1768582476166)
@@ -22,10 +22,11 @@
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.google.auth.oauth2.GoogleCredentials;
 import com.google.genai.errors.GenAiIOException;
-import com.google.genai.types.LiveConnectConfig;
-import com.google.genai.types.LiveConnectParameters;
-import com.google.genai.types.LiveServerMessage;
+import com.google.genai.types.*;
+
 import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.Proxy;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.nio.ByteBuffer;
@@ -34,9 +35,13 @@
 import java.nio.charset.CharsetDecoder;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.function.Consumer;
 import java.util.logging.Logger;
+
+import okhttp3.Credentials;
+import okhttp3.OkHttpClient;
 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.handshake.ServerHandshake;
 import org.jspecify.annotations.Nullable;
@@ -211,6 +216,7 @@
       this.sessionFuture = sessionFuture;
       this.messageCallback = null;
       this.apiClient = apiClient;
+      apiClient.clientOptions.flatMap(ClientOptions::proxyOptions).ifPresent(this::applyProxyOptions);
     }
 
     public void setMessageCallback(Consumer<LiveServerMessage> messageCallback) {
@@ -302,5 +308,51 @@
                 + " `AsyncSession.receive()` to register a callback.");
       }
     }
+
+    private void applyProxyOptions(ProxyOptions proxyOptions) {
+      final ProxyType proxyType = proxyOptions.type().orElse(new ProxyType("HTTP"));
+      final Proxy.Type type;
+
+      switch (proxyType.knownEnum()) {
+        case SOCKS:
+          type = Proxy.Type.SOCKS;
+          break;
+        case HTTP:
+          type = Proxy.Type.HTTP;
+          break;
+        case DIRECT:
+          setProxy(Proxy.NO_PROXY);
+          return;
+        default:
+          throw new IllegalArgumentException("Unsupported proxy type: " + proxyType);
+      }
+      // Set the proxy for non-direct types.
+      String host =
+              proxyOptions
+                      .host()
+                      .orElseThrow(
+                              () -> new IllegalArgumentException("Proxy host is required in the ProxyOptions."));
+      int port =
+              proxyOptions
+                      .port()
+                      .orElseThrow(
+                              () -> new IllegalArgumentException("Proxy port is required in the ProxyOptions."));
+
+      setProxy(new Proxy(type, new InetSocketAddress(host, port)));
+
+      // Set the proxy authenticator if username and password are provided.
+      boolean userPresent = proxyOptions.username().isPresent();
+      boolean passPresent = proxyOptions.password().isPresent();
+
+      if (userPresent != passPresent) {
+        throw new IllegalArgumentException(
+                "Proxy username and password must both be provided or not at all.");
+      }
+      if (userPresent && passPresent) {
+        final String credential =
+                Credentials.basic(proxyOptions.username().get(), proxyOptions.password().get());
+        addHeader("Proxy-Authorization", credential);
+      }
+    }
   }
 }

[github-actions]

This issue has been marked as stale because it has been open for 7 days with no activity. It will be closed in 2 days if no further activity occurs.