Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: remove unused code

Browse Source
This commit is contained in:
Baris Usakli
2021-10-08 15:16:17 -04:00
parent 4b92df821b
commit 997fb2b348
2 changed files with 0 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/socket.io/index.js
View File

@@ -26,10 +26,6 @@ Sockets.init = async function (server) {
});
if (nconf.get('isCluster')) {
// socket.io-adapter-cluster needs update
// if (nconf.get('singleHostCluster')) {
// io.adapter(require('./single-host-cluster'));
// } else if (nconf.get('redis')) {
if (nconf.get('redis')) {
const adapter = await require('../database/redis').socketAdapter();
io.adapter(adapter);

65
src/socket.io/single-host-cluster.js
View File

@@ -1,65 +0,0 @@
'use strict';
const Client = {
sendMessage: function (channel, message) {
process.send({
action: 'socket.io',
channel: channel,
message: message,
});
},
trigger: function (channel, message) {
Client.message.concat(Client.pmessage).forEach((callback) => {
setImmediate(() => {
callback.call(Client, channel, message);
});
});
},
publish: function (channel, message) {
Client.sendMessage(channel, message);
},
// we don't actually care about which channels we're subscribed to
subscribe: function () {},
psubscribe: function () {},
unsubscribe: function () {},
unpsubscribe: function () {},
message: [],
pmessage: [],
on: function (event, callback) {
if (event !== 'message' && event !== 'pmessage') {
return;
}
Client[event].push(callback);
},
off: function (event, callback) {
if (event !== 'message' && event !== 'pmessage') {
return;
}
if (callback) {
Client[event] = Client[event].filter(c => c !== callback);
} else {
Client[event] = [];
}
},
};
process.on('message', (message) => {
if (message && typeof message === 'object' && message.action === 'socket.io') {
Client.trigger(message.channel, message.message);
}
});
const adapter = require('socket.io-adapter-cluster')({
client: Client,
});
// Otherwise, every node thinks it is the master node and ignores messages
// because they are from "itself".
Object.defineProperty(adapter.prototype, 'id', {
get: function () {
return process.pid;
},
set: function () {
// ignore
},
});
module.exports = adapter;