'use strict'; /*global require, before, after*/ var assert = require('assert'); var async = require('async'); var db = require('./mocks/databasemock'); var topics = require('../src/topics'); var posts = require('../src/posts'); var categories = require('../src/categories'); var privileges = require('../src/privileges'); var user = require('../src/user'); var groups = require('../src/groups'); describe('Post\'s', function () { var voterUid; var voteeUid; var globalModUid; var postData; var topicData; var cid; before(function (done) { groups.resetCache(); async.series({ voterUid: function (next) { user.create({username: 'upvoter'}, next); }, voteeUid: function (next) { user.create({username: 'upvotee'}, next); }, globalModUid: function (next) { user.create({username: 'globalmod'}, next); }, category: function (next) { categories.create({ name: 'Test Category', description: 'Test category created by testing script' }, next); } }, function (err, results) { if (err) { return done(err); } voterUid = results.voterUid; voteeUid = results.voteeUid; globalModUid = results.globalModUid; cid = results.category.cid; topics.post({ uid: results.voteeUid, cid: results.category.cid, title: 'Test Topic Title', content: 'The content of test topic' }, function (err, data) { if (err) { return done(err); } postData = data.postData; topicData = data.topicData; groups.join('Global Moderators', globalModUid, done); }); }); }); describe('voting', function () { var socketPosts = require('../src/socket.io/posts'); it('should upvote a post', function (done) { socketPosts.upvote({uid: voterUid}, {pid: postData.pid, room_id: 'topic_1'}, function (err, result) { assert.ifError(err); assert.equal(result.post.upvotes, 1); assert.equal(result.post.downvotes, 0); assert.equal(result.post.votes, 1); assert.equal(result.user.reputation, 1); posts.hasVoted(postData.pid, voterUid, function (err, data) { assert.ifError(err); assert.equal(data.upvoted, true); assert.equal(data.downvoted, false); done(); }); }); }); it('should get voters', function (done) { socketPosts.getVoters({uid: globalModUid}, {pid: postData.pid, cid: cid}, function (err, data) { assert.ifError(err); assert.equal(data.upvoteCount, 1); assert.equal(data.downvoteCount, 0); assert(Array.isArray(data.upvoters)); assert.equal(data.upvoters[0].username, 'upvoter'); done(); }); }); it('should get upvoters', function (done) { socketPosts.getUpvoters({uid: globalModUid}, [postData.pid], function (err, data) { assert.ifError(err); assert.equal(data[0].otherCount, 0); assert.equal(data[0].usernames, 'upvoter'); done(); }); }); it('should unvote a post', function (done) { socketPosts.unvote({uid: voterUid}, {pid: postData.pid, room_id: 'topic_1'}, function (err, result) { assert.ifError(err); assert.equal(result.post.upvotes, 0); assert.equal(result.post.downvotes, 0); assert.equal(result.post.votes, 0); assert.equal(result.user.reputation, 0); posts.hasVoted(postData.pid, voterUid, function (err, data) { assert.ifError(err); assert.equal(data.upvoted, false); assert.equal(data.downvoted, false); done(); }); }); }); it('should downvote a post', function (done) { socketPosts.downvote({uid: voterUid}, {pid: postData.pid, room_id: 'topic_1'}, function (err, result) { assert.ifError(err); assert.equal(result.post.upvotes, 0); assert.equal(result.post.downvotes, 1); assert.equal(result.post.votes, -1); assert.equal(result.user.reputation, -1); posts.hasVoted(postData.pid, voterUid, function (err, data) { assert.ifError(err); assert.equal(data.upvoted, false); assert.equal(data.downvoted, true); done(); }); }); }); }); describe('bookmarking', function () { it('should bookmark a post', function (done) { posts.bookmark(postData.pid, voterUid, function (err, data) { assert.ifError(err); assert.equal(data.isBookmarked, true); posts.hasBookmarked(postData.pid, voterUid, function (err, hasBookmarked) { assert.ifError(err); assert.equal(hasBookmarked, true); done(); }); }); }); it('should unbookmark a post', function (done) { posts.unbookmark(postData.pid, voterUid, function (err, data) { assert.ifError(err); assert.equal(data.isBookmarked, false); posts.hasBookmarked([postData.pid], voterUid, function (err, hasBookmarked) { assert.ifError(err); assert.equal(hasBookmarked[0], false); done(); }); }); }); }); describe('post tools', function () { var socketPosts = require('../src/socket.io/posts'); it('should error if data is invalid', function (done) { socketPosts.loadPostTools({uid: globalModUid}, null, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should load post tools', function (done) { socketPosts.loadPostTools({uid: globalModUid}, {pid: postData.pid, cid: cid}, function (err, data) { assert.ifError(err); assert(data.posts.display_edit_tools); assert(data.posts.display_delete_tools); assert(data.posts.display_moderator_tools); assert(data.posts.display_move_tools); done(); }); }); }); describe('delete/restore/purge', function () { function createTopicWithReply(callback) { topics.post({ uid: voterUid, cid: cid, title: 'topic to delete/restore/purge', content: 'A post to delete/restore/purge' }, function (err, topicPostData) { assert.ifError(err); topics.reply({ uid: voterUid, tid: topicPostData.topicData.tid, timestamp: Date.now(), content: 'A post to delete/restore and purge' }, function (err, replyData) { assert.ifError(err); callback(topicPostData, replyData); }); }); } var tid; var mainPid; var replyPid; var socketPosts = require('../src/socket.io/posts'); before(function (done) { createTopicWithReply(function (topicPostData, replyData) { tid = topicPostData.topicData.tid; mainPid = topicPostData.postData.pid; replyPid = replyData.pid; privileges.categories.give(['purge'], cid, 'registered-users', done); }); }); it('should error with invalid data', function (done) { socketPosts.delete({uid: voterUid}, null, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should delete a post', function (done) { socketPosts.delete({uid: voterUid}, {pid: replyPid, tid: tid}, function (err) { assert.ifError(err); posts.getPostField(replyPid, 'deleted', function (err, isDeleted) { assert.ifError(err); assert.equal(parseInt(isDeleted, 10), 1); done(); }); }); }); it('should restore a post', function (done) { socketPosts.restore({uid: voterUid}, {pid: replyPid, tid: tid}, function (err) { assert.ifError(err); posts.getPostField(replyPid, 'deleted', function (err, isDeleted) { assert.ifError(err); assert.equal(parseInt(isDeleted, 10), 0); done(); }); }); }); it('should delete posts', function (done) { socketPosts.deletePosts({uid: globalModUid}, {pids: [replyPid, mainPid], tid: tid}, function (err) { assert.ifError(err); posts.getPostField(replyPid, 'deleted', function (err, deleted) { assert.ifError(err); assert.equal(parseInt(deleted, 10), 1); posts.getPostField(mainPid, 'deleted', function (err, deleted) { assert.ifError(err); assert.equal(parseInt(deleted, 10), 1); done(); }); }); }); }); it('should delete topic if last main post is deleted', function (done) { topics.post({uid: voterUid, cid: cid, title: 'test topic', content: 'test topic'}, function (err, data) { assert.ifError(err); socketPosts.deletePosts({uid: globalModUid}, {pids: [data.postData.pid], tid: data.topicData.tid}, function (err) { assert.ifError(err); topics.getTopicField(data.topicData.tid, 'deleted', function (err, deleted) { assert.ifError(err); assert.equal(parseInt(deleted, 10), 1); done(); }); }); }); }); it('should purge posts and delete topic', function (done) { createTopicWithReply(function (topicPostData, replyData) { socketPosts.purgePosts({uid: voterUid}, {pids: [replyData.pid, topicPostData.postData.pid], tid: topicPostData.topicData.tid}, function (err) { assert.ifError(err); posts.exists('post:' + replyData.pid, function (err, exists) { assert.ifError(err); assert.equal(exists, false); topics.getTopicField(topicPostData.topicData.tid, 'deleted', function (err, deleted) { assert.ifError(err); assert.equal(parseInt(deleted, 10), 1); done(); }); }); }); }); }); }); describe('edit', function () { var pid; var replyPid; var tid; var socketPosts = require('../src/socket.io/posts'); var meta = require('../src/meta'); before(function (done) { topics.post({ uid: voterUid, cid: cid, title: 'topic to edit', content: 'A post to edit' }, function (err, data) { assert.ifError(err); pid = data.postData.pid; tid = data.topicData.tid; topics.reply({ uid: voterUid, tid: tid, timestamp: Date.now(), content: 'A reply to edit' }, function (err, data) { assert.ifError(err); replyPid = data.pid; privileges.categories.give(['posts:edit'], cid, 'registered-users', done); }); }); }); it('should error if user is not logged in', function (done) { socketPosts.edit({uid: 0}, {}, function (err) { assert.equal(err.message, '[[error:not-logged-in]]'); done(); }); }); it('should error if data is invalid or missing', function (done) { socketPosts.edit({uid: voterUid}, {}, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should error if title is too short', function (done) { socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited post content', title: 'a'}, function (err) { assert.equal(err.message, '[[error:title-too-short, ' + meta.config.minimumTitleLength + ']]'); done(); }); }); it('should error if title is too long', function (done) { var longTitle = new Array(parseInt(meta.config.maximumTitleLength, 10) + 2).join('a'); socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited post content', title: longTitle}, function (err) { assert.equal(err.message, '[[error:title-too-long, ' + meta.config.maximumTitleLength + ']]'); done(); }); }); it('should error with too few tags', function (done) { var oldValue = meta.config.minimumTagsPerTopic; meta.config.minimumTagsPerTopic = 1; socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited post content', tags: []}, function (err) { assert.equal(err.message, '[[error:not-enough-tags, ' + meta.config.minimumTagsPerTopic + ']]'); meta.config.minimumTagsPerTopic = oldValue; done(); }); }); it('should error with too many tags', function (done) { var tags = []; for(var i = 0; i < meta.config.maximumTagsPerTopic + 1; ++i) { tags.push('tag' + i); } socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited post content', tags: tags}, function (err) { assert.equal(err.message, '[[error:too-many-tags, ' + meta.config.maximumTagsPerTopic + ']]'); done(); }); }); it('should error if content is too short', function (done) { socketPosts.edit({uid: voterUid}, {pid: pid, content: 'e'}, function (err) { assert.equal(err.message, '[[error:content-too-short, ' + meta.config.minimumPostLength + ']]'); done(); }); }); it('should error if content is too long', function (done) { var longContent = new Array(parseInt(meta.config.maximumPostLength, 10) + 2).join('a'); socketPosts.edit({uid: voterUid}, {pid: pid, content: longContent}, function (err) { assert.equal(err.message, '[[error:content-too-long, ' + meta.config.maximumPostLength + ']]'); done(); }); }); it('should edit post', function (done) { socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited post content', title: 'edited title', tags: ['edited']}, function (err, data) { assert.ifError(err); assert.equal(data.content, 'edited post content'); assert.equal(data.editor, voterUid); assert.equal(data.topic.title, 'edited title'); assert.equal(data.topic.tags[0].value, 'edited'); done(); }); }); it('should edit a deleted post', function (done) { socketPosts.delete({uid: voterUid}, {pid: pid, tid: tid}, function (err) { assert.ifError(err); socketPosts.edit({uid: voterUid}, {pid: pid, content: 'edited deleted content', title: 'edited deleted title', tags: ['deleted']}, function (err, data) { assert.ifError(err); assert.equal(data.content, 'edited deleted content'); assert.equal(data.editor, voterUid); assert.equal(data.topic.title, 'edited deleted title'); assert.equal(data.topic.tags[0].value, 'deleted'); done(); }); }); }); it('should edit a reply post', function (done) { socketPosts.edit({uid: voterUid}, {pid: replyPid, content: 'edited reply'}, function (err, data) { assert.ifError(err); assert.equal(data.content, 'edited reply'); assert.equal(data.editor, voterUid); assert.equal(data.topic.isMainPost, false); assert.equal(data.topic.renamed, false); done(); }); }); }); describe('move', function () { var replyPid; var tid; var moveTid; var socketPosts = require('../src/socket.io/posts'); before(function (done) { async.waterfall([ function (next) { topics.post({ uid: voterUid, cid: cid, title: 'topic 1', content: 'some content' }, next); }, function (data, next) { tid = data.topicData.tid; topics.post({ uid: voterUid, cid: cid, title: 'topic 2', content: 'some content' }, next); }, function (data, next) { moveTid = data.topicData.tid; topics.reply({ uid: voterUid, tid: tid, timestamp: Date.now(), content: 'A reply to move' }, function (err, data) { assert.ifError(err); replyPid = data.pid; next(); }); } ], done); }); it('should error if uid is not logged in', function (done) { socketPosts.movePost({uid: 0}, {}, function (err) { assert.equal(err.message, '[[error:not-logged-in]]'); done(); }); }); it('should error if data is invalid', function (done) { socketPosts.movePost({uid: globalModUid}, {}, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should error if user does not have move privilege', function (done) { socketPosts.movePost({uid: voterUid}, {pid: replyPid, tid: moveTid}, function (err) { assert.equal(err.message, '[[error:no-privileges]]'); done(); }); }); it('should move a post', function (done) { socketPosts.movePost({uid: globalModUid}, {pid: replyPid, tid: moveTid}, function (err) { assert.ifError(err); posts.getPostField(replyPid, 'tid', function (err, tid) { assert.ifError(err); assert(tid, moveTid); done(); }); }); }); }); describe('flagging a post', function () { var meta = require('../src/meta'); var socketPosts = require('../src/socket.io/posts'); it('should fail to flag a post due to low reputation', function (done) { meta.config['privileges:flag'] = 10; flagPost(function (err) { assert.equal(err.message, '[[error:not-enough-reputation-to-flag]]'); done(); }); }); it('should flag a post', function (done) { meta.config['privileges:flag'] = -1; flagPost(function (err) { assert.ifError(err); done(); }); }); it('should return nothing without a uid or a reason', function (done) { socketPosts.flag({uid: 0}, {pid: postData.pid, reason: 'reason'}, function (err) { assert.equal(err.message, '[[error:not-logged-in]]'); socketPosts.flag({uid: voteeUid}, {}, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); }); it('should return an error without an existing post', function (done) { socketPosts.flag({uid: voteeUid}, {pid: 12312312, reason: 'reason'}, function (err) { assert.equal(err.message, '[[error:no-post]]'); done(); }); }); it('should return an error if the flag already exists', function (done) { socketPosts.flag({uid: voteeUid}, {pid: postData.pid, reason: 'reason'}, function (err) { assert.equal(err.message, '[[error:already-flagged]]'); done(); }); }); }); function flagPost(next) { var socketPosts = require('../src/socket.io/posts'); socketPosts.flag({uid: voteeUid}, {pid: postData.pid, reason: 'reason'}, next); } describe('get flag data', function () { it('should see the flagged post', function (done) { posts.isFlaggedByUser(postData.pid, voteeUid, function (err, hasFlagged) { assert.ifError(err); assert(hasFlagged); done(); }); }); it('should return the flagged post data', function (done) { posts.getFlags('posts:flagged', cid, voteeUid, 0, -1, function (err, flagData) { assert.ifError(err); assert(flagData.posts); assert(flagData.count); assert.equal(flagData.count, 1); assert.equal(flagData.posts.length, 1); assert(flagData.posts[0].flagReasons); assert.equal(flagData.posts[0].flagReasons.length, 1); assert.strictEqual(flagData.posts[0].flagReasons[0].reason, 'reason'); assert(flagData.posts[0].flagData); assert.strictEqual(flagData.posts[0].flagData.state, 'open'); done(); }); }); }); describe('updating a flag', function () { var socketPosts = require('../src/socket.io/posts'); it('should update a flag', function (done) { async.waterfall([ function (next) { socketPosts.updateFlag({uid: globalModUid}, { pid: postData.pid, data: [ {name: 'assignee', value: `${globalModUid}`}, {name: 'notes', value: 'notes'} ] }, function (err) { assert.ifError(err); posts.getFlags('posts:flagged', cid, globalModUid, 0, -1, function (err, flagData) { assert.ifError(err); assert(flagData.posts); assert.equal(flagData.posts.length, 1); assert.deepEqual({ assignee: flagData.posts[0].flagData.assignee, notes: flagData.posts[0].flagData.notes, state: flagData.posts[0].flagData.state, labelClass: flagData.posts[0].flagData.labelClass }, { assignee: `${globalModUid}`, notes: 'notes', state: 'open', labelClass: 'info' }); next(); }); }); }, function (next) { posts.updateFlagData(globalModUid, postData.pid, { state: 'rejected' }, function (err) { assert.ifError(err); posts.getFlags('posts:flagged', cid, globalModUid, 0, -1, function (err, flagData) { assert.ifError(err); assert(flagData.posts); assert.equal(flagData.posts.length, 1); assert.deepEqual({ state: flagData.posts[0].flagData.state, labelClass: flagData.posts[0].flagData.labelClass }, { state: 'rejected', labelClass: 'danger' }); next(); }); }); }, function (next) { posts.updateFlagData(globalModUid, postData.pid, { state: 'wip' }, function (err) { assert.ifError(err); posts.getFlags('posts:flagged', cid, globalModUid, 0, -1, function (err, flagData) { assert.ifError(err); assert(flagData.posts); assert.equal(flagData.posts.length, 1); assert.deepEqual({ state: flagData.posts[0].flagData.state, labelClass: flagData.posts[0].flagData.labelClass }, { state: 'wip', labelClass: 'warning' }); next(); }); }); }, function (next) { posts.updateFlagData(globalModUid, postData.pid, { state: 'resolved' }, function (err) { assert.ifError(err); posts.getFlags('posts:flagged', cid, globalModUid, 0, -1, function (err, flagData) { assert.ifError(err); assert(flagData.posts); assert.equal(flagData.posts.length, 1); assert.deepEqual({ state: flagData.posts[0].flagData.state, labelClass: flagData.posts[0].flagData.labelClass }, { state: 'resolved', labelClass: 'success' }); next(); }); }); } ], done); }); }); describe('dismissing a flag', function () { var socketPosts = require('../src/socket.io/posts'); it('should dismiss a flag', function (done) { socketPosts.dismissFlag({uid: globalModUid}, postData.pid, function (err) { assert.ifError(err); posts.isFlaggedByUser(postData.pid, voteeUid, function (err, hasFlagged) { assert.ifError(err); assert(!hasFlagged); flagPost(function (err) { assert.ifError(err); done(); }); }); }); }); it('should dismiss all of a user\'s flags', function (done) { posts.dismissUserFlags(voteeUid, function (err) { assert.ifError(err); posts.isFlaggedByUser(postData.pid, voteeUid, function (err, hasFlagged) { assert.ifError(err); assert(!hasFlagged); flagPost(function (err) { assert.ifError(err); done(); }); }); }); }); it('should dismiss all flags', function (done) { socketPosts.dismissAllFlags({uid: globalModUid}, {}, function (err) { assert.ifError(err); posts.isFlaggedByUser(postData.pid, voteeUid, function (err, hasFlagged) { assert.ifError(err); assert(!hasFlagged); flagPost(function (err) { assert.ifError(err); done(); }); }); }); }); }); describe('getPostSummaryByPids', function () { it('should return empty array for empty pids', function (done) { posts.getPostSummaryByPids([], 0, {}, function (err, data) { assert.ifError(err); assert.equal(data.length, 0); done(); }); }); it('should get post summaries', function (done) { posts.getPostSummaryByPids([postData.pid], 0, {}, function (err, data) { assert.ifError(err); assert(data[0].user); assert(data[0].topic); assert(data[0].category); done(); }); }); }); it('should get recent poster uids', function (done) { topics.reply({ uid: voterUid, tid: topicData.tid, timestamp: Date.now(), content: 'some content' }, function (err) { assert.ifError(err); posts.getRecentPosterUids(0, 1, function (err, uids) { assert.ifError(err); assert(Array.isArray(uids)); assert.equal(uids.length, 2); assert.equal(uids[0], voterUid); done(); }); }); }); describe('socket methods', function () { var pid; before(function (done) { topics.reply({ uid: voterUid, tid: topicData.tid, timestamp: Date.now(), content: 'raw content' }, function (err, postData) { assert.ifError(err); pid = postData.pid; privileges.categories.rescind(['read'], cid, 'guests', done); }); }); var socketPosts = require('../src/socket.io/posts'); it('should error with invalid data', function (done) { socketPosts.reply({uid: 0}, null, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should error with invalid tid', function (done) { socketPosts.reply({uid: 0}, {tid: 0, content: 'derp'}, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should fail to get raw post because of privilege', function (done) { socketPosts.getRawPost({uid: 0}, pid, function (err) { assert.equal(err.message, '[[error:no-privileges]]'); done(); }); }); it('should fail to get raw post because post is deleted', function (done) { posts.setPostField(pid, 'deleted', 1, function (err) { assert.ifError(err); socketPosts.getRawPost({uid: voterUid}, pid, function (err) { assert.equal(err.message, '[[error:no-post]]'); done(); }); }); }); it('should get raw post content', function (done) { posts.setPostField(pid, 'deleted', 0, function (err) { assert.ifError(err); socketPosts.getRawPost({uid: voterUid}, pid, function (err, postContent) { assert.ifError(err); assert.equal(postContent, 'raw content'); done(); }); }); }); it('should get post', function (done) { socketPosts.getPost({uid: voterUid}, pid, function (err, postData) { assert.ifError(err); assert(postData); done(); }); }); it('shold error with invalid data', function (done) { socketPosts.loadMoreBookmarks({uid: voterUid}, {uid: voterUid, after: null}, function (err, postData) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should load more bookmarks', function (done) { socketPosts.loadMoreBookmarks({uid: voterUid}, {uid: voterUid, after: 0}, function (err, data) { assert.ifError(err); assert(data); done(); }); }); it('should load more user posts', function (done) { socketPosts.loadMoreUserPosts({uid: voterUid}, {uid: voterUid, after: 0}, function (err, data) { assert.ifError(err); assert(data); done(); }); }); it('should load more best posts', function (done) { socketPosts.loadMoreBestPosts({uid: voterUid}, {uid: voterUid, after: 0}, function (err, data) { assert.ifError(err); assert(data); done(); }); }); it('should load more up voted posts', function (done) { socketPosts.loadMoreUpVotedPosts({uid: voterUid}, {uid: voterUid, after: 0}, function (err, data) { assert.ifError(err); assert(data); done(); }); }); it('should load more down voted posts', function (done) { socketPosts.loadMoreDownVotedPosts({uid: voterUid}, {uid: voterUid, after: 0}, function (err, data) { assert.ifError(err); assert(data); done(); }); }); it('should get post category', function (done) { socketPosts.getCategory({uid: voterUid}, pid, function (err, postCid) { assert.ifError(err); assert.equal(cid, postCid); done(); }); }); it('should error with invalid data', function (done) { socketPosts.getPidIndex({uid: voterUid}, null, function (err) { assert.equal(err.message, '[[error:invalid-data]]'); done(); }); }); it('should get pid index', function (done) { socketPosts.getPidIndex({uid: voterUid}, {pid: pid, tid: topicData.tid, topicPostSort: 'oldest-to-newest'}, function (err, index) { assert.ifError(err); assert.equal(index, 2); done(); }); }); }); after(function (done) { db.emptydb(done); }); });