app.js

/*该文件主要就是给机器人提供接口，通过接受参数将不同状态的处理分配到不同状态的handler函数进行处理和数据传送。*/
const mongoose = require('mongoose');
const express = require('express');
const config = require('config');
const bodyParser = require('body-parser');
const async = require('async');
const glob = require('glob');
const path = require('path');
const constant = require('./config/constant');
const UserStatus = require('./model/userStatus');
const User = require('./model/user');
const status = {};

//加载wechat-status文件夹下的所有文件，并将所有文件名作为用户或群的status记录
glob("./wechat-status/*.js", {}, (err, files) => {
  files.forEach((file) => {
    let pathName = path.basename(file, '.js');
    let Clazz = require(file);
    status[pathName] = new Clazz();
  });
});

//连接数据库mongoDB
mongoose.connect(config.get('mongoUri'), (err) => {
  if (err) {
    console.log('connect failed');
  } else {
    console.log('connect success');
  }
});

const app = express();
app.use(bodyParser.json());
app.post('/wechat', (req, res) => {
  const userId = req.body.sender_puid;
  const message = req.body.message;
  const member = req.body.member_puid;
  async.waterfall([
    (done) => {
      UserStatus.findOne({userId}, done);
    },
    (data, done) => {
      if (!member) {
        if (!data) {
          status['info'].handler(userId, message, done);
        } else {
          status[data.status].handler(userId, message, done);
        }
      } else {
        if (!data) {
          status['group'].handler(userId, message, member, done);
        } else {
          status[data.status].handler(userId, message, member, done);
        }
      }

    }
  ], (err, data) => {
    if (err) {
      return res.sendStatus(constant.httpCode.BAD_REQUEST);
    }
    return res.status(constant.httpCode.OK).send(data);
  });
});

app.listen(config.get('httpPort'), ()=> {
  console.log('server started at http://localhost:' + config.get('httpPort'));   // eslint-disable-line no-console
});