mirrors/etherpad-lite
1
0
Fork 0
mirror of https://github.com/ether/etherpad-lite.git synced 2025-04-23 17:06:16 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 25

PadMessageHandler: Switch from nodeify to util.callbackify

Browse source
This commit is contained in:
Richard Hansen 2021-11-16 02:12:54 -05:00
parent abf4eeeb17
commit 5c1177a3d9
3 changed files with 9 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/node/handler/PadMessageHandler.js
View file

@ -37,8 +37,8 @@ const hooks = require('../../static/js/pluginfw/hooks.js');
const channels = require('channels');
const stats = require('../stats');
const assert = require('assert').strict;
const nodeify = require('nodeify');
const {RateLimiterMemory} = require('rate-limiter-flexible');
const util = require('util');
const webaccess = require('../hooks/express/webaccess');
let rateLimiter;
@ -87,9 +87,8 @@ stats.gauge('activePads', () => {
/**
* A changeset queue per pad that is processed by handleUserChanges()
*/
const padChannels = new channels.channels(
({socket, message}, callback) => nodeify(handleUserChanges(socket, message), callback)
);
const padChannels =
new channels.channels(({socket, message}, cb) => handleUserChangesCb(socket, message, cb));
/**
* This Method is called by server.js to tell the message handler on which socket it should send
@ -691,6 +690,7 @@ const handleUserChanges = async (socket, message) => {
stopWatch.end();
};
const handleUserChangesCb = util.callbackify(handleUserChanges);
exports.updatePadClients = async (pad) => {
// skip this if no-one is on this pad