Method callWs

test/onebot11-api-test/core/ApiClient.ts:324–366

* WebSocket 方式调用接口 * @param action 接口名称 * @param params 接口参数 * @returns API 响应 * @throws {NetworkError} 网络请求失败 * @throws {TimeoutError} 请求超时

(action: ActionName, params: any = {})

   * @throws {TimeoutError} 请求超时
   */
  async callWs(action: ActionName, params: any = {}): Promise<ApiResponse> {
    // 确保 WebSocket 已连接
    await this.connectWs();

    if (!this.ws || this.ws.readyState !== WebSocket.OPEN) {
      throw new NetworkError('WebSocket is not connected');
    }

    // 生成唯一的 echo 标识
    const echo = `${action}_${Date.now()}_${Math.random().toString(36).substring(7)}`;

    // 创建请求对象
    const request: WsRequest = {
      action,
      params,
      echo,
    };

    // 发送请求并等待响应
    return new Promise((resolve, reject) => {
      // 设置超时
      const timeout = setTimeout(() => {
        this.pendingRequests.delete(echo);
        reject(new TimeoutError(`WebSocket request timeout: ${action}`, 30000));
      }, 30000);

      // 保存待处理的请求
      this.pendingRequests.set(echo, {
        resolve,
        reject,
        timeout,
      });

      // 发送请求
      try {
        this.ws!.send(JSON.stringify(request));
      } catch (error) {
        clearTimeout(timeout);
        this.pendingRequests.delete(echo);
        reject(new NetworkError(`Failed to send WebSocket request: ${action}`, error as Error));
      }
    });
  }

  /**
   * 统一调用接口（根据配置的协议自动选择）