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
|
//
// UserMessages Controller
//
'use strict';
var _ = require('lodash'),
settings = require('./../config');
module.exports = function() {
var app = this.app,
core = this.core,
middlewares = this.middlewares;
if (!settings.private.enable) {
return;
}
core.on('user-messages:new', function(message) {
_.each(message.users, function(userId) {
var connections = core.presence.system.connections.query({
type: 'socket.io', userId: userId.toString()
});
_.each(connections, function(connection) {
connection.socket.emit('user-messages:new', message);
});
});
});
//
// Routes
//
app.route('/users/:user/messages')
.all(middlewares.requireLogin)
.get(function(req) {
req.io.route('user-messages:list');
})
.post(function(req) {
req.io.route('user-messages:create');
});
//
// Sockets
//
app.io.route('user-messages', {
create: function(req, res) {
var options = {
owner: req.user._id,
user: req.param('user'),
text: req.param('text')
};
core.usermessages.create(options, function(err, message) {
if (err) {
return res.sendStatus(400);
}
res.status(201).json(message);
});
},
list: function(req, res) {
var options = {
currentUser: req.user._id,
user: req.param('user'),
since_id: req.param('since_id'),
from: req.param('from'),
to: req.param('to'),
reverse: req.param('reverse'),
skip: req.param('skip'),
take: req.param('take'),
expand: req.param('expand')
};
core.usermessages.list(options, function(err, messages) {
if (err) {
return res.sendStatus(400);
}
res.json(messages);
});
}
});
};
|
