claude-dev/Dockerfile

@@ -28,6 +28,13 @@ ARG YQ_VERSION=v4.44.6
 RUN wget -q -O /usr/local/bin/yq "https://github.com/mikefarah/yq/releases/download/${YQ_VERSION}/yq_linux_amd64" \
     && chmod +x /usr/local/bin/yq
 
+ARG TEA_VERSION=0.12.0
+RUN wget -q -O /tmp/tea.tar.gz "https://dl.gitea.com/tea/${TEA_VERSION}/tea-${TEA_VERSION}-linux-amd64.tar.gz" \
+    && tar -xzf /tmp/tea.tar.gz -C /tmp \
+    && mv /tmp/tea-${TEA_VERSION}-linux-amd64/tea /usr/local/bin/tea \
+    && chmod +x /usr/local/bin/tea \
+    && rm -rf /tmp/tea.tar.gz /tmp/tea-${TEA_VERSION}-linux-amd64
+
 RUN npm install -g @anthropic-ai/claude-code
 
 RUN python3 - <<'PY'

claude-dev/required-tools.txt

@@ -14,4 +14,5 @@ zip
 unzip
 make
 tmux
+tea
 claude

dashboard/backend/routers/terminal.py

@@ -190,18 +190,31 @@ async def ws_endpoint(websocket: WebSocket, host: str = Query("nas")):
                         rows = struct.unpack("!H", data[3:5])[0]
                         process.channel.change_terminal_size(cols, rows)
                     else:
-                        process.stdin.write(data)
+                        try:
+                            process.stdin.write(data)
+                        except (BrokenPipeError, OSError) as e:
+                            logger.warning("Failed to write to stdin for %s: %s", host, e)
+                            break
                 elif "text" in msg and msg["text"]:
                     if msg["text"] == "__ping__":
                         logger.debug("Received ping from %s, sending pong", host)
                         await websocket.send_text("__pong__")
                         continue
-                    process.stdin.write(msg["text"].encode())
+                    try:
+                        process.stdin.write(msg["text"].encode())
+                    except (BrokenPipeError, OSError) as e:
+                        logger.warning("Failed to write to stdin for %s: %s", host, e)
+                        break
         except Exception as e:
             logger.warning("WebSocket receive loop ended for %s: %s", host, e)
         finally:
             read_task.cancel()
+            try:
+                await asyncio.wait_for(read_task, timeout=2.0)
+            except (asyncio.TimeoutError, asyncio.CancelledError):
+                pass
             process.close()
     finally:
         conn.close()
+        await conn.wait_closed()
         await _release_session(session_id)

dashboard/frontend/src/routes/Terminal.svelte

@@ -300,7 +300,9 @@
               ws.send("__ping__");
               // Set timeout to detect missing pong
               pongTimeout = setTimeout(() => {
-                if (ws.readyState === 1) {
+                // Check if still the same WebSocket instance and still open
+                const currentTab = tabData.get(tabId);
+                if (currentTab?.ws === ws && ws.readyState === 1) {
                   ws.close(1000, "keepalive ping timeout");
                 }
               }, PONG_TIMEOUT);
@@ -343,8 +345,8 @@
         };
         ws.onclose = async (e) => {
           const reason = e.reason || `Connection closed (code ${e.code})`;
-          d = tabData.get(tabId);
+          const tabState = tabData.get(tabId);
-          if (d) d.ws = null;
+          if (tabState) tabState.ws = null;
 
           // Handle auth failures (code 1008)
           if (e.code === 1008) {
@@ -359,18 +361,23 @@
             // Try to refresh session
             if (!closedManually && !authRecoveryInFlight) {
               authRecoveryInFlight = true;
-              const refreshed = await tryRefreshSession();
+              try {
-              authRecoveryInFlight = false;
+                const refreshed = await tryRefreshSession();
-              if (refreshed && !closedManually) {
+                if (refreshed && !closedManually) {
-                reconnecting = true;
+                  reconnecting = true;
-                updateTab(tabId, {
+                  updateTab(tabId, {
-                  connected: false,
+                    connected: false,
-                  error: `Refreshing session (attempt ${consecutiveAuthFailures}/${MAX_AUTH_FAILURES})...`,
+                    error: `Refreshing session (attempt ${consecutiveAuthFailures}/${MAX_AUTH_FAILURES})...`,
-                  statusBanner: tab.persistent ? "Reconnecting to persistent session..." : "",
+                    statusBanner: tab.persistent ? "Reconnecting to persistent session..." : "",
-                });
+                  });
-                term.write(`\r\n\x1b[90m[Refreshing session...]\x1b[0m`);
+                  term.write(`\r\n\x1b[90m[Refreshing session...]\x1b[0m`);
-                void connect(false);
+                  void connect(false);
-                return;
+                  return;
+                }
+              } catch (err) {
+                console.error("Session refresh failed:", err);
+              } finally {
+                authRecoveryInFlight = false;
               }
             }
             handleAuthExpired("Session expired — please log in again");
@@ -386,8 +393,8 @@
           }
         };
         ws.onerror = () => {
-          d = tabData.get(tabId);
+          const tabState = tabData.get(tabId);
-          if (d) d.ws = null;
+          if (tabState) tabState.ws = null;
           if (!closedManually) scheduleReconnect("Connection failed");
           else updateTab(tabId, { connected: false, error: "Connection failed" });
         };