sohub/api/services/MessageService.js

var User = require('../models/User.js');
var constants = require('../models/constants/common.js');

var MessageService = {
    processTextMessage: function (message, callback) {
        var originalContent = message.Content;

        if (Message.isValidNoticeMessage(message)) {
            message.MsgType = 'notice';
            originalContent = originalContent.replace('+', '');
        }

        if (Message.isValidNormalMessage(message)) {
            originalContent = originalContent.replace('-', '');
        }
        User.getNameByNameId(message.FromUserName, function (err, name) {
            if (err) {
                callback(null, constants.reply.systemErr);
                return;
            }
            Message.create({
                content: originalContent,
                createTime: new Date().getTime(),
                fromUser: name,
                toUser: message.ToUserName,
                messageType: message.MsgType,
                messageId: message.MsgId
            }).done(function (err, message) {
                    if (err) {
                        callback(err);
                    }
                    callback(null, '你的消息：' + message.content + '已收到');
                })
        });

    }

}

module.exports = MessageService;