Method rpc

electron/gateway/manager.ts:867–942

* Make an RPC call to the Gateway * Uses OpenClaw protocol format: { type: "req", id: "...", method: "...", params: {...} }

(method: string, params?: unknown, timeoutMs = 30000)

   * Uses OpenClaw protocol format: { type: "req", id: "...", method: "...", params: {...} }
   */
  async rpc<T>(method: string, params?: unknown, timeoutMs = 30000): Promise<T> {
    const startedAt = Date.now();
    return await new Promise<T>((resolve, reject) => {
      if (!this.ws || this.ws.readyState !== WebSocket.OPEN) {
        reject(new Error('Gateway not connected'));
        return;
      }

      const id = crypto.randomUUID();

      // Set timeout for request
      const timeout = setTimeout(() => {
        rejectPendingGatewayRequest(this.pendingRequests, id, new Error(`RPC timeout: ${method}`));
      }, timeoutMs);

      // Store pending request
      this.pendingRequests.set(id, {
        resolve: resolve as (value: unknown) => void,
        reject,
        timeout,
      });

      // Send request using OpenClaw protocol format
      const request = {
        type: 'req',
        id,
        method,
        params,
      };

      try {
        if (isGatewayWsTraceEnabled()) {
          logger.debug('[gateway-ws-trace] send', {
            summary: summarizeGatewayFrameForTrace(request),
            frame: redactGatewayFrameForTrace(request),
          });
        }
        this.ws.send(JSON.stringify(request));
      } catch (error) {
        rejectPendingGatewayRequest(this.pendingRequests, id, new Error(`Failed to send RPC request: ${error}`));
      }
    }).then((result) => {
      this.recordRpcSuccess();
      if (isCoreRpcMethod(method)) {
        this.capabilityMonitor.recordCoreProbe({
          ok: true,
          checkedAt: Date.now(),
          durationMs: Date.now() - startedAt,
        });
      }
      const capability = classifyCapabilityMethod(method);
      if (capability) {
        this.capabilityMonitor.recordCapabilitySuccess(
          capability,
          result as GatewayRuntimePayload,
          Date.now() - startedAt,
        );
      }