/**
 * Copyright(c) Alibaba Group Holding Limited.
 *
 * @file:     sms-sdk
 * @authors:  qiankun <chuck.ql@alibaba-inc.com> (https://work.alibaba-inc.com/work/u/85053)
 * @date      18/1/31
 */

'use strict';
const DysmsapiClient = require('@alicloud/dysmsapi-2017-05-25')
const DybaseapiClient = require('@alicloud/dybaseapi')
const MNSClient = require('@alicloud/mns')
// 短信回执报告：SmsReport，短信上行：SmsUp
const msgTypeList = ["SmsReport", "SmsUp"]
const DYSMSAPI_ENDPOINT = 'http://dysmsapi.aliyuncs.com'
const DYBASEAPI_ENDPOINT = 'http://dybaseapi.aliyuncs.com'
const DEFAULT_REGION = 'cn-hangzhou'

function hasOwnProperty(obj, key) {
  return Object.prototype.hasOwnProperty.call(obj, key)
}

class SMSClient {
  constructor(options) {
    let { accessKeyId, secretAccessKey, smsApiEndpoint, baseApiEndpoint, regionId, mnsVpc } = options
    if (!accessKeyId) {
      throw new TypeError('parameter "accessKeyId" is required')
    }
    if (!secretAccessKey) {
      throw new TypeError('parameter "secretAccessKey" is required')
    }
    this.dysmsapiClient = new DysmsapiClient({
      accessKeyId,
      secretAccessKey,
      regionId: regionId || DEFAULT_REGION,
      endpoint: smsApiEndpoint || DYSMSAPI_ENDPOINT
    })
    this.dybaseClient = new DybaseapiClient({
      accessKeyId,
      secretAccessKey,
      regionId: regionId || DEFAULT_REGION,
      endpoint: baseApiEndpoint || DYBASEAPI_ENDPOINT
    })
    this.mnsVpc = mnsVpc || {
      secure: false, // use https or http
      internal: false, // use internal endpoint
      vpc: false
    }
    this.expire = []
    this.mnsClient = []
  }

  //群发短信
  sendBatchSMS(params, options = {}) {
    return this.dysmsapiClient.sendBatchSms(params, { formatParams: false, ...options })
  }

  //发送短信
  sendSMS(params, options = {}) {
    return this.dysmsapiClient.sendSms(params, options)
  }

  //查询详情
  queryDetail(params, options = {}) {
    return this.dysmsapiClient.querySendDetails(params, options)
  }

  //失效时间与当前系统时间比较，提前2分钟刷新token
  _refresh(type) {
    return this.expire[type] - new Date().getTime() > 2 * 60 * 1000
  }

  //获取token
  _getToken(type) {
    let msgType = msgTypeList[type]
    return this.dybaseClient.queryTokenForMnsQueue({ MessageType: msgType })
  }

  //根据类型获取mnsclient实例
  async _getMNSClient(type) {
    if (this.mnsClient && (this.mnsClient[type] instanceof MNSClient) && this._refresh(type)) {
      return this.mnsClient[type]
    }
    let {
      MessageTokenDTO: {
        SecurityToken,
        AccessKeyId,
        AccessKeySecret
      }
    } = await this._getToken(type)
    if (!(AccessKeyId && AccessKeySecret && SecurityToken)) {
      throw new TypeError('get token fail')
    }
    let mnsClient = new MNSClient('1943695596114318', {
      securityToken: SecurityToken,
      region: DEFAULT_REGION,
      accessKeyId: AccessKeyId,
      accessKeySecret: AccessKeySecret,
      // optional & default
      secure: false, // use https or http
      internal: false, // use internal endpoint
      vpc: false, // use vpc endpoint
      ...this.mnsVpc
    })
    this.mnsClient[type] = mnsClient
    this.expire[type] = (new Date().getTime() + 10 * 60 * 1000)
    return mnsClient
  }

  //typeIndex :0 为回执,1为上行
  async receiveMsg(typeIndex = 0, preQueueName, waitSeconds = 10, isDel = false) {
    const queueName = preQueueName + msgTypeList[typeIndex]
    let mnsClient = await this._getMNSClient(typeIndex)
    const res = await mnsClient.receiveMessage(queueName, waitSeconds)
    const { code, body: { ReceiptHandle } } = res;
    if (isDel && code === 200 && ReceiptHandle) {
      await mnsClient.deleteMessage(queueName, ReceiptHandle)
    }
    return res;
  }
}

module.exports = SMSClient