cfeteam / qcloudapi-sdk Goto Github PK

const axios = require('axios')
const qs = require('querystring')
const dotQs = require('dot-qs')
const crypto = require('crypto')
const packageJSON = require('./package.json')
const baseHost = 'api.qcloud.com'

class QcloudApi {
  constructor(defaults) {
    this.defaults = Object.assign({
      path: '/v2/index.php',
      method: 'POST',
      protocol: 'https',
      baseHost: baseHost
    }, defaults)
  }

  generateUrl(opts) {
    opts = opts || {}
    const host = this._getHost(opts)
    const path = opts.path === undefined ? this.defaults.path : opts.path
    return (opts.protocol || this.defaults.protocol) + '://' + host + path
  }

  generateQueryString(data, opts) {
    opts = opts || this.defaults
    const defaults = this.defaults
    let param = Object.assign({
      Region: this.defaults.Region,
      SecretId: opts.SecretId || this.defaults.SecretId,
      Timestamp: Math.round(Date.now() / 1000),
      Nonce: Math.round(Math.random() * 65535),
      RequestClient: 'SDK_NODEJS_' + packageJSON.version 
    }, data)
    param = dotQs.flatten(param)
    let keys = Object.keys(param)
    let qstr = '', signStr
    const host = this._getHost(opts)
    const method = (opts.method || defaults.method).toUpperCase()
    const path = opts.path === undefined ? defaults.path : opts.path
    keys.sort()
    keys.forEach(function(key) {
      const val = param[key]
      if(method === 'POST' && val && val[0] === '@'){
        return
      }
      if(key === '') {
        return
      }
      if(val === undefined || val === null || (typeof val === 'number' && isNaN(val))) {
        val = ''
      }
      qstr += '&' + (key.indexOf('_') ? key.replace(/_/g, '.') : key )+ '=' + val
    })
    qstr = qstr.slice(1)
    signStr = this.sign(method + host + path + '?' + qstr, opts.SecretKey || defaults.SecretKey)
    param.Signature = signStr
    return qs.stringify(param)
  }

  /**
   * request({data: {x: 'x'}, opts: {y: 'y'}, extra: {z:'z'}})
   */
  request(options) {
    {data ={}, opts = this.defaults, extra} = options
    const url = this.generateUrl(opts)
    const method = (opts.method || this.defaults.method).toUpperCase()
    const dataStr = this.generateQueryString(data, opts)
    let option = {url, method}
    if(method === 'POST') {
        option.data = dataStr
    }else{
        option.url += '?' + dataStr
    }
    if(extra) Object.assign(option, extra)
    // use .catch or try catch to catch error in outside
    return axios(option)
  }

  /**
   * Buffer.from(string[, encoding]), encoding <string> The encoding of string. Default: 'utf8'.
   */
  sign(str, secretKey) {
    const hmac = crypto.createHmac('sha1', secretKey || '')
    return hmac.update(Buffer.from(str)).digest('base64')
  }

  _getHost(opts) {
    let host = opts.host
    if(!host) {
        host = (opts.serviceType || this.defaults.serviceType) + '.' + (opts.baseHost || this.defaults.baseHost)
    }
    return host
  }
}

module.exports = QcloudApi