|
|
|
@ -9,6 +9,7 @@ var RDB = require('./redis'),
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
(function(Notifications) {
|
|
|
|
|
"use strict";
|
|
|
|
|
|
|
|
|
|
Notifications.init = function() {
|
|
|
|
|
if (process.env.NODE_ENV === 'development') {
|
|
|
|
@ -79,7 +80,9 @@ var RDB = require('./redis'),
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Notifications.push = function(nid, uids, callback) {
|
|
|
|
|
if (!Array.isArray(uids)) uids = [uids];
|
|
|
|
|
if (!Array.isArray(uids)) {
|
|
|
|
|
uids = [uids];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var numUids = uids.length,
|
|
|
|
|
x;
|
|
|
|
@ -151,16 +154,16 @@ var RDB = require('./redis'),
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Notifications.mark_read = function(nid, uid, callback) {
|
|
|
|
|
if (parseInt(uid) > 0) {
|
|
|
|
|
Notifications.get(nid, uid, function(notif_data) {
|
|
|
|
|
RDB.zrem('uid:' + uid + ':notifications:unread', nid);
|
|
|
|
|
RDB.zadd('uid:' + uid + ':notifications:read', notif_data.datetime, nid);
|
|
|
|
|
if (callback) {
|
|
|
|
|
callback();
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
if (parseInt(uid, 10) > 0) {
|
|
|
|
|
Notifications.get(nid, uid, function(notif_data) {
|
|
|
|
|
RDB.zrem('uid:' + uid + ':notifications:unread', nid);
|
|
|
|
|
RDB.zadd('uid:' + uid + ':notifications:read', notif_data.datetime, nid);
|
|
|
|
|
if (callback) {
|
|
|
|
|
callback();
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Notifications.mark_read_multiple = function(nids, uid, callback) {
|
|
|
|
|
if (!Array.isArray(nids) && parseInt(nids, 10) > 0) {
|
|
|
|
|