Вопросы работы над WebSocket SailsJS

Я получаю ответ в

io.socket.on('chats', function (e, v) {
    console.log(e)
});

при использовании блока кода ниже.

io.socket.get('/chats', function (e, s) {
    console.log(e);
});

Итак, основные настройки в порядке. Затем я попытался немного настроить. Я хотел передать номер id, чтобы получить сообщения из конкретного номера вместо того, чтобы получать ненужные сообщения. Но нет ответа на добавление нового элемента при использовании

io.socket.get('/chats/get?room=PJ1RcnwbBxsH3xZn', function (e, s) {
    console.log(e);
});

Однако это было в состоянии получить исходные данные должным образом, как используется return res.json(chats);в ChatsController.получить

От ChatControllers.js

module.exports = {

    get: function (req, res) {

        if(!req.session.authenticated){
            return res.json({error: true, message: 'You must be logged in to join chat.'})
        }

        if (!req.isSocket) {
            return res.json({error: true, message: 'Inappropriate request format'})
        }

        sails.log(req.param('room'));
        if(!req.param('room')){
            return res.json({error: true, message: 'Inappropriate room ID'})
        }

        Chats.find({room: req.param('room')}).populate('user').exec(function (err, chats) {

            if (err) {
                return res.serverError(err);
            }

            Chats.subscribe(req, _.pluck(chats, 'id'));

            return res.json(chats);

        });
    },
.....

Я добавил Chats.subscribe(req, _.pluck(chats, 'id'));подписаться.
Не могу понять, что я пропустил в getдействии. Я искал, но не получил хороший учебник. Поэтому, изучая документацию, я попробовал их. Можете ли вы совет, чтобы исправить эту проблему?

Спасибо

1 ответ

  1. Я нашел решение после дополнительных исследований. паруса.розетки.join () и sails.розетки.broadcast() была моей игрушкой.

    Однако спасибо.