|
|
|
@ -104,13 +104,11 @@ redisModule.info = async function (cxn) {
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
redisModule.socketAdapter = async function () {
|
|
|
|
|
const redisAdapter = require('socket.io-redis');
|
|
|
|
|
const redisAdapter = require('@socket.io/redis-adapter');
|
|
|
|
|
const pub = await connection.connect(nconf.get('redis'));
|
|
|
|
|
const sub = await connection.connect(nconf.get('redis'));
|
|
|
|
|
return redisAdapter({
|
|
|
|
|
return redisAdapter(pub, sub, {
|
|
|
|
|
key: `db:${nconf.get('redis:database')}:adapter_key`,
|
|
|
|
|
pubClient: pub,
|
|
|
|
|
subClient: sub,
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|