Function doRequest

test/util/HttpUtil.js:91–151

* @param params {String} json类型或file路径 * {Object} key-value形式

(method = 'GET', url, params, headers = {}, isProxy)

 *                {Object}  key-value形式
 */
function doRequest(method = 'GET', url, params, headers = {}, isProxy) {
  headers = Object.assign({}, headers);

  let reqStream = new commonStream();
  const requestData = {
    headers,
    followRedirect: false,
    rejectUnauthorized: false
  };

  if (isProxy) {
    requestData.proxy = PROXY_HOST;
    requestData.headers['via-proxy'] = 'true';
  }

  const streamReq = (resolve, reject) => {
    requestData.headers['content-type'] = 'text/plain'; //otherwise, koa-body could not recognize
    if (typeof params === 'string') {
      fs.existsSync(params) ?
        reqStream = fs.createReadStream(params) :
        reqStream.push(params);
    } else if (typeof params === 'object') {
      reqStream.push(JSON.stringify(params));
    }
    reqStream.push(null);
    reqStream.pipe(request[method.toLowerCase()](
      url,
      requestData,
      (error, response, body) => {
        if (error) {
          reject(error);
        } else {
          resolve(response);
        }
      }
    ))
  }
  const commonReq = (resolve, reject) => {
    requestData.url = url;
    requestData.method = method;
    requestData.qs = params;
    request(
      requestData,
      (error, response, body) => {
        if (error) {
          reject(error);
        } else {
          resolve(response);
        }
      }
    );
  }
  const requestTask = new Promise((resolve, reject) => {
    if (method === 'POST' || method === 'PUT') {
      streamReq(resolve, reject);
    } else {
      commonReq(resolve, reject);
    }