redis_url = ENV["REDIS_URL"].present? ?  ENV["REDIS_URL"] : defined?(Rails.application.secrets.redis) ? Rails.application.secrets.redis : 'redis://localhost:6379/1'
resque_url = ENV["RESQUE_URL"].present? ?  ENV["RESQUE_URL"] : defined?(Rails.application.secrets.resque) ? Rails.application.secrets.resque : 'redis://localhost:6379/1'
flash_url = ENV["FLASH_URL"].present? ?  ENV["FLASH_URL"] : defined?(Rails.application.secrets.flash) ? Rails.application.secrets.flash : nil
browser_urls = {}
class RedisFlash
  def self.current
    @current ||= Redis.new()
  end
  def self.current=(redis)
    @current = redis
  end
end

class Redis
  def self.current
    @current ||= Redis.new()
  end
  def self.current=(redis)
    @current = redis
  end

  def self.subscriber
    @subscriber ||= Redis.new
  end

  def self.subscriber=(redis)
    @subscriber = redis
  end

  def self.publisher
    @publisher ||= Redis.new
  end

  def self.publisher=(redis)
    @publisher = redis
  end
end

if defined?(Redis.current)
  Redis.current = Redis.new(:id => "#{ZuoraObservability::Env.full_process_name(process_name: 'Redis')}", :url => redis_url, :timeout => 6, :reconnect_attempts => 2)
  Redis.subscriber = Redis.new(:id => "#{ZuoraObservability::Env.full_process_name(process_name: 'RedisSubscriber')}", :url => redis_url, :timeout => 6, :reconnect_attempts => 2)
  Redis.publisher = Redis.new(:id => "#{ZuoraObservability::Env.full_process_name(process_name: 'RedisPublisher')}", :url => redis_url, :timeout => 6, :reconnect_attempts => 2)

  browser_urls['Redis'] = { "url" => redis_url }
  if defined?(Resque.redis)
    if resque_url != redis_url
      Resque.redis = Redis.new(:id => "#{ZuoraObservability::Env.full_process_name(process_name: 'Resque')}", :url => resque_url, :timeout => 6, :reconnect_attempts => 2)
      browser_urls['Resque'] = { "url" => resque_url }
    else
      Resque.redis = Redis.current
    end
  end
  if defined?(flash_url.present?)
    RedisFlash.current = Redis.new(:id => "#{ZuoraObservability::Env.full_process_name(process_name: 'Flash')}", :url => flash_url, :timeout => 6, :reconnect_attempts => 2)
    browser_urls['Flash'] = { "url" => flash_url }
  end
end
if defined?(RedisBrowser)
  RedisBrowser.configure("connections" => browser_urls)
end