zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(redis): avoid info command for sub/pub redis

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2026-02-05 21:24:10 +00:00
parent ef8c2a4eee
commit 2d0478d626
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
packages/redis/redis.ts
View File

@@ -20,6 +20,7 @@ export interface ExtendedRedis extends Redis {
} }
const createRedisClient = ( const createRedisClient = (
name: string,
url: string, url: string,
overrides: RedisOptions = {}, overrides: RedisOptions = {},
): ExtendedRedis => { ): ExtendedRedis => {
@@ -29,7 +30,7 @@ const createRedisClient = (
}) as ExtendedRedis; }) as ExtendedRedis;
client.on('error', (error) => { client.on('error', (error) => {
console.error('Redis Client Error:', error); console.error(`[${name}] Redis Client Error:`, error);
}); });
client.getJson = async <T = any>(key: string): Promise<T | null> => { client.getJson = async <T = any>(key: string): Promise<T | null> => {
@@ -65,7 +66,7 @@ const createRedisClient = (
let redisCache: ExtendedRedis; let redisCache: ExtendedRedis;
export function getRedisCache() { export function getRedisCache() {
if (!redisCache) { if (!redisCache) {
redisCache = createRedisClient(REDIS_URL, options); redisCache = createRedisClient('redis-cache', REDIS_URL, options);
} }
return redisCache; return redisCache;
@@ -74,7 +75,12 @@ export function getRedisCache() {
let redisSub: ExtendedRedis; let redisSub: ExtendedRedis;
export function getRedisSub() { export function getRedisSub() {
if (!redisSub) { if (!redisSub) {
redisSub = createRedisClient(REDIS_URL, options); redisSub = createRedisClient('redis-sub', REDIS_URL, {
...options,
// Disable ready check for subscription client since it uses INFO command
// which is not allowed once the client enters subscription mode
enableReadyCheck: false,
});
} }
return redisSub; return redisSub;
@@ -83,7 +89,7 @@ export function getRedisSub() {
let redisPub: ExtendedRedis; let redisPub: ExtendedRedis;
export function getRedisPub() { export function getRedisPub() {
if (!redisPub) { if (!redisPub) {
redisPub = createRedisClient(REDIS_URL, options); redisPub = createRedisClient('redis-pub', REDIS_URL, options);
} }
return redisPub; return redisPub;
@@ -93,7 +99,7 @@ let redisQueue: ExtendedRedis;
export function getRedisQueue() { export function getRedisQueue() {
if (!redisQueue) { if (!redisQueue) {
// Use different redis for queues (self-hosting will re-use the same redis instance) // Use different redis for queues (self-hosting will re-use the same redis instance)
redisQueue = createRedisClient(REDIS_URL, { redisQueue = createRedisClient('redis-queue', REDIS_URL, {
...options, ...options,
enableReadyCheck: false, enableReadyCheck: false,
maxRetriesPerRequest: null, maxRetriesPerRequest: null,
@@ -108,7 +114,7 @@ let redisGroupQueue: ExtendedRedis;
export function getRedisGroupQueue() { export function getRedisGroupQueue() {
if (!redisGroupQueue) { if (!redisGroupQueue) {
// Dedicated Redis connection for GroupWorker to avoid blocking BullMQ // Dedicated Redis connection for GroupWorker to avoid blocking BullMQ
redisGroupQueue = createRedisClient(REDIS_URL, { redisGroupQueue = createRedisClient('redis-group-queue', REDIS_URL, {
...options, ...options,
enableReadyCheck: false, enableReadyCheck: false,
maxRetriesPerRequest: null, maxRetriesPerRequest: null,