Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: catch exceptions from sendNotifications

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2022-01-19 20:52:12 -05:00
parent d7796f0b73
commit c1ec20470b
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/messaging/notifications.js
View File

@@ -1,5 +1,7 @@
'use strict'; 'use strict';
const winston = require('winston');
const user = require('../user'); const user = require('../user');
const notifications = require('../notifications'); const notifications = require('../notifications');
const sockets = require('../socket.io'); const sockets = require('../socket.io');
@@ -45,8 +47,12 @@ module.exports = function (Messaging) {
Messaging.notifyQueue[`${fromUid}:${roomId}`] = queueObj; Messaging.notifyQueue[`${fromUid}:${roomId}`] = queueObj;
} }
queueObj.timeout = setTimeout(() => { queueObj.timeout = setTimeout(async () => {
sendNotifications(fromUid, uids, roomId, queueObj.message); try {
await sendNotifications(fromUid, uids, roomId, queueObj.message);
} catch (err) {
winston.error(`[messaging/notifications] Unabled to send notification\n${err.stack}`);
}
}, meta.config.notificationSendDelay * 1000); }, meta.config.notificationSendDelay * 1000);
}; };