controllers/reply.js
var validator = require('validator');
var _ = require('lodash');
var at = require('../common/at');
var message = require('../common/message');
var EventProxy = require('eventproxy');
var User = require('../proxy').User;
var Topic = require('../proxy').Topic;
var Reply = require('../proxy').Reply;
var config = require('../config');
/**
* 添加回复
*/
exports.add = function (req, res, next) {
var content = req.body.r_content;
var topic = req.params.topic;
var reply_id = req.body.reply_id;
var str = validator.trim(String(content));
if (str === '') {
return res.renderError('回复内容不能为空!', 422);
}
var ep = EventProxy.create();
ep.fail(next);
Topic.getTopic(topic, ep.doneLater(function (topic) {
if (!topic) {
ep.unbind();
// just 404 page
return next();
}
if (topic.lock) {
return res.status(403).send('此主题已锁定。');
}
ep.emit('topic', topic);
}));
ep.all('topic', function (topic) {
User.getUserById(topic.author, ep.done('topic_author'));
});
ep.all('topic', 'topic_author', function (topic, topicAuthor) {
Reply.newAndSave(content, topic, req.session.user._id, reply_id, ep.done(function (reply) {
Topic.updateLastReply(topic, reply._id, ep.done(function () {
ep.emit('reply_saved', reply);
//发送at消息,并防止重复 at 作者
var newContent = content.replace('@' + topicAuthor.loginname + ' ', '');
at.sendMessageToMentionUsers(newContent, topic, req.session.user._id, reply._id);
}));
}));
User.getUserById(req.session.user._id, ep.done(function (user) {
user.score += 5;
user.reply_count += 1;
user.save();
req.session.user = user;
ep.emit('score_saved');
}));
});
ep.all('reply_saved', 'topic', function (reply, topic) {
if (topic.author.toString() !== req.session.user._id.toString()) {
message.sendReplyMessage(topic.author, req.session.user._id, topic._id, reply._id);
}
ep.emit('message_saved');
});
ep.all('reply_saved', 'message_saved', 'score_saved', function (reply) {
res.redirect('/topic/' + topic + '#' + reply._id);
});
};
/**
* 删除回复信息
*/
exports.delete = function (req, res, next) {
var reply_id = req.body.reply_id;
Reply.getReplyById(reply_id, function (err, reply) {
if (err) {
return next(err);
}
if (!reply) {
res.status(422);
res.json({status: 'no reply ' + reply_id + ' exists'});
return;
}
if (reply.author.id === req.session.user._id.toString() || req.session.user.is_admin) {
reply.deleted = true;
reply.save();
res.json({status: 'success'});
reply.author.score -= 5;
reply.author.reply_count -= 1;
reply.author.save();
} else {
res.json({status: 'failed'});
return;
}
Topic.reduceCount(reply.topic, _.noop);
});
};
/*
打开回复编辑器
*/
exports.showEdit = function (req, res, next) {
var reply_id = req.params.reply_id;
Reply.getReplyById(reply_id, function (err, reply) {
if (!reply) {
return res.render404('此回复不存在或已被删除。');
}
if (req.session.user._id.equals(reply.author.id) || req.session.user.is_admin) {
res.render('reply/edit', {
reply_id: reply._id,
content: reply.content
});
} else {
return res.renderError('对不起,你不能编辑此回复。', 403);
}
});
};
/*
提交编辑回复
*/
exports.update = function (req, res, next) {
var reply_id = req.params.reply_id;
var content = req.body.t_content;
Reply.getReplyById(reply_id, function (err, reply) {
if (!reply) {
return res.render404('此回复不存在或已被删除。');
}
if (String(reply.author.id) === req.session.user._id.toString() || req.session.user.is_admin) {
if (content.trim().length > 0) {
reply.content = content;
reply.update_at = new Date();
reply.save(function (err) {
if (err) {
return next(err);
}
res.redirect('/topic/' + reply.topic + '#' + reply._id);
});
} else {
return res.renderError('回复的字数太少。', 400);
}
} else {
return res.renderError('对不起,你不能编辑此回复。', 403);
}
});
};
exports.up = function (req, res, next) {
var replyId = req.params.reply_id;
var userId = req.session.user._id;
Reply.getReplyById(replyId, function (err, reply) {
if (err) {
return next(err);
}
if (reply.author.equals(userId) && !config.debug) {
// 不能帮自己点赞
res.send({
success: false,
message: '呵呵,不能帮自己点赞。',
});
} else {
var action;
reply.ups = reply.ups || [];
var upIndex = reply.ups.indexOf(userId);
if (upIndex === -1) {
reply.ups.push(userId);
action = 'up';
} else {
reply.ups.splice(upIndex, 1);
action = 'down';
}
reply.save(function () {
res.send({
success: true,
action: action
});
});
}
});
};