Method call

src/api/client.ts:114–146

(
    method: string,
    params: Record<string, unknown> = {},
    timeout = CALL_TIMEOUT_MS,
  )

  }

  async call<T = unknown>(
    method: string,
    params: Record<string, unknown> = {},
    timeout = CALL_TIMEOUT_MS,
  ): Promise<T> {
    await this.opened
    const id = nextId()
    const payload = JSON.stringify({
      jsonrpc: '2.0',
      method,
      params: { token: this.token, ...params },
      id,
    })
    const queued = this.ws?.readyState !== WebSocket.OPEN
    log(this.name, `→ ${method} ${queued ? '(queued)' : ''} ${payload.length}B`)

    return new Promise<T>((resolve, reject) => {
      const timer = setTimeout(() => {
        this.pending.delete(id)
        warn(this.name, `× ${method} timeout ${timeout}ms`)
        reject(new Error(`${method} 超时`))
      }, timeout)
      this.pending.set(id, {
        method,
        sentAt: performance.now(),
        resolve: resolve as (v: unknown) => void,
        reject,
        timer,
      })
      if (queued) this.outbox.push(payload)
      else this.ws!.send(payload)
    })
  }

  close() {
    this.closed = true