mirror of
https://github.com/taobataoma/meanTorrent.git
synced 2026-01-13 19:02:23 +01:00
702 lines
16 KiB
JavaScript
702 lines
16 KiB
JavaScript
'use strict';
|
|
|
|
/**
|
|
* Module dependencies
|
|
*/
|
|
var path = require('path'),
|
|
config = require(path.resolve('./config/config')),
|
|
mongoose = require('mongoose'),
|
|
errorHandler = require(path.resolve('./modules/core/server/controllers/errors.server.controller')),
|
|
multer = require('multer'),
|
|
fs = require('fs'),
|
|
moment = require('moment'),
|
|
User = mongoose.model('User'),
|
|
Forum = mongoose.model('Forum'),
|
|
Topic = mongoose.model('Topic'),
|
|
Reply = mongoose.model('Reply'),
|
|
Thumb = mongoose.model('Thumb'),
|
|
async = require('async'),
|
|
traceLogCreate = require(path.resolve('./config/lib/tracelog')).create;
|
|
|
|
var traceConfig = config.meanTorrentConfig.trace;
|
|
var forumsConfig = config.meanTorrentConfig.forumsConfig;
|
|
|
|
/**
|
|
* list forums
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.list = function (req, res) {
|
|
var findForumsList = function (callback) {
|
|
Forum.find()
|
|
.sort('category order -createdat')
|
|
.populate({
|
|
path: 'lastTopic',
|
|
populate: {
|
|
path: 'user lastUser',
|
|
select: 'username displayName profileImageURL uploaded downloaded'
|
|
}
|
|
})
|
|
.populate('moderators', 'username displayName profileImageURL uploaded downloaded')
|
|
.exec(function (err, forums) {
|
|
if (err) {
|
|
callback(err, null);
|
|
} else {
|
|
callback(null, forums);
|
|
}
|
|
});
|
|
};
|
|
|
|
var forumsTopicsCount = function (callback) {
|
|
Topic.aggregate({
|
|
$project: {
|
|
'forum': '$forum',
|
|
'day': {
|
|
'$dayOfMonth': '$createdAt'
|
|
}
|
|
}
|
|
}, {
|
|
$match: {
|
|
day: moment.utc().date()
|
|
}
|
|
}, {
|
|
$group: {
|
|
_id: '$forum',
|
|
count: {$sum: 1}
|
|
}
|
|
}).exec(function (err, counts) {
|
|
if (err) {
|
|
callback(err, null);
|
|
} else {
|
|
callback(null, counts);
|
|
}
|
|
});
|
|
};
|
|
|
|
var forumsRepliesCount = function (callback) {
|
|
Topic.aggregate({
|
|
$unwind: '$_replies'
|
|
}, {
|
|
$project: {
|
|
'forum': '$forum',
|
|
//'title': '$title',
|
|
//'createdAt': '$_replies.createdAt',
|
|
'day': {
|
|
'$dayOfMonth': '$_replies.createdAt'
|
|
}
|
|
}
|
|
}, {
|
|
$match: {
|
|
day: moment.utc().date()
|
|
}
|
|
}, {
|
|
$group: {
|
|
_id: '$forum',
|
|
count: {$sum: 1}
|
|
}
|
|
}).exec(function (err, counts) {
|
|
if (err) {
|
|
callback(err, null);
|
|
} else {
|
|
callback(null, counts);
|
|
}
|
|
});
|
|
};
|
|
|
|
async.parallel([findForumsList, forumsTopicsCount, forumsRepliesCount], function (err, results) {
|
|
if (err) {
|
|
return res.status(422).send(err);
|
|
} else {
|
|
res.json({
|
|
forumsList: results[0],
|
|
forumsTopicsCount: results[1],
|
|
forumsRepliesCount: results[2]
|
|
});
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* read forum
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.read = function (req, res) {
|
|
res.json(req.forum);
|
|
};
|
|
|
|
/**
|
|
* listTopics
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.listTopics = function (req, res) {
|
|
Topic.find({
|
|
forum: req.params.forumId
|
|
})
|
|
.sort('-isTop -lastReplyAt -createdAt')
|
|
.populate('user', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('lastUser', 'username displayName profileImageURL uploaded downloaded')
|
|
.exec(function (err, topics) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
}
|
|
res.json(topics);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* postNewTopic
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.postNewTopic = function (req, res) {
|
|
var forum = req.forum;
|
|
var topic = new Topic(req.body);
|
|
topic.forum = forum;
|
|
topic.user = req.user;
|
|
|
|
//move temp torrent file to dest directory
|
|
req.body._uImage.forEach(function (f) {
|
|
var oldPath = config.uploads.attach.file.temp + f.filename;
|
|
var newPath = config.uploads.attach.file.dest + f.filename;
|
|
move(oldPath, newPath, function (err) {
|
|
if (err) {
|
|
console.log(err);
|
|
}
|
|
});
|
|
});
|
|
req.body._attach.forEach(function (f) {
|
|
var oldPath = config.uploads.attach.file.temp + f.filename;
|
|
var newPath = config.uploads.attach.file.dest + f.filename;
|
|
move(oldPath, newPath, function (err) {
|
|
if (err) {
|
|
console.log(err);
|
|
}
|
|
});
|
|
});
|
|
|
|
//replace content path
|
|
var regex = new RegExp('/modules/forums/client/attach/temp/', 'g');
|
|
topic.content = topic.content.replace(regex, '/modules/forums/client/attach/');
|
|
|
|
//save topic
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
|
|
forum.update({
|
|
$inc: {topicCount: 1},
|
|
lastTopic: topic
|
|
}).exec();
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* move file
|
|
* @param oldPath
|
|
* @param newPath
|
|
* @param callback
|
|
*/
|
|
function move(oldPath, newPath, callback) {
|
|
fs.rename(oldPath, newPath, function (err) {
|
|
if (err) {
|
|
if (err.code === 'EXDEV') {
|
|
copy();
|
|
} else {
|
|
callback(err);
|
|
}
|
|
return;
|
|
}
|
|
callback();
|
|
});
|
|
|
|
function copy() {
|
|
var readStream = fs.createReadStream(oldPath);
|
|
var writeStream = fs.createWriteStream(newPath);
|
|
|
|
readStream.on('error', callback);
|
|
writeStream.on('error', callback);
|
|
|
|
readStream.on('close', function () {
|
|
fs.unlink(oldPath, callback);
|
|
});
|
|
readStream.pipe(writeStream);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* read readTopic
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.readTopic = function (req, res) {
|
|
var topic = req.topic;
|
|
|
|
topic.update({
|
|
$inc: {viewCount: 1}
|
|
}).exec();
|
|
|
|
res.json(topic);
|
|
};
|
|
|
|
/**
|
|
* updateTopic
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.updateTopic = function (req, res) {
|
|
var forum = req.forum;
|
|
var topic = req.topic;
|
|
|
|
topic.content = req.body.content;
|
|
topic.updatedAt = Date.now();
|
|
topic.updatedBy = req.user;
|
|
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* toggleTopicReadonly
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.toggleTopicReadonly = function (req, res) {
|
|
var topic = req.topic;
|
|
|
|
topic.readOnly = !topic.readOnly;
|
|
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* thumbsUp
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.thumbsUp = function (req, res) {
|
|
var user = req.user;
|
|
var exist = false;
|
|
var topic = req.topic;
|
|
var thumb = new Thumb();
|
|
thumb.user = req.user;
|
|
thumb.score = forumsConfig.thumbs_up_score;
|
|
|
|
if (req.query.replyId) {
|
|
topic._replies.forEach(function (r) {
|
|
if (r._id.equals(req.query.replyId)) {
|
|
//check if already exist
|
|
exist = false;
|
|
r._scoreList.forEach(function (sr) {
|
|
if (sr.user._id.equals(req.user._id)) {
|
|
exist = true;
|
|
}
|
|
});
|
|
if (exist) {
|
|
return res.status(422).send({
|
|
message: 'ALREADY_THUMBS_UP'
|
|
});
|
|
} else {
|
|
if (r.user.score >= forumsConfig.thumbs_up_score) {
|
|
r._scoreList.push(thumb);
|
|
r.user.update({
|
|
$inc: {score: forumsConfig.thumbs_up_score}
|
|
}).exec();
|
|
} else {
|
|
return res.status(422).send({
|
|
message: 'SCORE_NOT_ENOUGH'
|
|
});
|
|
}
|
|
}
|
|
}
|
|
});
|
|
} else {
|
|
//check if already exist
|
|
exist = false;
|
|
topic._scoreList.forEach(function (sr) {
|
|
if (sr.user._id.equals(req.user._id)) {
|
|
exist = true;
|
|
}
|
|
});
|
|
if (exist) {
|
|
return res.status(422).send({
|
|
message: 'ALREADY_THUMBS_UP'
|
|
});
|
|
} else {
|
|
if (topic.user.score >= forumsConfig.thumbs_up_score) {
|
|
topic._scoreList.push(thumb);
|
|
topic.user.update({
|
|
$inc: {score: forumsConfig.thumbs_up_score}
|
|
}).exec();
|
|
} else {
|
|
return res.status(422).send({
|
|
message: 'SCORE_NOT_ENOUGH'
|
|
});
|
|
}
|
|
}
|
|
}
|
|
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
}
|
|
});
|
|
|
|
user.update({
|
|
$inc: {score: -forumsConfig.thumbs_up_score}
|
|
}).exec();
|
|
};
|
|
|
|
/**
|
|
* deleteTopic
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.deleteTopic = function (req, res) {
|
|
var forum = req.forum;
|
|
var topic = req.topic;
|
|
var rcount = topic.replyCount;
|
|
|
|
topic.remove(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
|
|
Topic.findOne({
|
|
forum: forum._id
|
|
})
|
|
.sort('-lastReplyAt -createdAt')
|
|
.exec(function (err, topic) {
|
|
if (!err) {
|
|
forum.update({
|
|
$inc: {topicCount: -1, replyCount: -rcount},
|
|
lastTopic: topic
|
|
}).exec();
|
|
}
|
|
});
|
|
|
|
//create trace log
|
|
traceLogCreate(req, traceConfig.action.forumDeleteTopic, {
|
|
forum: forum._id,
|
|
topic: topic._id
|
|
});
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* postNewReply
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.postNewReply = function (req, res) {
|
|
var forum = req.forum;
|
|
var topic = req.topic;
|
|
var reply = new Reply(req.body);
|
|
reply.user = req.user;
|
|
|
|
//replace content path
|
|
var regex = new RegExp('/modules/forums/client/attach/temp/', 'g');
|
|
reply.content = reply.content.replace(regex, '/modules/forums/client/attach/');
|
|
|
|
topic._replies.push(reply);
|
|
topic.replyCount++;
|
|
topic.lastReplyAt = Date.now();
|
|
topic.lastUser = req.user;
|
|
|
|
//move temp torrent file to dest directory
|
|
req.body._uImage.forEach(function (f) {
|
|
var oldPath = config.uploads.attach.file.temp + f.filename;
|
|
var newPath = config.uploads.attach.file.dest + f.filename;
|
|
move(oldPath, newPath, function (err) {
|
|
if (err) {
|
|
console.log(err);
|
|
}
|
|
});
|
|
});
|
|
req.body._attach.forEach(function (f) {
|
|
var oldPath = config.uploads.attach.file.temp + f.filename;
|
|
var newPath = config.uploads.attach.file.dest + f.filename;
|
|
move(oldPath, newPath, function (err) {
|
|
if (err) {
|
|
console.log(err);
|
|
}
|
|
});
|
|
});
|
|
|
|
//save topic
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
|
|
forum.update({
|
|
$inc: {replyCount: 1},
|
|
lastTopic: topic
|
|
}).exec();
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* updateReply
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.updateReply = function (req, res) {
|
|
var topic = req.topic;
|
|
|
|
topic._replies.forEach(function (t) {
|
|
if (t._id.equals(req.params.replyId)) {
|
|
t.content = req.body.content;
|
|
t.updatedAt = Date.now();
|
|
t.updatedBy = req.user;
|
|
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
}
|
|
});
|
|
}
|
|
});
|
|
};
|
|
|
|
|
|
/**
|
|
* deleteReply
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.deleteReply = function (req, res) {
|
|
var forum = req.forum;
|
|
var topic = req.topic;
|
|
|
|
topic._replies.forEach(function (t) {
|
|
if (t._id.equals(req.params.replyId)) {
|
|
topic._replies.pull(t);
|
|
topic.replyCount--;
|
|
topic.save(function (err) {
|
|
if (err) {
|
|
return res.status(422).send({
|
|
message: errorHandler.getErrorMessage(err)
|
|
});
|
|
} else {
|
|
res.json(topic);
|
|
|
|
forum.update({
|
|
$inc: {replyCount: -1}
|
|
}).exec();
|
|
|
|
//create trace log
|
|
traceLogCreate(req, traceConfig.action.forumDeleteReply, {
|
|
forum: forum._id,
|
|
topic: topic._id,
|
|
reply: req.params.replyId
|
|
});
|
|
}
|
|
});
|
|
}
|
|
});
|
|
};
|
|
|
|
/**
|
|
* attachUpload
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.attachUpload = function (req, res) {
|
|
var user = req.user;
|
|
var createUploadAttachFilename = require(path.resolve('./config/lib/multer')).createUploadAttachFilename;
|
|
var getUploadAttachDestination = require(path.resolve('./config/lib/multer')).getUploadAttachDestination;
|
|
var attachInfo = {};
|
|
|
|
var storage = multer.diskStorage({
|
|
destination: getUploadAttachDestination,
|
|
filename: createUploadAttachFilename
|
|
});
|
|
|
|
var upload = multer({
|
|
storage: storage,
|
|
//fileFilter: fileFilter,
|
|
limits: config.uploads.attach.file.limits
|
|
}).single('newAttachFile');
|
|
|
|
if (user) {
|
|
uploadFile()
|
|
.then(function () {
|
|
res.status(200).send(attachInfo);
|
|
})
|
|
.catch(function (err) {
|
|
res.status(422).send(err);
|
|
console.log(err);
|
|
|
|
if (req.file && req.file.filename) {
|
|
var newfile = config.uploads.attach.file.temp + req.file.filename;
|
|
if (fs.existsSync(newfile)) {
|
|
console.log(err);
|
|
console.log('ERROR: DELETE TEMP ATTACH FILE: ' + newfile);
|
|
fs.unlinkSync(newfile);
|
|
}
|
|
}
|
|
});
|
|
} else {
|
|
res.status(401).send({
|
|
message: 'User is not signed in'
|
|
});
|
|
}
|
|
|
|
function uploadFile() {
|
|
return new Promise(function (resolve, reject) {
|
|
upload(req, res, function (uploadError) {
|
|
if (uploadError) {
|
|
var message = errorHandler.getErrorMessage(uploadError);
|
|
|
|
if (uploadError.code === 'LIMIT_FILE_SIZE') {
|
|
message = 'Attach file too large. Maximum size allowed is ' + (config.uploads.attach.file.limits.fileSize / (1024 * 1024)).toFixed(2) + ' Mb files.';
|
|
}
|
|
|
|
reject(message);
|
|
} else {
|
|
attachInfo.filename = req.file.filename;
|
|
resolve();
|
|
}
|
|
});
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
* attachDownload
|
|
* @param req
|
|
* @param res
|
|
*/
|
|
exports.attachDownload = function (req, res) {
|
|
var topic = req.topic;
|
|
var filePath = undefined;
|
|
|
|
if (req.params.replyId) {
|
|
topic._replies.forEach(function (rep) {
|
|
if (rep._id.equals(req.params.replyId)) {
|
|
rep._attach.forEach(function (at) {
|
|
if (at._id.equals(req.query.attachId)) {
|
|
at.downCount++;
|
|
filePath = config.uploads.attach.file.dest + at.filename;
|
|
|
|
topic.markModified('_replies');
|
|
topic.save();
|
|
}
|
|
});
|
|
}
|
|
});
|
|
} else {
|
|
topic._attach.forEach(function (at) {
|
|
if (at._id.equals(req.query.attachId)) {
|
|
at.downCount++;
|
|
filePath = config.uploads.attach.file.dest + at.filename;
|
|
|
|
topic.save();
|
|
}
|
|
});
|
|
}
|
|
return downFile(filePath);
|
|
|
|
function downFile(filePath) {
|
|
if (!filePath) {
|
|
res.status(422).send({
|
|
message: 'FILE_DOES_NOT_FINDED'
|
|
});
|
|
}
|
|
|
|
fs.exists(filePath, function (exists) {
|
|
if (exists) {
|
|
var stat = fs.statSync(filePath);
|
|
|
|
try {
|
|
//res.set('Content-Type', 'application/x-bittorrent');
|
|
res.set('Content-Disposition', 'attachment; filename=' + req.params.filename);
|
|
res.set('Content-Length', stat.size);
|
|
|
|
fs.createReadStream(filePath).pipe(res);
|
|
} catch (err) {
|
|
res.status(422).send({
|
|
message: 'DOWNLOAD_FAILED'
|
|
});
|
|
}
|
|
} else {
|
|
res.status(422).send({
|
|
message: 'FILE_DOES_NOT_EXISTS'
|
|
});
|
|
}
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Invitation middleware
|
|
*/
|
|
exports.topicById = function (req, res, next, id) {
|
|
|
|
if (!mongoose.Types.ObjectId.isValid(id)) {
|
|
return res.status(400).send({
|
|
message: 'Topic is invalid'
|
|
});
|
|
}
|
|
|
|
Topic.findById(id)
|
|
.populate('user', 'username displayName profileImageURL uploaded downloaded score')
|
|
.populate('lastUser', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('updatedBy', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('_scoreList.user', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('_replies.user', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('_replies.updatedBy', 'username displayName profileImageURL uploaded downloaded')
|
|
.populate('_replies._scoreList.user', 'username displayName profileImageURL uploaded downloaded')
|
|
.exec(function (err, topic) {
|
|
if (err) {
|
|
return next(err);
|
|
} else if (!topic) {
|
|
return res.status(404).send({
|
|
message: 'No topic with that identifier has been found'
|
|
});
|
|
}
|
|
req.topic = topic;
|
|
next();
|
|
});
|
|
};
|