|
|
|
@ -197,9 +197,11 @@ var async = require('async'),
|
|
|
|
plugins.fireHook('action:notification.pushed', {notification: notification, uids: uids});
|
|
|
|
plugins.fireHook('action:notification.pushed', {notification: notification, uids: uids});
|
|
|
|
|
|
|
|
|
|
|
|
var websockets = require('./socket.io');
|
|
|
|
var websockets = require('./socket.io');
|
|
|
|
|
|
|
|
if (websockets.server) {
|
|
|
|
for(var i=0; i<uids.length; ++i) {
|
|
|
|
for(var i=0; i<uids.length; ++i) {
|
|
|
|
websockets.in('uid_' + uids[i]).emit('event:new_notification', notification);
|
|
|
|
websockets.in('uid_' + uids[i]).emit('event:new_notification', notification);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
callback();
|
|
|
|
callback();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|