fix: delegate isHeartbeatFresh to WsTransport activity tracking

The createWsRpcClient stub hardcoded isHeartbeatFresh to always return
false, causing reconnectEnvironmentConnectionsAfterBrowserResume to
trigger full reconnects for every environment on tab focus even when
connections were still active.

Add lastActivityAt tracking to WsTransport (updated on successful
requests and stream values) and expose isHeartbeatFresh() that checks
whether activity occurred within the last 30 seconds. Wire
createWsRpcClient to delegate to the transport method.

Author: cursoragent

packages/client-runtime/src/wsRpcClient.ts

@@ -171,7 +171,7 @@ export function createWsRpcClient(
 ): WsRpcClient {
   return {
     dispose: () => transport.dispose(),
-    isHeartbeatFresh: () => false,
+    isHeartbeatFresh: () => transport.isHeartbeatFresh(),
     reconnect: async () => {
       options?.beforeReconnect?.();
       await transport.reconnect();

packages/client-runtime/src/wsTransport.ts

@@ -44,6 +44,7 @@ interface SubscribeOptions {
 }
 
 const DEFAULT_SUBSCRIPTION_RETRY_DELAY = Duration.millis(250);
+const HEARTBEAT_FRESH_THRESHOLD_MS = 30_000;
 const NOOP: () => void = () => undefined;
 
 interface TransportSession {
@@ -68,6 +69,7 @@ export class WsTransport {
   private hasReportedTransportDisconnect = false;
   private reconnectChain: Promise<void> = Promise.resolve();
   private session: TransportSession;
+  private lastActivityAt = performance.now();
 
   constructor(
     url: WsRpcProtocolSocketUrlProvider,
@@ -89,7 +91,9 @@ export class WsTransport {
 
     const session = this.session;
     const client = await session.clientPromise;
-    return await session.runtime.runPromise(Effect.suspend(() => execute(client)));
+    const result = await session.runtime.runPromise(Effect.suspend(() => execute(client)));
+    this.lastActivityAt = performance.now();
+    return result;
   }
 
   async requestStream<TValue>(
@@ -105,6 +109,7 @@ export class WsTransport {
     await session.runtime.runPromise(
       Stream.runForEach(connect(client), (value) =>
         Effect.sync(() => {
+          this.lastActivityAt = performance.now();
           try {
             listener(value);
           } catch {
@@ -228,6 +233,10 @@ export class WsTransport {
     await this.closeSession(this.session);
   }
 
+  isHeartbeatFresh(): boolean {
+    return performance.now() - this.lastActivityAt < HEARTBEAT_FRESH_THRESHOLD_MS;
+  }
+
   private closeSession(session: TransportSession) {
     return session.runtime.runPromise(Scope.close(session.clientScope, Exit.void)).finally(() => {
       session.runtime.dispose();
@@ -283,6 +292,7 @@ export class WsTransport {
                 return;
               }
 
+              this.lastActivityAt = performance.now();
               markValueReceived();
               try {
                 listener(value);