Method request

src/common/util/EncryptRequest.js:44–90

* @function EncryptRequest.prototype.request * @description 加密请求地址。 * @param {Object} config - 加密请求参数。 * @param {string} config.method - 请求方法。 * @param {string} config.url - 请求地址。 * @param {string} config.params - 请求参数。 * @param {Object} config.options - 请求的配置属性。 * @returns {Pro

(options)

   * @returns {Promise} Promise 对象。
   */
  async request(options) {
    if (!this.serverUrl) {
      throw 'serverUrl can not be empty.';
    }
    const config = Object.assign({ baseURL: '' }, options);
    const tunnelUrl = await this._createTunnel();
    if (!tunnelUrl) {
      return;
    }
    for (const pattern of this.blockedUrlRegex[config.method.toUpperCase()]) {
      const regex = new RegExp(pattern);
      if (regex.test(config.baseURL + config.url)) {
        const data = {
          url: config.baseURL + (config.url.startsWith('/') ? config.url.substring(1, config.url.length) : config.url),
          method: config.method,
          timeout: config.timeout,
          headers: config.headers,
          body: config.data
        };
        // 替换请求
        config.method = 'post';
        config.data = AESGCMEncrypt(this.encryptAESKey, this.encryptAESIV, JSON.stringify(data));
        if (!config.data) {
          throw 'encrypt failed';
        }
        config.url = this.tunnelUrl;
        break;
      }
    }
    const response = await FetchRequest.commit(config.method, config.url, config.data, config.options);
    if (config.url === this.tunnelUrl) {
      const result = await response.text();
      const decryptResult = AESGCMDecrypt(this.encryptAESKey, this.encryptAESIV, result);
      if (!decryptResult) {
        console.debug('解密请求响应失败');
        return;
      }
      const resultData = JSON.parse(decryptResult);
      const resData = Object.create({
        json: function () {
          return Promise.resolve(resultData.data);
        }
      });
      return Object.assign(resData, resultData);
    }
    return response;
  }

  /**
   * @private