mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-10-31 02:55:58 +01:00
341 lines
7.8 KiB
JavaScript
341 lines
7.8 KiB
JavaScript
var RDB = require('./redis.js'),
|
|
utils = require('./../public/src/utils.js'),
|
|
schema = require('./schema.js'),
|
|
marked = require('marked'),
|
|
user = require('./user.js'),
|
|
topics = require('./topics.js'),
|
|
favourites = require('./favourites.js'),
|
|
threadTools = require('./threadTools.js'),
|
|
feed = require('./feed.js'),
|
|
async = require('async');
|
|
|
|
marked.setOptions({
|
|
breaks: true
|
|
});
|
|
|
|
(function(Posts) {
|
|
|
|
Posts.getPostsByTid = function(tid, start, end, callback) {
|
|
RDB.lrange('tid:' + tid + ':posts', start, end, function(err, pids) {
|
|
|
|
RDB.handle(err);
|
|
|
|
if (pids.length) {
|
|
Posts.getPostsByPids(pids, function(posts) {
|
|
callback(posts);
|
|
});
|
|
} else {
|
|
callback({
|
|
error: 'no-posts'
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
Posts.addUserInfoToPost = function(post, callback) {
|
|
user.getUserFields(post.uid, ['username', 'userslug', 'reputation', 'picture', 'signature'], function(userData) {
|
|
|
|
post.username = userData.username || 'anonymous';
|
|
post.userslug = userData.userslug || '';
|
|
post.user_rep = userData.reputation || 0;
|
|
post.picture = userData.picture || require('gravatar').url('', {}, https=global.config.https);
|
|
post.signature = marked(userData.signature || '');
|
|
|
|
callback();
|
|
});
|
|
}
|
|
|
|
Posts.getPostSummaryByPids = function(pids, callback) {
|
|
|
|
var returnData = [];
|
|
|
|
var loaded = 0;
|
|
|
|
for(var i=0, ii=pids.length; i<ii; ++i) {
|
|
|
|
(function(index, pid) {
|
|
Posts.getPostFields(pids[i], ['pid', 'content', 'uid', 'timestamp'], function(postData) {
|
|
Posts.addUserInfoToPost(postData, function() {
|
|
|
|
returnData[index] = postData;
|
|
++loaded;
|
|
|
|
if(loaded === pids.length) {
|
|
callback(returnData);
|
|
}
|
|
});
|
|
});
|
|
}(i, pids[i]));
|
|
}
|
|
};
|
|
|
|
Posts.getPostData = function(pid, callback) {
|
|
RDB.hgetall('post:' + pid, function(err, data) {
|
|
if(err === null)
|
|
callback(data);
|
|
else
|
|
console.log(err);
|
|
});
|
|
}
|
|
|
|
Posts.getPostFields = function(uid, fields, callback) {
|
|
RDB.hmget('post:' + uid, fields, function(err, data) {
|
|
if(err === null) {
|
|
var returnData = {};
|
|
|
|
for(var i=0, ii=fields.length; i<ii; ++i) {
|
|
returnData[fields[i]] = data[i];
|
|
}
|
|
|
|
callback(returnData);
|
|
}
|
|
else
|
|
console.log(err);
|
|
});
|
|
}
|
|
|
|
Posts.getPostsByPids = function(pids, callback) {
|
|
var posts = [],
|
|
loaded = 0;
|
|
|
|
for(var i=0, ii=pids.length; i<ii; ++i) {
|
|
(function(index, pid) {
|
|
Posts.getPostData(pid, function(postData) {
|
|
|
|
if(postData) {
|
|
postData.relativeTime = utils.relativeTime(postData.timestamp);
|
|
postData.post_rep = postData.reputation;
|
|
postData['edited-class'] = postData.editor !== '' ? '' : 'none';
|
|
postData['relativeEditTime'] = postData.edited !== '0' ? utils.relativeTime(postData.edited) : '';
|
|
|
|
posts[index] = postData;
|
|
}
|
|
|
|
++loaded;
|
|
if(loaded === pids.length)
|
|
callback(posts);
|
|
});
|
|
}(i, pids[i]));
|
|
}
|
|
}
|
|
|
|
Posts.getPostField = function(pid, field, callback) {
|
|
RDB.hget('post:' + pid, field, function(err, data) {
|
|
if(err === null)
|
|
callback(data);
|
|
else
|
|
console.log(err);
|
|
});
|
|
}
|
|
|
|
Posts.setPostField = function(pid, field, value) {
|
|
RDB.hset('post:' + pid, field, value);
|
|
}
|
|
|
|
Posts.getPostFields = function(pid, fields, callback) {
|
|
RDB.hmget('post:' + pid, fields, function(err, data) {
|
|
if(err === null) {
|
|
var returnData = {};
|
|
|
|
for(var i=0, ii=fields.length; i<ii; ++i) {
|
|
returnData[fields[i]] = data[i];
|
|
}
|
|
|
|
callback(returnData);
|
|
}
|
|
else
|
|
console.log(err);
|
|
});
|
|
}
|
|
|
|
Posts.get_cid_by_pid = function(pid, callback) {
|
|
Posts.getPostField(pid, 'tid', function(tid) {
|
|
if (tid) {
|
|
topics.getTopicField(tid, 'cid', function(cid) {
|
|
if (cid) {
|
|
callback(cid);
|
|
} else {
|
|
callback(false);
|
|
}
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
Posts.reply = function(socket, tid, uid, content) {
|
|
if (uid < 1) {
|
|
socket.emit('event:alert', {
|
|
title: 'Reply Unsuccessful',
|
|
message: 'You don't seem to be logged in, so you cannot reply.',
|
|
type: 'error',
|
|
timeout: 2000
|
|
});
|
|
return;
|
|
}
|
|
|
|
|
|
user.getUserField(uid, 'lastposttime', function(lastposttime) {
|
|
|
|
if(Date.now() - lastposttime < config.post_delay) {
|
|
socket.emit('event:alert', {
|
|
title: 'Too many posts!',
|
|
message: 'You can only post every '+ (config.post_delay / 1000) + ' seconds.',
|
|
type: 'error',
|
|
timeout: 2000
|
|
});
|
|
return;
|
|
}
|
|
|
|
Posts.create(uid, tid, content, function(pid) {
|
|
if (pid > 0) {
|
|
RDB.rpush('tid:' + tid + ':posts', pid);
|
|
|
|
RDB.del('tid:' + tid + ':read_by_uid');
|
|
|
|
Posts.get_cid_by_pid(pid, function(cid) {
|
|
RDB.del('cid:' + cid + ':read_by_uid', function(err, data) {
|
|
topics.markAsRead(tid, uid);
|
|
});
|
|
});
|
|
|
|
Posts.getTopicPostStats(socket);
|
|
|
|
// Send notifications to users who are following this topic
|
|
threadTools.notify_followers(tid, uid);
|
|
|
|
|
|
socket.emit('event:alert', {
|
|
title: 'Reply Successful',
|
|
message: 'You have successfully replied. Click here to view your reply.',
|
|
type: 'notify',
|
|
timeout: 2000
|
|
});
|
|
|
|
|
|
var timestamp = Date.now();
|
|
var socketData = {
|
|
'posts' : [
|
|
{
|
|
'pid' : pid,
|
|
'content' : marked(content || ''),
|
|
'uid' : uid,
|
|
'post_rep' : 0,
|
|
'timestamp' : timestamp,
|
|
'relativeTime': utils.relativeTime(timestamp),
|
|
'fav_star_class' :'icon-star-empty',
|
|
'edited-class': 'none',
|
|
'editor': '',
|
|
}
|
|
]
|
|
};
|
|
|
|
posts.addUserInfoToPost(socketData['posts'][0], function() {
|
|
io.sockets.in('topic_' + tid).emit('event:new_post', socketData);
|
|
io.sockets.in('recent_posts').emit('event:new_post', socketData);
|
|
});
|
|
|
|
} else {
|
|
socket.emit('event:alert', {
|
|
title: 'Reply Unsuccessful',
|
|
message: 'Your reply could not be posted at this time. Please try again later.',
|
|
type: 'notify',
|
|
timeout: 2000
|
|
});
|
|
}
|
|
});
|
|
});
|
|
};
|
|
|
|
Posts.create = function(uid, tid, content, callback) {
|
|
if (uid === null) {
|
|
callback(-1);
|
|
return;
|
|
}
|
|
|
|
topics.isLocked(tid, function(locked) {
|
|
|
|
if (!locked || locked === '0') {
|
|
RDB.incr('global:next_post_id', function(err, pid) {
|
|
RDB.handle(err);
|
|
|
|
var timestamp = Date.now();
|
|
|
|
RDB.hmset('post:' + pid, {
|
|
'pid': pid,
|
|
'uid': uid,
|
|
'tid': tid,
|
|
'content': content,
|
|
'timestamp': timestamp,
|
|
'reputation': 0,
|
|
'editor': '',
|
|
'edited': 0,
|
|
'deleted': 0
|
|
});
|
|
|
|
topics.increasePostCount(tid);
|
|
topics.setTopicField(tid, 'lastposttime', timestamp);
|
|
topics.addToRecent(tid, timestamp);
|
|
|
|
RDB.incr('totalpostcount');
|
|
|
|
topics.getTopicField(tid, 'cid', function(cid) {
|
|
RDB.handle(err);
|
|
|
|
feed.updateTopic(tid, cid);
|
|
|
|
RDB.zadd('categories:recent_posts:cid:' + cid, Date.now(), pid);
|
|
|
|
// this is a bit of a naive implementation, defn something to look at post-MVP
|
|
RDB.scard('cid:' + cid + ':active_users', function(amount) {
|
|
if (amount > 10) {
|
|
RDB.spop('cid:' + cid + ':active_users');
|
|
}
|
|
|
|
RDB.sadd('cid:' + cid + ':active_users', uid);
|
|
});
|
|
});
|
|
|
|
|
|
|
|
user.onNewPostMade(uid, tid, pid, timestamp);
|
|
|
|
if (callback)
|
|
callback(pid);
|
|
});
|
|
} else {
|
|
callback(-1);
|
|
}
|
|
});
|
|
}
|
|
|
|
Posts.getPostsByUid = function(uid, start, end, callback) {
|
|
|
|
user.getPostIds(uid, start, end, function(pids) {
|
|
|
|
if(pids && pids.length) {
|
|
|
|
Posts.getPostsByPids(pids, function(posts) {
|
|
callback(posts);
|
|
});
|
|
}
|
|
else
|
|
callback([]);
|
|
});
|
|
}
|
|
|
|
Posts.getTopicPostStats = function(socket) {
|
|
RDB.mget(['totaltopiccount', 'totalpostcount'], function(err, data) {
|
|
if(err === null) {
|
|
var stats = {
|
|
topics: data[0]?data[0]:0,
|
|
posts: data[1]?data[1]:0
|
|
};
|
|
|
|
socket.emit('post.stats', stats);
|
|
}
|
|
else
|
|
console.log(err);
|
|
});
|
|
}
|
|
|
|
}(exports)); |