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
|
//
// Messages Controller
//
'use strict';
module.exports = function() {
var app = this.app,
core = this.core,
middlewares = this.middlewares;
core.on('messages:new', function(message, room, user) {
var msg = message.toJSON();
msg.owner = user;
msg.room = room.toJSON(user);
app.io.to(room.id)
.emit('messages:new', msg);
});
//
// Routes
//
app.route('/messages')
.all(middlewares.requireLogin)
.get(function(req) {
req.io.route('messages:list');
})
.post(function(req) {
req.io.route('messages:create');
});
app.route('/rooms/:room/messages')
.all(middlewares.requireLogin, middlewares.roomRoute)
.get(function(req) {
req.io.route('messages:list');
})
.post(function(req) {
req.io.route('messages:create');
});
//
// Sockets
//
app.io.route('messages', {
create: function(req, res) {
var options = {
owner: req.user._id,
room: req.param('room'),
text: req.param('text')
};
core.messages.create(options, function(err, message) {
if (err) {
return res.sendStatus(400);
}
res.status(201).json(message);
});
},
list: function(req, res) {
var options = {
userId: req.user._id,
password: req.param('password'),
room: req.param('room'),
since_id: req.param('since_id'),
from: req.param('from'),
to: req.param('to'),
query: req.param('query'),
reverse: req.param('reverse'),
skip: parseInt(req.param('skip')),
take: parseInt(req.param('take')),
expand: req.param('expand')
};
core.messages.list(options, function(err, messages) {
if (err) {
return res.sendStatus(400);
}
messages = messages.map(function(message) {
return message.toJSON(req.user);
});
res.json(messages);
});
}
});
};
|
