diff --git a/lib/game/socket/server.js b/lib/game/socket/server.js index e12b995..42416fd 100644 --- a/lib/game/socket/server.js +++ b/lib/game/socket/server.js @@ -95,6 +95,9 @@ module.exports = function installSocketServer(server, PROTOCOL) { conn.on('data', function (message) { if (m = message.match(/^subscribe (.*)$/)) { + if(user && m[1].startsWith(`user:`) && !m[1].startsWith(`user:${user._id.toString()}`)) { + return; + } socketModules.forEach(socketMod => { try { if (socketMod.onSubscribe(m[1], user, conn)) {