SDK regeneration

Author: fern-api[bot]

.fern/metadata.json

@@ -11,7 +11,7 @@
     },
     "enable-wire-tests": true
   },
-  "originGitCommit": "0be656a350cef88f6586d6cb4aa28f8fc25b30ea",
+  "originGitCommit": "a2c7ddbf260366af00a0e541a7e9ad4de19acabe",
   "originGitCommitIsDirty": true,
   "invokedBy": "manual",
   "sdkVersion": "0.5.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.5.0"); // x-release-please-version
+                put("User-Agent", "com.deepgram:deepgram-sdk/0.5.1");
                 put("X-Fern-Language", "JAVA");
-                put("X-Fern-SDK-Name", "com.deepgram:deepgram-java-sdk");
-                put("X-Fern-SDK-Version", "0.5.0"); // x-release-please-version
+                put("X-Fern-SDK-Name", "com.deepgram.fern:api-sdk");
+                put("X-Fern-SDK-Version", "0.5.1");
             }
         });
         this.headerSuppliers = headerSuppliers;

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/listen/v2/types/ListenV2TurnInfoWordsItem.java

@@ -10,12 +10,10 @@
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.annotation.JsonSetter;
-import com.fasterxml.jackson.annotation.Nulls;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
-import java.util.Optional;
 import org.jetbrains.annotations.NotNull;
 
 @JsonInclude(JsonInclude.Include.NON_ABSENT)
@@ -25,18 +23,14 @@ public final class ListenV2TurnInfoWordsItem {
 
     private final float confidence;
 
-    private final Optional<Float> start;
+    private final double start;
 
-    private final Optional<Float> end;
+    private final double end;
 
     private final Map<String, Object> additionalProperties;
 
     private ListenV2TurnInfoWordsItem(
-            String word,
-            float confidence,
-            Optional<Float> start,
-            Optional<Float> end,
-            Map<String, Object> additionalProperties) {
+            String word, float confidence, double start, double end, Map<String, Object> additionalProperties) {
         this.word = word;
         this.confidence = confidence;
         this.start = start;
@@ -64,15 +58,15 @@ public float getConfidence() {
      * @return The start time of the word
      */
     @JsonProperty("start")
-    public Optional<Float> getStart() {
+    public double getStart() {
         return start;
     }
 
     /**
      * @return The end time of the word
      */
     @JsonProperty("end")
-    public Optional<Float> getEnd() {
+    public double getEnd() {
         return end;
     }
 
@@ -88,10 +82,7 @@ public Map<String, Object> getAdditionalProperties() {
     }
 
     private boolean equalTo(ListenV2TurnInfoWordsItem other) {
-        return word.equals(other.word)
-                && confidence == other.confidence
-                && start.equals(other.start)
-                && end.equals(other.end);
+        return word.equals(other.word) && confidence == other.confidence && start == other.start && end == other.end;
     }
 
     @java.lang.Override
@@ -121,40 +112,40 @@ public interface ConfidenceStage {
         /**
          * <p>Confidence that this word was transcribed correctly</p>
          */
-        _FinalStage confidence(float confidence);
+        StartStage confidence(float confidence);
     }
 
-    public interface _FinalStage {
-        ListenV2TurnInfoWordsItem build();
-
-        _FinalStage additionalProperty(String key, Object value);
-
-        _FinalStage additionalProperties(Map<String, Object> additionalProperties);
-
+    public interface StartStage {
         /**
          * <p>The start time of the word</p>
          */
-        _FinalStage start(Optional<Float> start);
-
-        _FinalStage start(Float start);
+        EndStage start(double start);
+    }
 
+    public interface EndStage {
         /**
          * <p>The end time of the word</p>
          */
-        _FinalStage end(Optional<Float> end);
+        _FinalStage end(double end);
+    }
 
-        _FinalStage end(Float end);
+    public interface _FinalStage {
+        ListenV2TurnInfoWordsItem build();
+
+        _FinalStage additionalProperty(String key, Object value);
+
+        _FinalStage additionalProperties(Map<String, Object> additionalProperties);
     }
 
     @JsonIgnoreProperties(ignoreUnknown = true)
-    public static final class Builder implements WordStage, ConfidenceStage, _FinalStage {
+    public static final class Builder implements WordStage, ConfidenceStage, StartStage, EndStage, _FinalStage {
         private String word;
 
         private float confidence;
 
-        private Optional<Float> end = Optional.empty();
+        private double start;
 
-        private Optional<Float> start = Optional.empty();
+        private double end;
 
         @JsonAnySetter
         private Map<String, Object> additionalProperties = new HashMap<>();
@@ -189,48 +180,32 @@ public ConfidenceStage word(@NotNull String word) {
          */
         @java.lang.Override
         @JsonSetter("confidence")
-        public _FinalStage confidence(float confidence) {
+        public StartStage confidence(float confidence) {
             this.confidence = confidence;
             return this;
         }
 
         /**
-         * <p>The end time of the word</p>
+         * <p>The start time of the word</p>
+         * <p>The start time of the word</p>
          * @return Reference to {@code this} so that method calls can be chained together.
          */
         @java.lang.Override
-        public _FinalStage end(Float end) {
-            this.end = Optional.ofNullable(end);
+        @JsonSetter("start")
+        public EndStage start(double start) {
+            this.start = start;
             return this;
         }
 
         /**
          * <p>The end time of the word</p>
-         */
-        @java.lang.Override
-        @JsonSetter(value = "end", nulls = Nulls.SKIP)
-        public _FinalStage end(Optional<Float> end) {
-            this.end = end;
-            return this;
-        }
-
-        /**
-         * <p>The start time of the word</p>
+         * <p>The end time of the word</p>
          * @return Reference to {@code this} so that method calls can be chained together.
          */
         @java.lang.Override
-        public _FinalStage start(Float start) {
-            this.start = Optional.ofNullable(start);
-            return this;
-        }
-
-        /**
-         * <p>The start time of the word</p>
-         */
-        @java.lang.Override
-        @JsonSetter(value = "start", nulls = Nulls.SKIP)
-        public _FinalStage start(Optional<Float> start) {
-            this.start = start;
+        @JsonSetter("end")
+        public _FinalStage end(double end) {
+            this.end = end;
             return this;
         }