refactor: parallel socket.io adapter

This commit is contained in:
Barış Soner Uşaklı
2025-06-18 16:59:57 -04:00
parent 48621f5c6b
commit 0b9bfc1ce1

View File

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