module Redis::Config DEFAULT_SENTINEL_PORT ||= '26379'.freeze class << self def app config end def config @config ||= sentinel? ? sentinel_config : base_config end def base_config { url: ENV.fetch('REDIS_URL', 'redis://127.0.0.1:6379'), password: ENV.fetch('REDIS_PASSWORD', nil).presence, ssl_params: { verify_mode: Chatwoot.redis_ssl_verify_mode }, reconnect_attempts: 2, network_timeout: 5 } end def sentinel? ENV.fetch('REDIS_SENTINELS', nil).presence end def sentinel_config redis_sentinels = ENV.fetch('REDIS_SENTINELS', nil) # expected format for REDIS_SENTINELS url string is host1:port1, host2:port2 sentinels = redis_sentinels.split(',').map do |sentinel_url| host, port = sentinel_url.split(':').map(&:strip) { host: host, port: port.presence || DEFAULT_SENTINEL_PORT, password: base_config[:password] } end # over-write redis url as redis://:@/ when using sentinel # more at https://github.com/redis/redis-rb/issues/531#issuecomment-263501322 master = "redis://#{ENV.fetch('REDIS_SENTINEL_MASTER_NAME', 'mymaster')}" base_config.merge({ url: master, sentinels: sentinels }) end end end