SDK regeneration

Author: fern-api[bot]

.fern/metadata.json

@@ -11,7 +11,7 @@
     },
     "enable-wire-tests": true
   },
-  "originGitCommit": "0052a020a7becd03b349857664c9f4a89b6c449a",
+  "originGitCommit": "d228f82e93aaa8aa77f978d458cf912f3daaa8c1",
   "originGitCommitIsDirty": true,
   "invokedBy": "manual",
   "sdkVersion": "0.4.1"

src/main/java/com/deepgram/core/ClientOptions.java

@@ -41,10 +41,10 @@ private ClientOptions(
         this.headers.putAll(headers);
         this.headers.putAll(new HashMap<String, String>() {
             {
-                put("User-Agent", "com.deepgram:deepgram-java-sdk/0.4.0"); // x-release-please-version
+                put("User-Agent", "com.deepgram:deepgram-sdk/0.4.1");
                 put("X-Fern-Language", "JAVA");
-                put("X-Fern-SDK-Name", "com.deepgram:deepgram-java-sdk");
-                put("X-Fern-SDK-Version", "0.4.0"); // x-release-please-version
+                put("X-Fern-SDK-Name", "com.deepgram.fern:api-sdk");
+                put("X-Fern-SDK-Version", "0.4.1");
             }
         });
         this.headerSuppliers = headerSuppliers;

src/main/java/com/deepgram/core/Environment.java

@@ -4,22 +4,25 @@
 package com.deepgram.core;
 
 public final class Environment {
-    public static final Environment PRODUCTION =
-            new Environment("https://api.deepgram.com", "wss://api.deepgram.com", "wss://agent.deepgram.com");
-
-    public static final Environment AGENT =
-            new Environment("https://agent.deepgram.com", "wss://api.deepgram.com", "wss://agent.deepgram.com");
+    public static final Environment PRODUCTION = new Environment(
+            "https://api.deepgram.com",
+            "wss://api.deepgram.com",
+            "wss://agent.deepgram.com",
+            "https://agent.deepgram.com");
 
     private final String base;
 
     private final String production;
 
     private final String agent;
 
-    Environment(String base, String production, String agent) {
+    private final String agentRest;
+
+    Environment(String base, String production, String agent, String agentRest) {
         this.base = base;
         this.production = production;
         this.agent = agent;
+        this.agentRest = agentRest;
     }
 
     public String getBaseURL() {
@@ -34,6 +37,10 @@ public String getAgentURL() {
         return this.agent;
     }
 
+    public String getAgentRestURL() {
+        return this.agentRest;
+    }
+
     public static Builder custom() {
         return new Builder();
     }
@@ -45,6 +52,8 @@ public static class Builder {
 
         private String agent;
 
+        private String agentRest;
+
         public Builder base(String base) {
             this.base = base;
             return this;
@@ -60,8 +69,13 @@ public Builder agent(String agent) {
             return this;
         }
 
+        public Builder agentRest(String agentRest) {
+            this.agentRest = agentRest;
+            return this;
+        }
+
         public Environment build() {
-            return new Environment(base, production, agent);
+            return new Environment(base, production, agent, agentRest);
         }
     }
 }

src/main/java/com/deepgram/core/ReconnectingWebSocketListener.java

@@ -25,21 +25,16 @@
  * Provides production-ready resilience for WebSocket connections.
  */
 public abstract class ReconnectingWebSocketListener extends WebSocketListener {
-    // Option-derived fields are volatile (not final) so {@link #applyOptionsOverride} can rewire them
-    // after construction — used by {@code TransportWebSocketFactory} to honour
-    // {@code DeepgramTransportFactory.reconnectOptions()} without editing the generated WS clients.
-    private volatile long minReconnectionDelayMs;
+    private final long minReconnectionDelayMs;
 
-    private volatile long maxReconnectionDelayMs;
+    private final long maxReconnectionDelayMs;
 
-    private volatile double reconnectionDelayGrowFactor;
+    private final double reconnectionDelayGrowFactor;
 
-    private volatile int maxRetries;
+    private final int maxRetries;
 
     private final int maxEnqueuedMessages;
 
-    private volatile long connectionTimeoutMs;
-
     private final AtomicInteger retryCount = new AtomicInteger(0);
 
     private final AtomicBoolean connectLock = new AtomicBoolean(false);
@@ -71,44 +66,16 @@ public ReconnectingWebSocketListener(
         this.reconnectionDelayGrowFactor = options.reconnectionDelayGrowFactor;
         this.maxRetries = options.maxRetries;
         this.maxEnqueuedMessages = options.maxEnqueuedMessages;
-        this.connectionTimeoutMs = options.connectionTimeoutMs;
         this.connectionSupplier = connectionSupplier;
     }
 
-    /**
-     * Replaces the option-derived parameters on this listener at runtime. Used by
-     * {@code TransportWebSocketFactory} to apply {@code DeepgramTransportFactory.reconnectOptions()}
-     * without requiring edits to the generated per-resource WebSocket clients. {@code maxEnqueuedMessages}
-     * is intentionally not overridden — the message queue is sized at construction.
-     *
-     * <p>Thread-safety: option-derived fields are volatile; reads observe the latest write. The
-     * initial connect() call may have already started before the override lands, so for the very
-     * first attempt the original options apply; the override takes effect from the next attempt
-     * onwards. For the SageMaker storm-suppression case ({@code maxRetries(0)}) this is fine
-     * because the initial attempt's gate ({@code retryCount > maxRetries} with {@code retryCount=0})
-     * always passes regardless.
-     *
-     * @param options replacement options; {@code null} is a no-op.
-     */
-    public void applyOptionsOverride(ReconnectOptions options) {
-        if (options == null) {
-            return;
-        }
-        this.minReconnectionDelayMs = options.minReconnectionDelayMs;
-        this.maxReconnectionDelayMs = options.maxReconnectionDelayMs;
-        this.reconnectionDelayGrowFactor = options.reconnectionDelayGrowFactor;
-        this.maxRetries = options.maxRetries;
-        this.connectionTimeoutMs = options.connectionTimeoutMs;
-    }
-
     /**
      * Initiates a WebSocket connection with automatic reconnection enabled.
      *
      * Connection behavior:
-     * - Times out after {@code ReconnectOptions.connectionTimeoutMs} (default 4000ms)
+     * - Times out after 4000 milliseconds
      * - Thread-safe via atomic lock (returns immediately if connection in progress)
-     * - {@code maxRetries} counts retries only — the initial attempt always proceeds.
-     *   {@code maxRetries(0)} means "connect once, don't retry" (not "refuse to connect").
+     * - Retry count not incremented for initial connection attempt
      *
      * Error handling:
      * - TimeoutException: Includes retry attempt context
@@ -119,21 +86,18 @@ public void connect() {
         if (!connectLock.compareAndSet(false, true)) {
             return;
         }
-        // retryCount is incremented inside scheduleReconnect() before re-entering connect(),
-        // so on the initial call retryCount == 0 and we always proceed. The cap applies to
-        // retries only — maxRetries(0) blocks retries but allows the initial attempt.
-        if (retryCount.get() > maxRetries) {
+        if (retryCount.get() >= maxRetries) {
             connectLock.set(false);
             return;
         }
         try {
             CompletableFuture<? extends WebSocket> connectionFuture = CompletableFuture.supplyAsync(connectionSupplier);
             try {
-                webSocket = connectionFuture.get(connectionTimeoutMs, MILLISECONDS);
+                webSocket = connectionFuture.get(4000, MILLISECONDS);
             } catch (TimeoutException e) {
                 connectionFuture.cancel(true);
                 TimeoutException timeoutError =
-                        new TimeoutException("WebSocket connection timeout after " + connectionTimeoutMs + " milliseconds"
+                        new TimeoutException("WebSocket connection timeout after " + 4000 + " milliseconds"
                                 + (retryCount.get() > 0
                                         ? " (retry attempt #" + retryCount.get()
                                         : " (initial connection attempt)"));
@@ -435,15 +399,12 @@ public static final class ReconnectOptions {
 
         public final int maxEnqueuedMessages;
 
-        public final long connectionTimeoutMs;
-
         private ReconnectOptions(Builder builder) {
             this.minReconnectionDelayMs = builder.minReconnectionDelayMs;
             this.maxReconnectionDelayMs = builder.maxReconnectionDelayMs;
             this.reconnectionDelayGrowFactor = builder.reconnectionDelayGrowFactor;
             this.maxRetries = builder.maxRetries;
             this.maxEnqueuedMessages = builder.maxEnqueuedMessages;
-            this.connectionTimeoutMs = builder.connectionTimeoutMs;
         }
 
         public static Builder builder() {
@@ -461,15 +422,12 @@ public static final class Builder {
 
             private int maxEnqueuedMessages;
 
-            private long connectionTimeoutMs;
-
             public Builder() {
                 this.minReconnectionDelayMs = 1000;
                 this.maxReconnectionDelayMs = 10000;
                 this.reconnectionDelayGrowFactor = 1.3;
                 this.maxRetries = 2147483647;
                 this.maxEnqueuedMessages = 1000;
-                this.connectionTimeoutMs = 4000;
             }
 
             public Builder minReconnectionDelayMs(long minReconnectionDelayMs) {
@@ -497,16 +455,6 @@ public Builder maxEnqueuedMessages(int maxEnqueuedMessages) {
                 return this;
             }
 
-            /**
-             * Sets the per-attempt connection timeout in milliseconds. Defaults to {@code 4000}.
-             * Each call to {@link ReconnectingWebSocketListener#connect()} will wait at most
-             * this long for the underlying WebSocket factory to produce a connected socket.
-             */
-            public Builder connectionTimeoutMs(long connectionTimeoutMs) {
-                this.connectionTimeoutMs = connectionTimeoutMs;
-                return this;
-            }
-
             /**
              * Builds the ReconnectOptions with validation.
              *
@@ -515,7 +463,6 @@ public Builder connectionTimeoutMs(long connectionTimeoutMs) {
              * - minReconnectionDelayMs <= maxReconnectionDelayMs
              * - reconnectionDelayGrowFactor >= 1.0
              * - maxRetries and maxEnqueuedMessages are non-negative
-             * - connectionTimeoutMs is positive
              *
              * @return The validated ReconnectOptions instance
              * @throws IllegalArgumentException if configuration is invalid
@@ -540,9 +487,6 @@ public ReconnectOptions build() {
                 if (maxEnqueuedMessages < 0) {
                     throw new IllegalArgumentException("maxEnqueuedMessages must be non-negative");
                 }
-                if (connectionTimeoutMs <= 0) {
-                    throw new IllegalArgumentException("connectionTimeoutMs must be positive");
-                }
                 return new ReconnectOptions(this);
             }
         }

src/main/java/com/deepgram/resources/agent/v1/settings/think/models/AsyncRawModelsClient.java

@@ -42,7 +42,7 @@ public CompletableFuture<DeepgramApiHttpResponse<AgentThinkModelsV1Response>> li
      * Retrieves the available think models that can be used for AI agent processing
      */
     public CompletableFuture<DeepgramApiHttpResponse<AgentThinkModelsV1Response>> list(RequestOptions requestOptions) {
-        HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getAgentURL())
+        HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getAgentRestURL())
                 .newBuilder()
                 .addPathSegments("v1/agent/settings/think/models");
         if (requestOptions != null) {

src/main/java/com/deepgram/resources/agent/v1/settings/think/models/RawModelsClient.java

@@ -38,7 +38,7 @@ public DeepgramApiHttpResponse<AgentThinkModelsV1Response> list() {
      * Retrieves the available think models that can be used for AI agent processing
      */
     public DeepgramApiHttpResponse<AgentThinkModelsV1Response> list(RequestOptions requestOptions) {
-        HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getAgentURL())
+        HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getAgentRestURL())
                 .newBuilder()
                 .addPathSegments("v1/agent/settings/think/models");
         if (requestOptions != null) {