Method invoke

src/main/pmhq/base.ts:415–506

(method: Extract<unknown, `${S}/${M}`> | string, args: P, options: InvokeOptions<R> = {})

  // 实际实现
  invoke<
    R = any,
    S extends keyof NTService = any,
    M extends keyof NTService[S] & string = any,
    P extends Parameters<Extract<NTService[S][M], (...args: any) => unknown>> = any
  >(method: Extract<unknown, `${S}/${M}`> | string, args: P, options: InvokeOptions<R> = {}): Promise<R> {
    const splitMethod = method.split('/')
    const serviceName = splitMethod[0] as keyof NTService
    const methodName = splitMethod.slice(1).join('/')
    const pmhqService = NT_SERVICE_TO_PMHQ[serviceName]
    let funcName = ''
    if (pmhqService) {
      if (NOT_SESSION_SERVICES.includes(serviceName))
        funcName = `${pmhqService}.${methodName}`
      else {
        funcName = `wrapperSession.${pmhqService}().${methodName}`
      }
    }
    else {
      funcName = method
    }
    const timeout = options.timeout ?? 15000

    return new Promise<R>((resolve, reject) => {
      let timeoutId = null
      let hookId: string = ''
      if (timeout) {
        timeoutId = setTimeout(() => {
          this.removeReceiveHook(hookId)
          const display = inspect(args, {
            depth: 10,
            compact: true,
            breakLength: Infinity,
            maxArrayLength: 220
          })
          reject(new Error(`invoke timeout, ${funcName}, ${display}`))
        }, timeout)
      }
      if (options.resultCmd) {
        let firstResult: unknown = undefined
        hookId = this.registerReceiveHook<R>(options.resultCmd as string, (data: R) => {
          if (options.resultCb && !options.resultCb(data, firstResult)) {
            return
          }
          resolve(data)
          this.removeReceiveHook(hookId)
          if (timeoutId) {
            clearTimeout(timeoutId)
          }
        })
        this.call(funcName, args, timeout).then(r => {
          firstResult = r
          if (options.onCallResult) {
            const result = options.onCallResult(r)
            if (result !== undefined) {
              resolve(result)
              this.removeReceiveHook(hookId)
              if (timeoutId) clearTimeout(timeoutId)