redis-client.ts

import { createClient } from 'redis';

class RedisClient {
  private static redisClient: ReturnType<typeof createClient>;

  private static initRedisClient() {
    const redisClient = createClient({
      url: process.env.REDIS_URL,
      password: process.env.REDIS_PASSWORD,
      socket: {
        tls: !process.env.REDIS_URL?.includes?.('localhost'),
        connectTimeout: 3000,
        reconnectStrategy: () => 360000,
      },
    });

    redisClient.on('connect', () => console.log('Redis client is connected...'));
    redisClient.on('ready', () => console.log('Redis client is ready...'));
    redisClient.on('error', (err) => console.log('Redis client error occured', err));
    redisClient.on('end', () => console.log('Redis client is disconnected'));
    process.on('SIGINT', () => redisClient.quit());
    redisClient.connect();
    return redisClient;
  }

  public static getRedisClient(): ReturnType<typeof createClient> {
    if (!RedisClient.redisClient) {
      RedisClient.redisClient = RedisClient.initRedisClient();
    }
    return RedisClient.redisClient;
  }
}

export default RedisClient;