forked from GetStream/stream-react-example
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathindex.js
More file actions
144 lines (140 loc) · 3.75 KB
/
Copy pathindex.js
File metadata and controls
144 lines (140 loc) · 3.75 KB
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
var async = require('async');
function referencesFromActivities(activitiesOrNotifications) {
/*
Returns the references from a list of activities
*/
var references = {};
activitiesOrNotifications.forEach(function(item) {
var activities = item.activities ? item.activities : [item];
activities.forEach(function(activity) {
Object.keys(activity).forEach(function(key) {
if (
activity[key] &&
activity[key].indexOf &&
activity[key].indexOf(':') != -1
) {
var parts = activity[key].split(':');
var reference = parts[0];
var referenceId = parts[1];
if (!(reference in references)) {
references[reference] = {};
}
references[reference][referenceId] = 1;
}
});
});
});
return references;
}
function loadReferencedObjects(references, userId, callback) {
// TODO: subqueries are inneficient. Handle do i like and do i follow
// in 2 separate queries
var queries = [];
if (references.upload) {
let sql = `
SELECT
uploads.id AS id,
users.id AS user_id,
users.first_name AS first_name,
users.last_name AS last_name,
MD5(users.email) AS email_md5,
uploads.id AS upload_id,
uploads.filename AS filename,
uploads.hashtags AS hashtags,
uploads.caption AS caption,
uploads.location AS location,
IF((SELECT 1 AS liked FROM likes WHERE user_id = ? AND upload_id = uploads.id), true, false) AS liked
FROM uploads
LEFT JOIN users ON (uploads.user_id = users.id)
WHERE uploads.id IN (?)
`;
queries.push({
name: 'upload',
sql: sql,
});
}
if (references.user) {
// do the same thing for users
let sql = `
SELECT
users.id AS id,
users.id AS user_id,
users.first_name AS first_name,
users.last_name AS last_name,
MD5(users.email) AS email_md5,
IF(
(
SELECT
1 AS following
FROM followers AS f
WHERE f.follower_id = users.id
AND f.user_id = ?
),
true,
false
) AS following
FROM users
WHERE users.id IN (?)
`;
queries.push({
name: 'user',
sql: sql,
});
}
var referencedObject = {};
// run all the queries
async.eachSeries(
queries,
function iteratee(query, cb) {
db.query(
query.sql,
[userId, Object.keys(references[query.name])],
function(err, results) {
if (err) {
cb(err);
}
referencedObject[query.name] = {};
results.forEach(function(result) {
referencedObject[query.name][result.id] = result;
});
cb();
},
);
},
function done() {
callback(referencedObject);
},
);
}
function enrichActivities(activitiesOrNotifications, refencedObjects) {
/*
* Enriches the activities by replacing references with the actual objects
*/
activitiesOrNotifications.forEach(function(item) {
var activities = item.activities ? item.activities : [item];
activities.forEach(function(activity) {
Object.keys(activity).forEach(function(key) {
if (
activity[key] &&
activity[key].indexOf &&
activity[key].indexOf(':') != -1
) {
var parts = activity[key].split(':');
var reference = parts[0];
var referenceId = parts[1];
if (
reference in refencedObjects &&
refencedObjects[reference][referenceId]
) {
activity[key] = refencedObjects[reference][referenceId];
}
}
});
});
});
}
module.exports = {
referencesFromActivities: referencesFromActivities,
loadReferencedObjects: loadReferencedObjects,
enrichActivities: enrichActivities,
};