refactor: remove unused code

isekai-main
Baris Usakli 3 years ago
parent 4b92df821b
commit 997fb2b348

@ -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);

@ -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;
Loading…
Cancel
Save