release: v1.0.10 — 腾讯云 Coding Plan 套餐支持

root/usr/share/openclaw/web-pty.js

@@ -106,12 +106,29 @@ class PtySession {
     this.alive = true;
     this._spawnFailCount = 0;
     this._MAX_SPAWN_RETRIES = 5;
+    this._pingTimer = null;
+    this._pongReceived = true;
     activeSessions++;
     console.log(`[oc-config] Session created (active: ${activeSessions}/${MAX_SESSIONS})`);
     this._setupWSReader();
+    this._startPing();
     this._spawnPty();
   }
 
+  // WebSocket ping/pong 保活 (每 25 秒发一次 ping)
+  _startPing() {
+    this._pingTimer = setInterval(() => {
+      if (!this.alive) { clearInterval(this._pingTimer); return; }
+      if (!this._pongReceived) {
+        console.log('[oc-config] Pong timeout, closing connection');
+        this._cleanup();
+        return;
+      }
+      this._pongReceived = false;
+      try { this.socket.write(encodeWSFrame(Buffer.alloc(0), 0x09)); } catch(e) { this._cleanup(); }
+    }, 25000);
+  }
+
   _setupWSReader() {
     this.socket.on('data', (chunk) => {
       this.buffer = Buffer.concat([this.buffer, chunk]);
@@ -123,6 +140,7 @@ class PtySession {
         else if (frame.opcode === 0x02 && this.proc && this.proc.stdin.writable) this.proc.stdin.write(frame.data);
         else if (frame.opcode === 0x08) { console.log('[oc-config] WS close frame received'); this._cleanup(); }
         else if (frame.opcode === 0x09) this.socket.write(encodeWSFrame(frame.data, 0x0a));
+        else if (frame.opcode === 0x0a) { this._pongReceived = true; }
       }
     });
     this.socket.on('close', (hadError) => { console.log(`[oc-config] Socket closed, hadError=${hadError}`); this._cleanup(); });
@@ -141,6 +159,10 @@ class PtySession {
         this.cols = msg.cols || 80; this.rows = msg.rows || 24;
         if (this.proc && this.proc.pid) { try { process.kill(-this.proc.pid, 'SIGWINCH'); } catch(e){} }
       }
+      else if (msg.type === 'ping') {
+        // 应用层心跳: 客户端定期发送 ping，服务端回复 pong 保持连接活跃
+        this.socket.write(encodeWSFrame(JSON.stringify({ type: 'pong' }), 0x01));
+      }
     } catch(e) { if (this.proc && this.proc.stdin.writable) this.proc.stdin.write(text); }
   }
 
@@ -205,6 +227,7 @@ class PtySession {
 
   _cleanup() {
     if (!this.alive) return; this.alive = false;
+    if (this._pingTimer) { clearInterval(this._pingTimer); this._pingTimer = null; }
     activeSessions = Math.max(0, activeSessions - 1);
     console.log(`[oc-config] Session ended (active: ${activeSessions}/${MAX_SESSIONS})`);
     if (this.proc) { try { process.kill(-this.proc.pid, 'SIGTERM'); } catch(e){} try { this.proc.kill('SIGTERM'); } catch(e){} }