mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-10-26 08:36:12 +01:00
feat: add awaitable socket.emit
This commit is contained in:
@@ -17,6 +17,25 @@ app.isConnected = false;
|
|||||||
|
|
||||||
socket = io(config.websocketAddress, ioParams);
|
socket = io(config.websocketAddress, ioParams);
|
||||||
|
|
||||||
|
var oEmit = socket.emit;
|
||||||
|
socket.emit = function (event, data, callback) {
|
||||||
|
if (typeof data === 'function') {
|
||||||
|
callback = data;
|
||||||
|
data = null;
|
||||||
|
}
|
||||||
|
if (typeof callback === 'function') {
|
||||||
|
oEmit.apply(socket, [event, data, callback]);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
return new Promise(function (resolve, reject) {
|
||||||
|
oEmit.apply(socket, [event, data, function (err, result) {
|
||||||
|
if (err) reject(err);
|
||||||
|
else resolve(result);
|
||||||
|
}]);
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
if (parseInt(app.user.uid, 10) >= 0) {
|
if (parseInt(app.user.uid, 10) >= 0) {
|
||||||
addHandlers();
|
addHandlers();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user