Method callApi

src/client/http/HttpClient.ts:35–85

(apiName: T, req: ServiceType['req'][T], options: TransportOptions = {})

    }

    callApi<T extends keyof ServiceType['req']>(apiName: T, req: ServiceType['req'][T], options: TransportOptions = {}): SuperPromise<ServiceType['res'][T], TsrpcError> {
        let sn = this._snCounter.getNext();
        this.logger.log(`[ApiReq] #${sn}`, apiName, req);

        // GetService
        let service = this.serviceMap.apiName2Service[apiName as string];
        if (!service) {
            throw new Error('Invalid api name: ' + apiName);
        }

        // Encode
        let buf = TransportDataUtil.encodeApiReq(this.tsbuffer, service, req);

        // Send
        return this._sendBuf(buf, options, 'api', sn).then(resBuf => {
            if (!resBuf) {
                throw new TsrpcError('Unknown Error', {
                    code: 'EMPTY_RES',
                    isServerOutputError: true
                })
            }

            // Parsed res
            let parsed: ParsedServerOutput;
            try {
                parsed = TransportDataUtil.parseServerOutout(this.tsbuffer, this.serviceMap, resBuf);
            }
            catch (e) {
                throw new TsrpcError('Invalid server output', {
                    code: 'INVALID_SERVER_OUTPUT',
                    isServerOutputError: true,
                    innerError: e,
                    buf: resBuf
                });
            }
            if (parsed.type !== 'api') {
                throw new TsrpcError('Invalid response', {
                    code: 'INVALID_API_ID',
                    isServerOutputError: true
                });
            }
            if (parsed.isSucc) {
                this.logger.log(`[ApiRes] #${sn}`, parsed.res)
                return parsed.res;
            }
            else {
                this.logger.log(`[ApiErr] #${sn}`, parsed.error)
                throw parsed.error;
            }
        })
    }

    sendMsg<T extends keyof ServiceType['msg']>(msgName: T, msg: ServiceType['msg'][T], options: TransportOptions = {}): SuperPromise<void, TsrpcError> {
        let sn = this._snCounter.getNext();