// This file is auto-generated, don't edit it
import * as $dara from '@darabonba/typescript';
import OpenApiUtil, * as $OpenApiUtil from './utils';
import Credential, * as $Credential from '@alicloud/credentials';
import SPI, * as $SPI from '@alicloud/gateway-spi';


export * as $OpenApiUtil from './utils';
export { default as OpenApiUtil } from './utils';

import * as $_error from './exceptions/error';
export * from './exceptions/error';
import * as $_model from './models/model';
export * from './models/model';
import * as websocketUtils from './websocketUtils';
export * as websocketUtils from './websocketUtils';
export * as WebSocketUtils from './websocketUtils';
export * as $WebSocketUtils from './websocketUtils';

export default class Client {
  _endpoint: string;
  _regionId: string;
  _protocol: string;
  _method: string;
  _userAgent: string;
  _endpointRule: string;
  _endpointMap: {[key: string ]: string};
  _suffix: string;
  _readTimeout: number;
  _connectTimeout: number;
  _httpProxy: string;
  _httpsProxy: string;
  _socks5Proxy: string;
  _socks5NetWork: string;
  _noProxy: string;
  _network: string;
  _productId: string;
  _maxIdleConns: number;
  _endpointType: string;
  _openPlatformEndpoint: string;
  _credential: Credential;
  _signatureVersion: string;
  _signatureAlgorithm: string;
  _headers: {[key: string ]: string};
  _spi: SPI;
  _globalParameters: $OpenApiUtil.GlobalParameters;
  _key: string;
  _cert: string;
  _ca: string;
  _disableHttp2: boolean;
  _retryOptions: $dara.RetryOptions;
  _tlsMinVersion: string;
  _attributeMap: $SPI.AttributeMap;

  /**
   * @remarks
   * Init client with Config
   * 
   * @param config - config contains the necessary information to create a client
   */
  constructor(config: $OpenApiUtil.Config) {
    if ($dara.isNull(config)) {
      throw new $_error.ClientError({
        code: "ParameterMissing",
        message: "'config' can not be unset",
      });
    }

    if ((!$dara.isNull(config.accessKeyId) && config.accessKeyId != "") && (!$dara.isNull(config.accessKeySecret) && config.accessKeySecret != "")) {
      if (!$dara.isNull(config.securityToken) && config.securityToken != "") {
        config.type = "sts";
      } else {
        config.type = "access_key";
      }

      let credentialConfig = new $Credential.Config({
        accessKeyId: config.accessKeyId,
        type: config.type,
        accessKeySecret: config.accessKeySecret,
      });
      credentialConfig.securityToken = config.securityToken;
      this._credential = new Credential(credentialConfig);
    } else if (!$dara.isNull(config.bearerToken) && config.bearerToken != "") {
      let cc = new $Credential.Config({
        type: "bearer",
        bearerToken: config.bearerToken,
      });
      this._credential = new Credential(cc);
    } else if (!$dara.isNull(config.credential)) {
      this._credential = config.credential;
    }

    if ($dara.isNull(config.userAgent)) {
      this._userAgent = process.env["ALIBABA_CLOUD_USER_AGENT"];
    } else {
      this._userAgent = config.userAgent;
    }

    this._endpoint = config.endpoint;
    this._endpointType = config.endpointType;
    this._network = config.network;
    this._suffix = config.suffix;
    this._protocol = config.protocol;
    this._method = config.method;
    this._regionId = config.regionId;
    this._readTimeout = config.readTimeout;
    this._connectTimeout = config.connectTimeout;
    this._httpProxy = config.httpProxy;
    this._httpsProxy = config.httpsProxy;
    this._noProxy = config.noProxy;
    this._socks5Proxy = config.socks5Proxy;
    this._socks5NetWork = config.socks5NetWork;
    this._maxIdleConns = config.maxIdleConns;
    this._signatureVersion = config.signatureVersion;
    this._signatureAlgorithm = config.signatureAlgorithm;
    this._globalParameters = config.globalParameters;
    this._key = config.key;
    this._cert = config.cert;
    this._ca = config.ca;
    this._disableHttp2 = config.disableHttp2;
    this._retryOptions = config.retryOptions;
    this._tlsMinVersion = config.tlsMinVersion;
  }

  /**
   * @remarks
   * Encapsulate the request and invoke the network
   * 
   * @param action - api name
   * @param version - product version
   * @param protocol - http or https
   * @param method - e.g. GET
   * @param authType - authorization type e.g. AK
   * @param bodyType - response body type e.g. String
   * @param request - object of OpenApiRequest
   * @param runtime - which controls some details of call api, such as retry times
   * @returns the response
   */
  async doRPCRequest(action: string, version: string, protocol: string, method: string, authType: string, bodyType: string, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        request_.protocol = this._protocol || protocol;
        request_.method = method;
        request_.pathname = "/";
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        request_.query = {
          Action: action,
          Format: "json",
          Version: version,
          Timestamp: OpenApiUtil.getTimestamp(),
          SignatureNonce: OpenApiUtil.getNonce(),
          ...globalQueries,
          ...extendsQueries,
          ...request.query,
        };
        let headers = this.getRpcHeaders();
        if ($dara.isNull(headers)) {
          // endpoint is setted in product client
          request_.headers = {
            host: this._endpoint,
            'x-acs-version': version,
            'x-acs-action': action,
            'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
            ...globalHeaders,
            ...extendsHeaders,
            ...request.headers,
          };
        } else {
          request_.headers = {
            host: this._endpoint,
            'x-acs-version': version,
            'x-acs-action': action,
            'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
            ...globalHeaders,
            ...extendsHeaders,
            ...request.headers,
            ...headers,
          };
        }

        OpenApiUtil.applyRetryHeaders(request_.headers, _retryAttempts, _backoffTime);

        if (!$dara.isNull(request.body)) {
          let m = request.body;
          let tmp = OpenApiUtil.query(m);
          request_.body = new $dara.BytesReadable($dara.Form.toFormString(tmp));
          request_.headers["content-type"] = "application/x-www-form-urlencoded";
        }

        if (authType != "Anonymous") {
          if ($dara.isNull(this._credential)) {
            throw new $_error.ClientError({
              code: `InvalidCredentials`,
              message: `Please set up the credentials correctly. If you are setting them through environment variables, please ensure that ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set correctly. See https://help.aliyun.com/zh/sdk/developer-reference/configure-the-alibaba-cloud-accesskey-environment-variable-on-linux-macos-and-windows-systems for more details.`,
            });
          }

          let credentialModel = await this._credential.getCredential();
          if (!$dara.isNull(credentialModel.providerName)) {
            request_.headers["x-acs-credentials-provider"] = credentialModel.providerName;
          }

          let credentialType = credentialModel.type;
          if (credentialType == "bearer") {
            let bearerToken = credentialModel.bearerToken;
            request_.query["BearerToken"] = bearerToken;
            request_.query["SignatureType"] = "BEARERTOKEN";
          } else if (credentialType == "id_token") {
            let idToken = credentialModel.securityToken;
            request_.headers["x-acs-zero-trust-idtoken"] = idToken;
          } else {
            let accessKeyId = credentialModel.accessKeyId;
            let accessKeySecret = credentialModel.accessKeySecret;
            let securityToken = credentialModel.securityToken;
            if (!$dara.isNull(securityToken) && securityToken != "") {
              request_.query["SecurityToken"] = securityToken;
            }

            request_.query["SignatureMethod"] = "HMAC-SHA1";
            request_.query["SignatureVersion"] = "1.0";
            request_.query["AccessKeyId"] = accessKeyId;
            let t : {[key: string ]: any} = null;
            if (!$dara.isNull(request.body)) {
              t = request.body;
            }

            let signedParam = {
              ...request_.query,
              ...OpenApiUtil.query(t),
            };
            request_.query["Signature"] = OpenApiUtil.getRPCSignature(signedParam, request_.method, accessKeySecret);
          }

        }

        _lastRequest = request_;
        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
          let _res = await $dara.Stream.readAsJSON(response_.body);
          let err = _res;
          let requestId = err["RequestId"] || err["requestId"];
          let code = err["Code"] || err["code"];
          if (`${code}`.includes("Throttling")) {
            throw new $_error.ThrottlingError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              retryAfter: OpenApiUtil.getThrottlingTimeLeft(response_.headers),
              data: err,
              requestId: `${requestId}`,
            });
          } else if ((response_.statusCode >= 400) && (response_.statusCode < 500)) {
            throw new $_error.ClientError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              accessDeniedDetail: this.getAccessDeniedDetail(err),
              requestId: `${requestId}`,
            });
          } else {
            throw new $_error.ServerError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              requestId: `${requestId}`,
            });
          }

        }

        if (bodyType == "binary") {
          let resp = {
            body: response_.body,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
          return resp;
        } else if (bodyType == "byte") {
          let byt = await $dara.Stream.readAsBytes(response_.body);
          return {
            body: byt,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "string") {
          let _str = await $dara.Stream.readAsString(response_.body);
          return {
            body: _str,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "json") {
          let obj = await $dara.Stream.readAsJSON(response_.body);
          let res = obj;
          return {
            body: res,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "array") {
          let arr = await $dara.Stream.readAsJSON(response_.body);
          return {
            body: arr,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else {
          return {
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        }

      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  /**
   * @remarks
   * Encapsulate the request and invoke the network
   * 
   * @param action - api name
   * @param version - product version
   * @param protocol - http or https
   * @param method - e.g. GET
   * @param authType - authorization type e.g. AK
   * @param pathname - pathname of every api
   * @param bodyType - response body type e.g. String
   * @param request - object of OpenApiRequest
   * @param runtime - which controls some details of call api, such as retry times
   * @returns the response
   */
  async doROARequest(action: string, version: string, protocol: string, method: string, authType: string, pathname: string, bodyType: string, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        request_.protocol = this._protocol || protocol;
        request_.method = method;
        request_.pathname = pathname;
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        request_.headers = {
          date: OpenApiUtil.getDateUTCString(),
          host: this._endpoint,
          accept: "application/json",
          'x-acs-signature-nonce': OpenApiUtil.getNonce(),
          'x-acs-signature-method': "HMAC-SHA1",
          'x-acs-signature-version': "1.0",
          'x-acs-version': version,
          'x-acs-action': action,
          'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
          ...globalHeaders,
          ...extendsHeaders,
          ...request.headers,
        };
        OpenApiUtil.applyRetryHeaders(request_.headers, _retryAttempts, _backoffTime);
        if (!$dara.isNull(request.body)) {
          request_.body = new $dara.BytesReadable(typeof request.body === "string" ? request.body : JSON.stringify(request.body));
          request_.headers["content-type"] = "application/json; charset=utf-8";
        }

        request_.query = {
          ...globalQueries,
          ...extendsQueries,
        };
        if (!$dara.isNull(request.query)) {
          request_.query = {
            ...request_.query,
            ...request.query,
          };
        }

        if (authType != "Anonymous") {
          if ($dara.isNull(this._credential)) {
            throw new $_error.ClientError({
              code: `InvalidCredentials`,
              message: `Please set up the credentials correctly. If you are setting them through environment variables, please ensure that ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set correctly. See https://help.aliyun.com/zh/sdk/developer-reference/configure-the-alibaba-cloud-accesskey-environment-variable-on-linux-macos-and-windows-systems for more details.`,
            });
          }

          let credentialModel = await this._credential.getCredential();
          if (!$dara.isNull(credentialModel.providerName)) {
            request_.headers["x-acs-credentials-provider"] = credentialModel.providerName;
          }

          let credentialType = credentialModel.type;
          if (credentialType == "bearer") {
            let bearerToken = credentialModel.bearerToken;
            request_.headers["x-acs-bearer-token"] = bearerToken;
            request_.headers["x-acs-signature-type"] = "BEARERTOKEN";
          } else if (credentialType == "id_token") {
            let idToken = credentialModel.securityToken;
            request_.headers["x-acs-zero-trust-idtoken"] = idToken;
          } else {
            let accessKeyId = credentialModel.accessKeyId;
            let accessKeySecret = credentialModel.accessKeySecret;
            let securityToken = credentialModel.securityToken;
            if (!$dara.isNull(securityToken) && securityToken != "") {
              request_.headers["x-acs-accesskey-id"] = accessKeyId;
              request_.headers["x-acs-security-token"] = securityToken;
            }

            let stringToSign = OpenApiUtil.getStringToSign(request_);
            request_.headers["authorization"] = `acs ${accessKeyId}:${OpenApiUtil.getROASignature(stringToSign, accessKeySecret)}`;
          }

        }

        _lastRequest = request_;
        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        if (response_.statusCode == 204) {
          return {
            headers: response_.headers,
          };
        }

        if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
          let _res = await $dara.Stream.readAsJSON(response_.body);
          let err = _res;
          let requestId = err["RequestId"] || err["requestId"];
          requestId = requestId || err["requestid"];
          let code = err["Code"] || err["code"];
          if (`${code}`.includes("Throttling")) {
            throw new $_error.ThrottlingError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              retryAfter: OpenApiUtil.getThrottlingTimeLeft(response_.headers),
              data: err,
              requestId: `${requestId}`,
            });
          } else if ((response_.statusCode >= 400) && (response_.statusCode < 500)) {
            throw new $_error.ClientError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              accessDeniedDetail: this.getAccessDeniedDetail(err),
              requestId: `${requestId}`,
            });
          } else {
            throw new $_error.ServerError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              requestId: `${requestId}`,
            });
          }

        }

        if (bodyType == "binary") {
          let resp = {
            body: response_.body,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
          return resp;
        } else if (bodyType == "byte") {
          let byt = await $dara.Stream.readAsBytes(response_.body);
          return {
            body: byt,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "string") {
          let _str = await $dara.Stream.readAsString(response_.body);
          return {
            body: _str,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "json") {
          let obj = await $dara.Stream.readAsJSON(response_.body);
          let res = obj;
          return {
            body: res,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "array") {
          let arr = await $dara.Stream.readAsJSON(response_.body);
          return {
            body: arr,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else {
          return {
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        }

      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  /**
   * @remarks
   * Encapsulate the request and invoke the network with form body
   * 
   * @param action - api name
   * @param version - product version
   * @param protocol - http or https
   * @param method - e.g. GET
   * @param authType - authorization type e.g. AK
   * @param pathname - pathname of every api
   * @param bodyType - response body type e.g. String
   * @param request - object of OpenApiRequest
   * @param runtime - which controls some details of call api, such as retry times
   * @returns the response
   */
  async doROARequestWithForm(action: string, version: string, protocol: string, method: string, authType: string, pathname: string, bodyType: string, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        request_.protocol = this._protocol || protocol;
        request_.method = method;
        request_.pathname = pathname;
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        request_.headers = {
          date: OpenApiUtil.getDateUTCString(),
          host: this._endpoint,
          accept: "application/json",
          'x-acs-signature-nonce': OpenApiUtil.getNonce(),
          'x-acs-signature-method': "HMAC-SHA1",
          'x-acs-signature-version': "1.0",
          'x-acs-version': version,
          'x-acs-action': action,
          'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
          ...globalHeaders,
          ...extendsHeaders,
          ...request.headers,
        };
        OpenApiUtil.applyRetryHeaders(request_.headers, _retryAttempts, _backoffTime);
        if (!$dara.isNull(request.body)) {
          let m = request.body;
          request_.body = new $dara.BytesReadable(OpenApiUtil.toForm(m));
          request_.headers["content-type"] = "application/x-www-form-urlencoded";
        }

        request_.query = {
          ...globalQueries,
          ...extendsQueries,
        };
        if (!$dara.isNull(request.query)) {
          request_.query = {
            ...request_.query,
            ...request.query,
          };
        }

        if (authType != "Anonymous") {
          if ($dara.isNull(this._credential)) {
            throw new $_error.ClientError({
              code: `InvalidCredentials`,
              message: `Please set up the credentials correctly. If you are setting them through environment variables, please ensure that ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set correctly. See https://help.aliyun.com/zh/sdk/developer-reference/configure-the-alibaba-cloud-accesskey-environment-variable-on-linux-macos-and-windows-systems for more details.`,
            });
          }

          let credentialModel = await this._credential.getCredential();
          if (!$dara.isNull(credentialModel.providerName)) {
            request_.headers["x-acs-credentials-provider"] = credentialModel.providerName;
          }

          let credentialType = credentialModel.type;
          if (credentialType == "bearer") {
            let bearerToken = credentialModel.bearerToken;
            request_.headers["x-acs-bearer-token"] = bearerToken;
            request_.headers["x-acs-signature-type"] = "BEARERTOKEN";
          } else if (credentialType == "id_token") {
            let idToken = credentialModel.securityToken;
            request_.headers["x-acs-zero-trust-idtoken"] = idToken;
          } else {
            let accessKeyId = credentialModel.accessKeyId;
            let accessKeySecret = credentialModel.accessKeySecret;
            let securityToken = credentialModel.securityToken;
            if (!$dara.isNull(securityToken) && securityToken != "") {
              request_.headers["x-acs-accesskey-id"] = accessKeyId;
              request_.headers["x-acs-security-token"] = securityToken;
            }

            let stringToSign = OpenApiUtil.getStringToSign(request_);
            request_.headers["authorization"] = `acs ${accessKeyId}:${OpenApiUtil.getROASignature(stringToSign, accessKeySecret)}`;
          }

        }

        _lastRequest = request_;
        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        if (response_.statusCode == 204) {
          return {
            headers: response_.headers,
          };
        }

        if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
          let _res = await $dara.Stream.readAsJSON(response_.body);
          let err = _res;
          let requestId = err["RequestId"] || err["requestId"];
          let code = err["Code"] || err["code"];
          if (`${code}`.includes("Throttling")) {
            throw new $_error.ThrottlingError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              retryAfter: OpenApiUtil.getThrottlingTimeLeft(response_.headers),
              data: err,
              requestId: `${requestId}`,
            });
          } else if ((response_.statusCode >= 400) && (response_.statusCode < 500)) {
            throw new $_error.ClientError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              accessDeniedDetail: this.getAccessDeniedDetail(err),
              requestId: `${requestId}`,
            });
          } else {
            throw new $_error.ServerError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              requestId: `${requestId}`,
            });
          }

        }

        if (bodyType == "binary") {
          let resp = {
            body: response_.body,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
          return resp;
        } else if (bodyType == "byte") {
          let byt = await $dara.Stream.readAsBytes(response_.body);
          return {
            body: byt,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "string") {
          let _str = await $dara.Stream.readAsString(response_.body);
          return {
            body: _str,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "json") {
          let obj = await $dara.Stream.readAsJSON(response_.body);
          let res = obj;
          return {
            body: res,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (bodyType == "array") {
          let arr = await $dara.Stream.readAsJSON(response_.body);
          return {
            body: arr,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else {
          return {
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        }

      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  /**
   * @remarks
   * Encapsulate the request and invoke the network
   * 
   * @param action - api name
   * @param version - product version
   * @param protocol - http or https
   * @param method - e.g. GET
   * @param authType - authorization type e.g. AK
   * @param bodyType - response body type e.g. String
   * @param request - object of OpenApiRequest
   * @param runtime - which controls some details of call api, such as retry times
   * @returns the response
   */
  async doRequest(params: $OpenApiUtil.Params, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    const protocol = `${this._protocol || params.protocol || ''}`.toLowerCase();
    let isWebSocket = protocol === 'ws' || protocol === 'wss';
    let wsHandler: $dara.WebSocketHandler | undefined;
    let websocketSubProtocol = '';

    if (isWebSocket) {
      websocketSubProtocol = params.websocketSubProtocol || '';
      if (!websocketSubProtocol) {
        throw new Error('websocketSubProtocol is required: please set it in params.websocketSubProtocol');
      }
      if (websocketSubProtocol !== websocketUtils.SubProtocolAWAP && websocketSubProtocol !== websocketUtils.SubProtocolGeneral) {
        throw new Error(`websocketSubProtocol must be 'awap' or 'general', got: ${websocketSubProtocol}`);
      }

      request.headers = request.headers || {};
      request.headers['sec-websocket-protocol'] = websocketSubProtocol;
      wsHandler = $dara.getWebSocketHandler(runtime);
      if (!wsHandler) {
        throw new Error('WebSocketHandler is required: please set it in runtime.WebSocketHandler');
      }
    }

    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
    };

    if (isWebSocket) {
      _runtime = {
        ..._runtime,
        webSocketPingInterval: $dara.getWebSocketPingInterval(runtime),
        webSocketPongTimeout: $dara.getWebSocketPongTimeout(runtime),
        webSocketEnableReconnect: $dara.getWebSocketEnableReconnect(runtime),
        webSocketReconnectInterval: $dara.getWebSocketReconnectInterval(runtime),
        webSocketMaxReconnectTimes: $dara.getWebSocketMaxReconnectTimes(runtime),
        webSocketWriteTimeout: $dara.getWebSocketWriteTimeout(runtime),
        webSocketHandshakeTimeout: $dara.getWebSocketHandshakeTimeout(runtime),
        webSocketHandler: wsHandler,
      };
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        request_.protocol = this._protocol || params.protocol;
        request_.method = params.method;
        request_.pathname = params.pathname;
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        request_.query = {
          ...globalQueries,
          ...extendsQueries,
          ...request.query,
        };
        // endpoint is setted in product client
        request_.headers = {
          host: this._endpoint,
          'x-acs-version': params.version,
          'x-acs-action': params.action,
          'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
          'x-acs-date': OpenApiUtil.getTimestamp(),
          'x-acs-signature-nonce': OpenApiUtil.getNonce(),
          accept: "application/json",
          ...globalHeaders,
          ...extendsHeaders,
          ...request.headers,
        };
        if (params.style == "RPC") {
          let headers = this.getRpcHeaders();
          if (!$dara.isNull(headers)) {
            request_.headers = {
              ...request_.headers,
              ...headers,
            };
          }

        }

        OpenApiUtil.applyRetryHeaders(request_.headers, _retryAttempts, _backoffTime);

        let signatureAlgorithm = this._signatureAlgorithm || "ACS3-HMAC-SHA256";
        let hashedRequestPayload = OpenApiUtil.hash(Buffer.from("", "utf-8"), signatureAlgorithm);
        if (!$dara.isNull(request.stream)) {
          let tmp = await $dara.Stream.readAsBytes(request.stream);
          hashedRequestPayload = OpenApiUtil.hash(tmp, signatureAlgorithm);
          request_.body = new $dara.BytesReadable(tmp);
          request_.headers["content-type"] = "application/octet-stream";
        } else {
          if (!$dara.isNull(request.body)) {
            if (params.reqBodyType == "byte") {
              let byteObj = Buffer.from(request.body);
              hashedRequestPayload = OpenApiUtil.hash(byteObj, signatureAlgorithm);
              request_.body = new $dara.BytesReadable(byteObj);
            } else if (params.reqBodyType == "json") {
              let jsonObj = typeof request.body === "string" ? request.body : JSON.stringify(request.body);
              hashedRequestPayload = OpenApiUtil.hash(Buffer.from(jsonObj, "utf8"), signatureAlgorithm);
              request_.body = new $dara.BytesReadable(jsonObj);
              request_.headers["content-type"] = "application/json; charset=utf-8";
            } else {
              let m = request.body;
              let formObj = OpenApiUtil.toForm(m);
              hashedRequestPayload = OpenApiUtil.hash(Buffer.from(formObj, "utf8"), signatureAlgorithm);
              request_.body = new $dara.BytesReadable(formObj);
              request_.headers["content-type"] = "application/x-www-form-urlencoded";
            }

          }

        }

        request_.headers["x-acs-content-sha256"] = hashedRequestPayload.toString("hex");
        if (params.authType != "Anonymous") {
          if ($dara.isNull(this._credential)) {
            throw new $_error.ClientError({
              code: `InvalidCredentials`,
              message: `Please set up the credentials correctly. If you are setting them through environment variables, please ensure that ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set correctly. See https://help.aliyun.com/zh/sdk/developer-reference/configure-the-alibaba-cloud-accesskey-environment-variable-on-linux-macos-and-windows-systems for more details.`,
            });
          }

          let credentialModel = await this._credential.getCredential();
          if (!$dara.isNull(credentialModel.providerName)) {
            request_.headers["x-acs-credentials-provider"] = credentialModel.providerName;
          }

          let authType = credentialModel.type;
          if (authType == "bearer") {
            let bearerToken = credentialModel.bearerToken;
            request_.headers["x-acs-bearer-token"] = bearerToken;
            if (params.style == "RPC") {
              request_.query["SignatureType"] = "BEARERTOKEN";
            } else {
              request_.headers["x-acs-signature-type"] = "BEARERTOKEN";
            }

          } else if (authType == "id_token") {
            let idToken = credentialModel.securityToken;
            request_.headers["x-acs-zero-trust-idtoken"] = idToken;
          } else {
            let accessKeyId = credentialModel.accessKeyId;
            let accessKeySecret = credentialModel.accessKeySecret;
            let securityToken = credentialModel.securityToken;
            if (!$dara.isNull(securityToken) && securityToken != "") {
              request_.headers["x-acs-accesskey-id"] = accessKeyId;
              request_.headers["x-acs-security-token"] = securityToken;
            }

            request_.headers["Authorization"] = OpenApiUtil.getAuthorization(request_, signatureAlgorithm, hashedRequestPayload.toString("hex"), accessKeyId, accessKeySecret);
          }

        } else {
          if (params.style == "RPC") {
            request_.query["Format"] = "json";
          }
        }

        _lastRequest = request_;
        if (isWebSocket) {
          const streamHandler = new websocketUtils.StreamHandler(
            wsHandler!,
            websocketSubProtocol,
          );
          const wsRuntime = $dara.cast({
            ..._runtime,
            webSocketHandler: streamHandler,
          }, new $dara.RuntimeOptions({}));
          const { client: wsClient, response: response_ } = await $dara.newWebSocketClientAndConnect(request_, wsRuntime);
          const wsClientObj = websocketUtils.newWebSocketClient(wsClient, response_);
          streamHandler.client = wsClientObj;
          return {
            webSocketClient: wsClientObj,
          };
        }

        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
          let err : {[key: string ]: any} = { };
          if (!$dara.isNull(response_.headers["content-type"]) && response_.headers["content-type"] == "text/xml;charset=utf-8") {
            let _str = await $dara.Stream.readAsString(response_.body);
            let respMap = $dara.XML.parseXml(_str, null);
            err = respMap["Error"];
          } else {
            let _res = await $dara.Stream.readAsJSON(response_.body);
            err = _res;
          }

          let requestId = err["RequestId"] || err["requestId"];
          let code = err["Code"] || err["code"];
          if (`${code}`.includes("Throttling")) {
            throw new $_error.ThrottlingError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              retryAfter: OpenApiUtil.getThrottlingTimeLeft(response_.headers),
              data: err,
              requestId: `${requestId}`,
            });
          } else if ((response_.statusCode >= 400) && (response_.statusCode < 500)) {
            throw new $_error.ClientError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              accessDeniedDetail: this.getAccessDeniedDetail(err),
              requestId: `${requestId}`,
            });
          } else {
            throw new $_error.ServerError({
              statusCode: response_.statusCode,
              code: `${code}`,
              message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${requestId}`,
              detail: `${err["Detail"] || err["detail"]}`,
              description: `${err["Description"] || err["description"]}`,
              data: err,
              requestId: `${requestId}`,
            });
          }

        }

        if (params.bodyType == "binary") {
          let resp = {
            body: response_.body,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
          return resp;
        } else if (params.bodyType == "byte") {
          let byt = await $dara.Stream.readAsBytes(response_.body);
          return {
            body: byt,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (params.bodyType == "string") {
          let respStr = await $dara.Stream.readAsString(response_.body);
          return {
            body: respStr,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (params.bodyType == "json") {
          let obj = await $dara.Stream.readAsJSON(response_.body);
          let res = obj;
          return {
            body: res,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else if (params.bodyType == "array") {
          let arr = await $dara.Stream.readAsJSON(response_.body);
          return {
            body: arr,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        } else {
          let anything = await $dara.Stream.readAsString(response_.body);
          return {
            body: anything,
            headers: response_.headers,
            statusCode: response_.statusCode,
          };
        }

      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  /**
   * @remarks
   * Encapsulate the request and invoke the network
   * 
   * @param action - api name
   * @param version - product version
   * @param protocol - http or https
   * @param method - e.g. GET
   * @param authType - authorization type e.g. AK
   * @param bodyType - response body type e.g. String
   * @param request - object of OpenApiRequest
   * @param runtime - which controls some details of call api, such as retry times
   * @returns the response
   */
  async execute(params: $OpenApiUtil.Params, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
      disableHttp2: this._disableHttp2 || false,
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        // spi = new Gateway();//Gateway implements SPI，这一步在产品 SDK 中实例化
        let headers = this.getRpcHeaders();
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        let requestContext = new $SPI.InterceptorContextRequest({
          headers: {
            ...globalHeaders,
            ...extendsHeaders,
            ...request.headers,
            ...headers,
          },
          query: {
            ...globalQueries,
            ...extendsQueries,
            ...request.query,
          },
          body: request.body,
          stream: request.stream,
          hostMap: request.hostMap,
          pathname: params.pathname,
          productId: this._productId,
          action: params.action,
          version: params.version,
          protocol: this._protocol || params.protocol,
          method: this._method || params.method,
          authType: params.authType,
          bodyType: params.bodyType,
          reqBodyType: params.reqBodyType,
          style: params.style,
          credential: this._credential,
          signatureVersion: this._signatureVersion,
          signatureAlgorithm: this._signatureAlgorithm,
          userAgent: OpenApiUtil.getUserAgent(this._userAgent),
        });
        let configurationContext = new $SPI.InterceptorContextConfiguration({
          regionId: this._regionId,
          endpoint: request.endpointOverride || this._endpoint,
          endpointRule: this._endpointRule,
          endpointMap: this._endpointMap,
          endpointType: this._endpointType,
          network: this._network,
          suffix: this._suffix,
        });
        let interceptorContext = new $SPI.InterceptorContext({
          request: requestContext,
          configuration: configurationContext,
        });
        let attributeMap = new $SPI.AttributeMap({ });
        if (!$dara.isNull(this._attributeMap)) {
          attributeMap = this._attributeMap;
        }

        // 1. spi.modifyConfiguration(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
        await this._spi.modifyConfiguration(interceptorContext, attributeMap);
        // 2. spi.modifyRequest(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
        await this._spi.modifyRequest(interceptorContext, attributeMap);
        request_.protocol = interceptorContext.request.protocol;
        request_.method = interceptorContext.request.method;
        request_.pathname = interceptorContext.request.pathname;
        request_.query = interceptorContext.request.query;
        request_.body = interceptorContext.request.stream;
        request_.headers = interceptorContext.request.headers;
        _lastRequest = request_;
        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        let responseContext = new $SPI.InterceptorContextResponse({
          statusCode: response_.statusCode,
          headers: response_.headers,
          body: response_.body,
        });
        interceptorContext.response = responseContext;
        // 3. spi.modifyResponse(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
        await this._spi.modifyResponse(interceptorContext, attributeMap);
        let resp = {
          headers: interceptorContext.response.headers,
          statusCode: interceptorContext.response.statusCode,
          body: interceptorContext.response.deserializedBody,
        };
        return resp;
      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  async *callSSEApi(params: $OpenApiUtil.Params, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): AsyncGenerator<$_model.SSEResponse, any, unknown> {
    let _runtime: { [key: string]: any } = {
      key: runtime.key || this._key,
      cert: runtime.cert || this._cert,
      ca: runtime.ca || this._ca,
      readTimeout: runtime.readTimeout || this._readTimeout,
      connectTimeout: runtime.connectTimeout || this._connectTimeout,
      httpProxy: runtime.httpProxy || this._httpProxy,
      httpsProxy: runtime.httpsProxy || this._httpsProxy,
      noProxy: runtime.noProxy || this._noProxy,
      socks5Proxy: runtime.socks5Proxy || this._socks5Proxy,
      socks5NetWork: runtime.socks5NetWork || this._socks5NetWork,
      maxIdleConns: runtime.maxIdleConns || this._maxIdleConns,
      retryOptions: this._retryOptions,
      ignoreSSL: runtime.ignoreSSL,
      tlsMinVersion: this._tlsMinVersion,
    }

    let _retriesAttempted = 0;
    let _lastRequest = null, _lastResponse = null;
    let _context = new $dara.RetryPolicyContext({
      retriesAttempted: _retriesAttempted,
    });
    while ($dara.shouldRetry(_runtime['retryOptions'], _context)) {
      let _backoffTime = 0;
      if (_retriesAttempted > 0) {
        _backoffTime = $dara.getBackoffDelay(_runtime['retryOptions'], _context);
        if (_backoffTime > 0) {
          await $dara.sleep(_backoffTime);
        }
      }

      const _retryAttempts = _retriesAttempted;
      _retriesAttempted = _retriesAttempted + 1;
      try {
        let request_ = new $dara.Request();
        request_.protocol = this._protocol || params.protocol;
        request_.method = params.method;
        request_.pathname = params.pathname;
        let globalQueries : {[key: string ]: string} = { };
        let globalHeaders : {[key: string ]: string} = { };
        if (!$dara.isNull(this._globalParameters)) {
          let globalParams = this._globalParameters;
          if (!$dara.isNull(globalParams.queries)) {
            globalQueries = globalParams.queries;
          }

          if (!$dara.isNull(globalParams.headers)) {
            globalHeaders = globalParams.headers;
          }

        }

        let extendsHeaders : {[key: string ]: string} = { };
        let extendsQueries : {[key: string ]: string} = { };
        if (!$dara.isNull(runtime.extendsParameters)) {
          let extendsParameters = runtime.extendsParameters;
          if (!$dara.isNull(extendsParameters.headers)) {
            extendsHeaders = extendsParameters.headers;
          }

          if (!$dara.isNull(extendsParameters.queries)) {
            extendsQueries = extendsParameters.queries;
          }

        }

        request_.query = {
          ...globalQueries,
          ...extendsQueries,
          ...request.query,
        };
        // endpoint is setted in product client
        request_.headers = {
          host: this._endpoint,
          'x-acs-version': params.version,
          'x-acs-action': params.action,
          'user-agent': OpenApiUtil.getUserAgent(this._userAgent),
          'x-acs-date': OpenApiUtil.getTimestamp(),
          'x-acs-signature-nonce': OpenApiUtil.getNonce(),
          accept: "application/json",
          ...extendsHeaders,
          ...globalHeaders,
          ...request.headers,
        };
        if (params.style == "RPC") {
          let headers = this.getRpcHeaders();
          if (!$dara.isNull(headers)) {
            request_.headers = {
              ...request_.headers,
              ...headers,
            };
          }

        }

        OpenApiUtil.applyRetryHeaders(request_.headers, _retryAttempts, _backoffTime);

        let signatureAlgorithm = this._signatureAlgorithm || "ACS3-HMAC-SHA256";
        let hashedRequestPayload = OpenApiUtil.hash(Buffer.from("", "utf-8"), signatureAlgorithm);
        if (!$dara.isNull(request.stream)) {
          let tmp = await $dara.Stream.readAsBytes(request.stream);
          hashedRequestPayload = OpenApiUtil.hash(tmp, signatureAlgorithm);
          request_.body = new $dara.BytesReadable(tmp);
          request_.headers["content-type"] = "application/octet-stream";
        } else {
          if (!$dara.isNull(request.body)) {
            if (params.reqBodyType == "byte") {
              let byteObj = Buffer.from(request.body);
              hashedRequestPayload = OpenApiUtil.hash(byteObj, signatureAlgorithm);
              request_.body = new $dara.BytesReadable(byteObj);
            } else if (params.reqBodyType == "json") {
              let jsonObj = typeof request.body === "string" ? request.body : JSON.stringify(request.body);
              hashedRequestPayload = OpenApiUtil.hash(Buffer.from(jsonObj, "utf8"), signatureAlgorithm);
              request_.body = new $dara.BytesReadable(jsonObj);
              request_.headers["content-type"] = "application/json; charset=utf-8";
            } else {
              let m = request.body;
              let formObj = OpenApiUtil.toForm(m);
              hashedRequestPayload = OpenApiUtil.hash(Buffer.from(formObj, "utf8"), signatureAlgorithm);
              request_.body = new $dara.BytesReadable(formObj);
              request_.headers["content-type"] = "application/x-www-form-urlencoded";
            }

          }

        }

        request_.headers["x-acs-content-sha256"] = hashedRequestPayload.toString("hex");
        if (params.authType != "Anonymous") {
          let credentialModel = await this._credential.getCredential();
          if (!$dara.isNull(credentialModel.providerName)) {
            request_.headers["x-acs-credentials-provider"] = credentialModel.providerName;
          }

          let authType = credentialModel.type;
          if (authType == "bearer") {
            let bearerToken = credentialModel.bearerToken;
            request_.headers["x-acs-bearer-token"] = bearerToken;
          } else if (authType == "id_token") {
            let idToken = credentialModel.securityToken;
            request_.headers["x-acs-zero-trust-idtoken"] = idToken;
          } else {
            let accessKeyId = credentialModel.accessKeyId;
            let accessKeySecret = credentialModel.accessKeySecret;
            let securityToken = credentialModel.securityToken;
            if (!$dara.isNull(securityToken) && securityToken != "") {
              request_.headers["x-acs-accesskey-id"] = accessKeyId;
              request_.headers["x-acs-security-token"] = securityToken;
            }

            request_.headers["Authorization"] = OpenApiUtil.getAuthorization(request_, signatureAlgorithm, hashedRequestPayload.toString("hex"), accessKeyId, accessKeySecret);
          }

        }

        _lastRequest = request_;
        let response_ = await $dara.doAction(request_, _runtime);
        _lastResponse = response_;

        if ((response_.statusCode >= 400) && (response_.statusCode < 600)) {
          let err : {[key: string ]: any} = { };
          if (!$dara.isNull(response_.headers["content-type"]) && response_.headers["content-type"] == "text/xml;charset=utf-8") {
            let _str = await $dara.Stream.readAsString(response_.body);
            let respMap = $dara.XML.parseXml(_str, null);
            err = respMap["Error"];
          } else {
            let _res = await $dara.Stream.readAsJSON(response_.body);
            err = _res;
          }

          err["statusCode"] = response_.statusCode;
          throw $dara.newError({
            code: `${err["Code"] || err["code"]}`,
            message: `code: ${response_.statusCode}, ${err["Message"] || err["message"]} request id: ${err["RequestId"] || err["requestId"]}`,
            data: err,
            detail: `${err["Detail"] || err["detail"]}`,
            description: `${err["Description"] || err["description"]}`,
            accessDeniedDetail: err["AccessDeniedDetail"] || err["accessDeniedDetail"],
          });
        }

        let events = await $dara.Stream.readAsSSE(response_.body);

        for await (let event of events) {
          yield new $_model.SSEResponse({
            statusCode: response_.statusCode,
            headers: response_.headers,
            event: event,
          });
        }
        return null;
      } catch (ex) {
        _context = new $dara.RetryPolicyContext({
          retriesAttempted : _retriesAttempted,
          httpRequest : _lastRequest,
          httpResponse : _lastResponse,
          exception : ex,
        });
        continue;
      }
    }

    throw $dara.newUnretryableError(_context);
  }

  async callApi(params: $OpenApiUtil.Params, request: $OpenApiUtil.OpenApiRequest, runtime: $dara.RuntimeOptions): Promise<{[key: string]: any}> {
    if ($dara.isNull(params)) {
      throw new $_error.ClientError({
        code: "ParameterMissing",
        message: "'params' can not be unset",
      });
    }

    if ($dara.isNull(this._signatureVersion) || this._signatureVersion != "v4") {
      if ($dara.isNull(this._signatureAlgorithm) || this._signatureAlgorithm != "v2") {
        return await this.doRequest(params, request, runtime);
      } else if ((params.style == "ROA") && (params.reqBodyType == "json")) {
        return await this.doROARequest(params.action, params.version, params.protocol, params.method, params.authType, params.pathname, params.bodyType, request, runtime);
      } else if (params.style == "ROA") {
        return await this.doROARequestWithForm(params.action, params.version, params.protocol, params.method, params.authType, params.pathname, params.bodyType, request, runtime);
      } else {
        return await this.doRPCRequest(params.action, params.version, params.protocol, params.method, params.authType, params.bodyType, request, runtime);
      }

    } else {
      return await this.execute(params, request, runtime);
    }

  }

  /**
   * @remarks
   * Get accesskey id by using credential
   * @returns accesskey id
   */
  async getAccessKeyId(): Promise<string> {
    if ($dara.isNull(this._credential)) {
      return "";
    }

    let accessKeyId = await this._credential.getAccessKeyId();
    return accessKeyId;
  }

  /**
   * @remarks
   * Get accesskey secret by using credential
   * @returns accesskey secret
   */
  async getAccessKeySecret(): Promise<string> {
    if ($dara.isNull(this._credential)) {
      return "";
    }

    let secret = await this._credential.getAccessKeySecret();
    return secret;
  }

  /**
   * @remarks
   * Get security token by using credential
   * @returns security token
   */
  async getSecurityToken(): Promise<string> {
    if ($dara.isNull(this._credential)) {
      return "";
    }

    let token = await this._credential.getSecurityToken();
    return token;
  }

  /**
   * @remarks
   * Get bearer token by credential
   * @returns bearer token
   */
  async getBearerToken(): Promise<string> {
    if ($dara.isNull(this._credential)) {
      return "";
    }

    let token = this._credential.getBearerToken();
    return token;
  }

  /**
   * @remarks
   * Get credential type by credential
   * @returns credential type e.g. access_key
   */
  async getType(): Promise<string> {
    if ($dara.isNull(this._credential)) {
      return "";
    }

    let authType = this._credential.getType();
    return authType;
  }

  /**
   * @remarks
   * If the endpointRule and config.endpoint are empty, throw error
   * 
   * @param config - config contains the necessary information to create a client
   */
  checkConfig(config: $OpenApiUtil.Config): void {
    if ($dara.isNull(this._endpointRule) && $dara.isNull(config.endpoint)) {
      throw new $_error.ClientError({
        code: "ParameterMissing",
        message: "'config.endpoint' can not be empty",
      });
    }

  }

  /**
   * @remarks
   * set gateway client
   * 
   * @param spi - .
   */
  setGatewayClient(spi: SPI): void {
    this._spi = spi;
  }

  /**
   * @remarks
   * set RPC header for debug
   * 
   * @param headers - headers for debug, this header can be used only once.
   */
  setRpcHeaders(headers: {[key: string ]: string}): void {
    this._headers = headers;
  }

  /**
   * @remarks
   * get RPC header for debug
   */
  getRpcHeaders(): {[key: string ]: string} {
    let headers : {[key: string ]: string} = this._headers;
    this._headers = null;
    return headers;
  }

  getAccessDeniedDetail(err: {[key: string ]: any}): {[key: string ]: any} {
    let accessDeniedDetail : {[key: string ]: any} = null;
    if (!$dara.isNull(err["AccessDeniedDetail"])) {
      let detail1 = err["AccessDeniedDetail"];
      accessDeniedDetail = detail1;
    } else if (!$dara.isNull(err["accessDeniedDetail"])) {
      let detail2 = err["accessDeniedDetail"];
      accessDeniedDetail = detail2;
    }

    return accessDeniedDetail;
  }

}