帆js订阅由groupid属性限定范围的模型更改

Sails js subscribe to model changes scoped by groupid attribute

本文关键字：范围 模型 属性 js groupid      更新时间：2023-09-26

我有一个名为Groupfeed的模型，它看起来像这样

module.exports = {
  schema:true,
  attributes: 
  {
    groupid:
    {
        model:'groups',
        required:true
    },
    postid: 
    {
        model:'post',
        required:true
    },
    objectid: 
    {
        model:'objects',
        required:true
    },
  }
};

在客户端，我可以使用

订阅Groupfeed模型
io.socket.get('/groupfeed')

，由蓝图API自动完成然后

io.socket.on('groupfeed',function(obj){console.log(obj)})
当我在后端使用 发布时，

将为我提供模型更改的更新。

Groupfeed.publishCreate({id:4,groupid:6,postid:2,objectid:1})

我想要的:-

我希望客户端只订阅来自特定groupid的groupfeeds。例如:用户X可以从groupid 1订阅groupfeeds(注意:组模型存储组的用户成员资格)

或者类似这样的想象调用:

io.socket.get('/groupfeed?groupid=5')

因此，当我使用groupid:5调用publishCreate时，只有订阅groupid 5的groupfeed的人才能获得更新

你最好为不同的组创建不同的房间。

代码未测试!创建控制器:NotificationsController.js

module.exports = {
    subscribe: function(req, res) {
        // Get groupId of user by your method
        .....
        .....
        var roomName = 'group_' + groupId;
        sails.sockets.join(req.socket, roomName);
        res.json({
            room: roomName
        });
    }
}

你可以在某个地方创建通知:

var roomNameForGroup = 'group_' + groupId;
sails.sockets.blast(roomNameForGroup, {id:4,groupid:6,postid:2,objectid:1});

在你看来:

io.socket.on('connect', function(){
    io.socket.get('/notifications/subscribe', function(data, jwr){
        if (jwr.statusCode == 200){
            io.socket.on(data.room,function(obj){
                console.log(obj);
            });
        } else {
            console.log(jwr);
        }
    });
});

我现在不能测试代码，但它看起来是可行的。

相关文章：