feat: add hook for user notifications, closes #7672

src/notifications.js

@@ -63,22 +63,18 @@ Notifications.getMultiple = function (nids, callback) {
 	if (!Array.isArray(nids) || !nids.length) {
 		return setImmediate(callback, null, []);
 	}
-	var keys = nids.map(function (nid) {
-		return 'notifications:' + nid;
-	});
 
 	var notifications;
 
 	async.waterfall([
 		function (next) {
+			const keys = nids.map(nid => 'notifications:' + nid);
 			db.getObjects(keys, next);
 		},
 		function (_notifications, next) {
 			notifications = _notifications;
-			var userKeys = notifications.map(function (notification) {
-				return notification && notification.from;
-			});
 
+			const userKeys = notifications.map(n => n && n.from);
 			User.getUsersFields(userKeys, ['username', 'userslug', 'picture'], next);
 		},
 		function (usersData, next) {

src/user/notifications.js

@@ -9,6 +9,7 @@ var db = require('../database');
 var meta = require('../meta');
 var notifications = require('../notifications');
 var privileges = require('../privileges');
+var plugins = require('../plugins');
 var utils = require('../utils');
 
 var UserNotifications = module.exports;
@@ -111,7 +112,7 @@ function getNotificationsFromSet(set, uid, start, stop, callback) {
 
 UserNotifications.getNotifications = function (nids, uid, callback) {
 	if (!Array.isArray(nids) || !nids.length) {
-		return callback(null, []);
+		return setImmediate(callback, null, []);
 	}
 
 	var notificationData = [];
@@ -145,6 +146,14 @@ UserNotifications.getNotifications = function (nids, uid, callback) {
 		function (next) {
 			notifications.merge(notificationData, next);
 		},
+		function (notifications, next) {
+			plugins.fireHook('filter:user.notifications.getNotifications', {
+				uid: uid,
+				notifications: notifications,
+			}, function (err, result) {
+				next(err, result && result.notifications);
+			});
+		},
 	], callback);
 };