Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-12-20 23:40:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: rewrote SocketPosts.getRawPost in await style

Browse Source 
Added new filter hook filter:post.getRawPost
This commit is contained in:
Julian Lam
2019-08-07 13:18:22 -04:00
parent 90bcd65a00
commit 08530bb33f
1 changed files with 16 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/socket.io/posts.js
View File

@@ -70,24 +70,22 @@ function postReply(socket, data, callback) {
], callback); ], callback);
} }
SocketPosts.getRawPost = function (socket, pid, callback) { SocketPosts.getRawPost = async (socket, pid) => {
async.waterfall([ const canRead = await privileges.posts.can('topics:read', pid, socket.uid);
function (next) {
privileges.posts.can('topics:read', pid, socket.uid, next);
},
function (canRead, next) {
if (!canRead) { if (!canRead) {
return next(new Error('[[error:no-privileges]]')); throw new Error('[[error:no-privileges]]');
} }
posts.getPostFields(pid, ['content', 'deleted'], next);
}, let postData = await posts.getPostFields(pid, ['content', 'deleted']);
function (postData, next) {
if (postData.deleted) { if (postData.deleted) {
return next(new Error('[[error:no-post]]')); throw new Error('[[error:no-post]]');
} }
next(null, postData.content);
}, postData = await plugins.fireHook('filter:post.getRawPost', Object.assign(postData, {
], callback); pid: pid,
}));
return postData.content;
}; };
SocketPosts.getTimestampByIndex = function (socket, data, callback) { SocketPosts.getTimestampByIndex = function (socket, data, callback) {