Method getSocket

packages/web/src/lib/socket/manager.ts:25–66

* 获取或创建统一 socket 连接

()

   * 获取或创建统一 socket 连接
   */
  getSocket(): Socket {
    if (!this.socket) {
      this.socket = io(`${this.baseUrl}${NAMESPACE}`, {
        autoConnect: false,
        transports: ['websocket'],  // 跳过 polling，直接用 WebSocket
        reconnection: true,
        reconnectionAttempts: Infinity,
        reconnectionDelay: 1000,
        reconnectionDelayMax: 10000,
      })

      // 连接事件日志
      this.socket.on('connect', () => {
        console.log(`[Socket] Connected to ${NAMESPACE} t=${Date.now()}`)
      })

      this.socket.on('disconnect', (reason) => {
        console.log(`[Socket] Disconnected from ${NAMESPACE}: t=${Date.now()}`, reason)
      })

      this.socket.on('connect_error', (error) => {
        console.error(`[Socket] Connection error on ${NAMESPACE}: t=${Date.now()}`, error.message)
      })

      // 添加原始事件监听用于调试
      if (DEBUG_SOCKET) {
        this.socket.onAny((event, ...args) => {
          if (event === ServerEvents.SESSION_PATCH) {
            const payload = args[0] as { sessionId: string; patch: unknown[] };
            console.log(`[Socket:raw] t=${Date.now()} event=${event} sessionId=${payload.sessionId} ops=${payload.patch?.length}`);
          } else if (event === ServerEvents.SESSION_STDOUT) {
            const payload = args[0] as { sessionId: string; data: string };
            console.log(`[Socket:raw] t=${Date.now()} event=${event} sessionId=${payload.sessionId} dataLen=${payload.data?.length}`);
          } else {
            console.log(`[Socket:raw] t=${Date.now()} event=${event}`);
          }
        });
      }
    }

    return this.socket
  }

  /**
   * 连接到指定命名空间