-
Notifications
You must be signed in to change notification settings - Fork 2.8k
/
bookmarks.js
84 lines (70 loc) · 2.05 KB
/
bookmarks.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
'use strict';
var async = require('async');
var db = require('../database');
var posts = require('../posts');
module.exports = function (Topics) {
Topics.getUserBookmark = function (tid, uid, callback) {
if (!parseInt(uid, 10)) {
return callback(null, null);
}
db.sortedSetScore('tid:' + tid + ':bookmarks', uid, callback);
};
Topics.getUserBookmarks = function (tids, uid, callback) {
if (!parseInt(uid, 10)) {
return callback(null, tids.map(function () {
return null;
}));
}
db.sortedSetsScore(tids.map(function (tid) {
return 'tid:' + tid + ':bookmarks';
}), uid, callback);
};
Topics.setUserBookmark = function (tid, uid, index, callback) {
db.sortedSetAdd('tid:' + tid + ':bookmarks', index, uid, callback);
};
Topics.getTopicBookmarks = function (tid, callback) {
db.getSortedSetRangeWithScores(['tid:' + tid + ':bookmarks'], 0, -1, callback);
};
Topics.updateTopicBookmarks = function (tid, pids, callback) {
var maxIndex;
async.waterfall([
function (next) {
Topics.getPostCount(tid, next);
},
function (postcount, next) {
maxIndex = postcount;
Topics.getTopicBookmarks(tid, next);
},
function (bookmarks, next) {
var forkedPosts = pids.map(function (pid) {
return { pid: pid, tid: tid };
});
var uidData = bookmarks.map(function (bookmark) {
return {
uid: bookmark.value,
bookmark: bookmark.score,
};
});
async.eachLimit(uidData, 50, function (data, next) {
posts.getPostIndices(forkedPosts, data.uid, function (err, postIndices) {
if (err) {
return next(err);
}
var bookmark = data.bookmark;
bookmark = bookmark < maxIndex ? bookmark : maxIndex;
for (var i = 0; i < postIndices.length && postIndices[i] < data.bookmark; i += 1) {
bookmark -= 1;
}
if (parseInt(bookmark, 10) !== parseInt(data.bookmark, 10)) {
Topics.setUserBookmark(tid, data.uid, bookmark, next);
} else {
next();
}
});
}, next);
},
], function (err) {
callback(err);
});
};
};