public-offering
/
pad.pub0.org
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

PadMessageHandler: Move code out of unnecessary closure 

Also simplify the logic.
pull/4289/head
Richard Hansen 2020-09-04 22:57:36 -04:00 committed by John McLear
parent a261fdf430
commit 80c0e2487d
1 changed files with 8 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/node/handler/PadMessageHandler.js
View File

@ -199,30 +199,15 @@ exports.handleMessage = async function(client, message)
return;
}
async function handleMessageHook() {
// Allow plugins to bypass the readonly message blocker
let messages = await hooks.aCallAll("handleMessageSecurity", { client: client, message: message });
// Allow plugins to bypass the readonly message blocker
if ((await hooks.aCallAll('handleMessageSecurity', {client, message})).some((w) => w === true)) {
thisSession.readonly = false;
}
for (let message of messages) {
if (message === true) {
thisSession.readonly = false;
break;
}
}
let dropMessage = false;
// Call handleMessage hook. If a plugin returns null, the message will be dropped. Note that for all messages
// handleMessage will be called, even if the client is not authorized
messages = await hooks.aCallAll("handleMessage", { client: client, message: message });
for (let message of messages) {
if (message === null ) {
dropMessage = true;
break;
}
}
return dropMessage;
// Call handleMessage hook. If a plugin returns null, the message will be dropped. Note that for
// all messages handleMessage will be called, even if the client is not authorized
if ((await hooks.aCallAll('handleMessage', {client, message})).some((m) => m === null)) {
return;
}
function finalHandler() {
@ -259,9 +244,6 @@ exports.handleMessage = async function(client, message)
}
}
let dropMessage = await handleMessageHook();
if (dropMessage) return;
if (message.type === "CLIENT_READY") {
// client tried to auth for the first time (first msg from the client)
createSessionInfoAuth(client, message);