fix(session): cancel any queued reconnect once restored; release 0.11.9

CHANGELOG.md

@@ -2,6 +2,13 @@
 
 ## [Unreleased]
 
+## [0.11.9] - 2026-10-08
+
+### Fixed
+
+- Recovery: once the session is restored, any reconnect attempt still waiting to start is cancelled, whichever way the connection came back.
+- Recovery: a reconnect attempt whose connection is up but still opening its data channel is given time to finish instead of being replaced.
+
 ## [0.11.8] - 2026-10-08
 
 ### Fixed

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@voicethere/client",
-  "version": "0.11.8",
+  "version": "0.11.9",
   "description": "VoiceThere browser/Node client — cloud gateway, browser voice/chat, embed widget",
   "type": "module",
   "exports": {

src/browser/browser-voice-session-recovery.test.ts

@@ -485,6 +485,52 @@ describe("connectBrowserVoiceSession time-budgeted recovery", () => {
     expect(MockWebSocket.instances.length).toBe(wsCount);
   });
 
+  it("a queued attempt is cancelled when a reconnect attempt restores the session", async () => {
+    vi.useFakeTimers();
+    const onReconnected = vi.fn();
+    const { session, replacement, debugLines } = await startCheckingAttempt({
+      onReconnected,
+    });
+    // The replacement drops, which queues attempt 2 behind its backoff ...
+    replacement.fail();
+    await flush();
+    const wsCount = MockWebSocket.instances.length;
+    // ... then comes back and opens its channels before that attempt starts.
+    setIce(replacement, "connected");
+    openDataChannels(replacement);
+    await flush();
+    expect(session.getConnectionStatus().recovery?.state).toBe("restored");
+    await vi.advanceTimersByTimeAsync(5_000);
+    expect(MockWebSocket.instances.length).toBe(wsCount);
+    expect(
+      debugLines.some(
+        (l) => l.includes("reconnect_cancelled") && l.includes("via=reconnect"),
+      ),
+    ).toBe(true);
+    expect(session.getConnectionStatus().recovery?.state).toBe("restored");
+  });
+
+  it("settle timer extends while the replacement is connected but its data channel is not open", async () => {
+    vi.useFakeTimers();
+    const onReconnected = vi.fn();
+    const { session, replacement, debugLines } = await startCheckingAttempt({
+      onReconnected,
+    });
+    setIce(replacement, "connected");
+    replacement.connect();
+    const wsCount = MockWebSocket.instances.length;
+    await vi.advanceTimersByTimeAsync(6_500);
+    expect(
+      debugLines.some((l) => l.includes("reconnect_settle_extended")),
+    ).toBe(true);
+    expect(MockWebSocket.instances.length).toBe(wsCount);
+    openDataChannels(replacement);
+    await flush();
+    expect(session.getConnectionStatus().recovery?.state).toBe("restored");
+    expect(onReconnected).toHaveBeenCalledTimes(1);
+    expect(MockWebSocket.instances.length).toBe(wsCount);
+  });
+
   it("an attempt in flight at budget end gets the grace and restores", async () => {
     vi.useFakeTimers();
     const { session, replacement, errors } = await startCheckingAttempt({

src/browser/browser-voice-session.ts

@@ -913,6 +913,12 @@ export async function connectBrowserVoiceSession(
     ) {
       return false;
     }
+    if (
+      state === "connected" &&
+      !isWebRtcConnectionReady(connectionSnapshot, readinessProfile)
+    ) {
+      return true;
+    }
     return ice === "checking" || state === "connecting";
   };
 
@@ -1057,14 +1063,14 @@ export async function connectBrowserVoiceSession(
     outageStartMs = null;
     outageRestoreEligible = false;
     clearRecoveryTimers();
-    // The original connection came back before the queued attempt started: drop it.
-    if (outageRecoveryVia === "ice-restart" && reconnectTimer) {
+    // The session is back: an attempt still waiting to start would replace a healthy connection.
+    if (reconnectTimer) {
       clearTimeout(reconnectTimer);
       reconnectTimer = undefined;
       debug?.info(
         "session",
         "reconnect_cancelled",
-        `restored_before_attempt attempt=${autoReconnectAttempts}`,
+        `restored_before_attempt via=${outageRecoveryVia} attempt=${autoReconnectAttempts}`,
       );
     }
     debug?.info(
@@ -1294,6 +1300,7 @@ export async function connectBrowserVoiceSession(
     );
     if (reconnectTimer) clearTimeout(reconnectTimer);
     reconnectTimer = setTimeout(() => {
+      reconnectTimer = undefined;
       void reconnectSignaling(true)
         .then(() => armSettleTimer(ICE_RECOVERY_SETTLE_MS, "ice_recovery"))
         .catch((error: unknown) => {
@@ -2054,6 +2061,7 @@ export async function connectBrowserVoiceSession(
     if (settleTimer) clearTimeout(settleTimer);
     settleTimer = undefined;
     reconnectTimer = setTimeout(() => {
+      reconnectTimer = undefined;
       replacementIceDead = false;
       outageRecoveryVia = "reconnect";
       void reconnectSignaling(true)