-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathhashtag.js
64 lines (60 loc) · 1.73 KB
/
hashtag.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
var mongoose = require('mongoose');
var SqueekModel = require('./squeek');
var UserModel = require('./user');
var _ = require('lodash');
var HashtagSchema = mongoose.Schema({
tag : {type : String, required : true},
createdOn : {
type : Date,
required : true,
default : Date.now
},
squeeks : {type : Array, required : true}
});
HashtagSchema.methods.getTags = function(msg){
var tags = [];
var matches = msg.match(/#\w\w+/g);
return matches;
}
HashtagSchema.methods.getMessages = function(tag){
var tagData;
var userIds;
var squeekData;
tag = tag || this.local.tag;
return HashTag.findOne({tag : tag})
.exec()
.then(function(tagDocument){
tagData = tagDocument;
return SqueekModel.find({_id : {'$in' : tagDocument.squeeks}})
.sort({createdOn : -1})
.limit(100)
.exec()
})
.then(function(squeekDocuments){
squeekData = squeekDocuments;
userIds = _.pluck(squeekDocuments,'userId');
userIds = _.uniq(userIds, false, function(id){
return id.toString();
});
return UserModel.find({_id : {'$in' : userIds}}, 'username')
.exec();
})
.then(function(userDocuments){
var messages = squeekData.map(function(squeek){
var user = userDocuments.filter(function(u){
if(squeek.userId.equals(u._id)){
return true;
}
return false;
});
squeek.userInfo = user[0];
return squeek;
});
return {
squeeks : messages,
tag : tag
}
})
}
var HashTag = mongoose.model('HashTag', HashtagSchema, 'hashtags');
module.exports = HashTag;