'use strict';
// 引入模塊
var Promise = require('bluebird');
var request = Promise.promisify(require('request'));

//增加url配置項(xiàng)
var prefix = 'https://api.weixin.qq.com/cgi-bin/';
var api = {
  accessToken: prefix + 'token?grant_type=client_credential'
};

//利用構(gòu)造函數(shù)生成實(shí)例 完成票據(jù)存儲(chǔ)邏輯
function weChat(opts) {
  var that = this;
  this.appID = opts.appID;
  this.appSecret = opts.appSecret;
  this.getAccessToken = opts.getAccessToken;
  this.saveAccessToken = opts.saveAccessToken;
  //獲取票據(jù)的方法
  this.getAccessToken()
    .then(function(data) {
      //從靜態(tài)文件獲取票據(jù)，JSON化數(shù)據(jù)，如果有異常，則嘗試更新票據(jù)
      try {
        data = JSON.parse(data);
      } catch (e) {
        return that.updateAccessToken();
      }
      //判斷票據(jù)是否在有效期內(nèi)，如果合法，向下傳遞票據(jù)，如果不合法，更新票據(jù)
      if (that.isValidAccessToken(data)) {
        Promise.resolve(data);
      } else {
        return that.updateAccessToken();
      }
    })
    //將拿到的票據(jù)信息和有效期信息存儲(chǔ)起來(lái)
    .then(function(data) {
      //console.log(data);
      that.access_token = data.access_token;
      that.expires_in = data.expires_in;

      that.saveAccessToken(data);
    })
};

//在weChat的原型鏈上增加驗(yàn)證有效期的方法
weChat.prototype.isValidAccessToken = function(data) {
  //進(jìn)行判斷，如果票據(jù)不合法，返回false
  if (!data || !data.access_token || !data.expires_in) {
    return false;
  }
  //拿到票據(jù)和過(guò)期時(shí)間的數(shù)據(jù)
  var access_token = data.access_token;
  var expires_in = data.expires_in;
  //獲取當(dāng)前時(shí)間
  var now = (new Date().getTime());
  //如果當(dāng)前時(shí)間小于票據(jù)過(guò)期時(shí)間，返回true，否則返回false
  if (now < expires_in) {
    return true;
  } else {
    return false;
  };
};

//在weChat的原型鏈上增加更新票據(jù)的方法
weChat.prototype.updateAccessToken = function() {
  var appID = this.appID;
  var appSecret = this.appSecret;
  var url = api.accessToken + '&appid=' + appID + '&secret=' + appSecret;

  return new Promise(function(resolve, reject) {
    //使用request發(fā)起請(qǐng)求
    request({
      url: url,
      json: true
    }).then(function(response) {
      var data = response.body;
      var now = (new Date().getTime());
      var expires_in = now + (data.expires_in - 20) * 1000;
      //把新票據(jù)的有效時(shí)間賦值給data
      data.expires_in = expires_in;
      resolve(data);
    })
  })
};

//向外暴露weChat
module.exports = weChat;

'use strict';
// 引入模塊
var sha1 = require('sha1');
var getRawBody = require('raw-body');
var weChat = require('./wechat');
var tools = require('./tools');

// 建立中間件函數(shù)并暴露出去
module.exports = function(opts) {
  //實(shí)例化weChat()函數(shù)
  //var wechat = new weChat(opts);
  return function*(next) {
    //console.log(this.query);
    var that = this;
    var token = opts.token;
    var signature = this.query.signature;
    var nonce = this.query.nonce;
    var timestamp = this.query.timestamp;
    var echostr = this.query.echostr;
    // 進(jìn)行字典排序
    var str = [token, timestamp, nonce].sort().join('');
    // 進(jìn)行加密
    var sha = sha1(str);
    //使用this.method對(duì)請(qǐng)求方法進(jìn)行判斷
    if (this.method === 'GET') {
      // 如果是get請(qǐng)求 判斷加密后的值是否等于簽名值
      if (sha === signature) {
        this.body = echostr + '';
      } else {
        this.body = 'wrong';
      };
    } else if (this.method === 'POST') {
      //如果是post請(qǐng)求 也是先判斷簽名是否合法 如果不合法 直接返回wrong
      if (sha !== signature) {
        this.body = 'wrong';
        return false;
      };
      //通過(guò)raw-body模塊 可以把把this上的request對(duì)象 也就是http模塊中的request對(duì)象 去拼裝它的數(shù)據(jù) 最終拿到一個(gè)buffer的xml數(shù)據(jù)
      //通過(guò)yield關(guān)鍵字 獲取到post過(guò)來(lái)的原始的XML數(shù)據(jù)
      var data = yield getRawBody(this.req, {
        length: this.length,
        limit: '1mb',
        encoding: this.charset
      });
      //console.log(data.toString());打印XML數(shù)據(jù)（當(dāng)微信公眾號(hào)有操作的時(shí)候 終端可以看到返回的XML數(shù)據(jù)）
      //tools為處理XML數(shù)據(jù)的工具包 使用tools工具包的parseXMLAsync方法 把XML數(shù)據(jù)轉(zhuǎn)化成數(shù)組對(duì)象
      var content = yield tools.parseXMLAsync(data);
      //console.log(content);打印轉(zhuǎn)化后的數(shù)組對(duì)象
      //格式化content數(shù)據(jù)為json對(duì)象
      var message = tools.formatMessage(content.xml);
      console.log(message);
      //打印message
      //判斷message的MsgType 如果是event 則是一個(gè)事件
      if (message.MsgType === 'event') {
        //如果是訂閱事件
        if (message.Event === 'subscribe') {
          //獲取當(dāng)前時(shí)間戳
          var now = new Date().getTime();
          //設(shè)置回復(fù)狀態(tài)是200
          that.status = 200;
          //設(shè)置回復(fù)的類型是xml格式
          that.type = 'application/xml';
          //設(shè)置回復(fù)的主體
          that.body = '<xml>' +
            '<ToUserName><![CDATA[' + message.FromUserName + ']]></ToUserName>' +
            '<FromUserName><![CDATA[' + message.ToUserName + ']]></FromUserName>' +
            '<CreateTime>' + now + '</CreateTime>' +
            '<MsgType><![CDATA[text]]></MsgType>' +
            '<Content><![CDATA[你好，同學(xué)！]]></Content>' +
            '</xml>';
          return;
        }
      }
    }

  }
};

'use strict';
//引入模塊
var xml2js = require('xml2js');
var Promise = require('bluebird');
//導(dǎo)出解析XML的方法
exports.parseXMLAsync = function(xml) {
  return new Promise(function(resolve, reject) {
    xml2js.parseString(xml, { trim: true }, function(err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      };
    });
  });
};
//因?yàn)関alue值可能是嵌套多層的 所以先對(duì)value值進(jìn)行遍歷
function formatMessage(result) {
  //聲明空對(duì)象message
  var message = {};
  //對(duì)result類型進(jìn)行判斷
  if (typeof result === 'object') {
    //如果是object類型 通過(guò)Object.keys()方法拿到result所有的key 并存入keys變量中
    var keys = Object.keys(result);
    //對(duì)keys進(jìn)行循環(huán)遍歷
    for (var i = 0; i < keys.length; i++) {
      //拿到每個(gè)key對(duì)應(yīng)的value值
      var item = result[keys[i]];
      //拿到key
      var key = keys[i];
      //判斷item是否為數(shù)組或者長(zhǎng)度是否為0
      if (!(item instanceof Array) || item.length === 0) {
        //如果item不是數(shù)組或者長(zhǎng)度為0 則跳過(guò)繼續(xù)向下解析
        continue;
      }
      //如果長(zhǎng)度為1
      if (item.length === 1) {
        //拿到value值存入val變量
        var val = item[0];
        //判斷val是否為對(duì)象
        if (typeof val === 'object') {
          //如果val為對(duì)象 則進(jìn)一步進(jìn)行遍歷
          message[key] = formatMessage(val);
        } else {
          //如果不是對(duì)象 就把值賦給當(dāng)前的key放入message里 并去除收尾空格
          message[key] = (val || '').trim();
        }
      }
      //如果item的長(zhǎng)度既不是0也不是1 則說(shuō)明它是一個(gè)數(shù)組
      else {
        //把message的key設(shè)置為空數(shù)組
        message[key] = [];
        //對(duì)數(shù)組進(jìn)行遍歷
        for (var j = 0, k = item.length; j < k; j++) {
          message[key].push(formatMessage(item[j]));
        }
      }
    }
  }
  return message;
}

exports.formatMessage = function(xml) {
  return new Promise(function(resolve, reject) {
    xml2js.parseString(xml, { trim: true }, function(err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      };
    });
  });
};

exports.formatMessage = formatMessage;