class Redis::Cluster::Option

def add_common_node_option_if_needed(options, node_opts, key)
  return options if options[key].nil? && node_opts.first[key].nil?
  options[key] ||= node_opts.first[key]
end

def add_node(host, port)
  @node_opts << { host: host, port: port }
end

def build_node_options(addrs)
  raise InvalidClientOptionError, 'Redis option of `cluster` must be an Array' unless addrs.is_a?(Array)
  addrs.map { |addr| parse_node_addr(addr) }
end

def initialize(options)
  options = options.dup
  node_addrs = options.delete(:cluster)
  @node_opts = build_node_options(node_addrs)
  @replica = options.delete(:replica) == true
  @fixed_hostname = options.delete(:fixed_hostname)
  add_common_node_option_if_needed(options, @node_opts, :scheme)
  add_common_node_option_if_needed(options, @node_opts, :username)
  add_common_node_option_if_needed(options, @node_opts, :password)
  @options = options
end

def parse_node_addr(addr)
  case addr
  when String
    parse_node_url(addr)
  when Hash
    parse_node_option(addr)
  else
    raise InvalidClientOptionError, 'Redis option of `cluster` must includes String or Hash'
  end
end

def parse_node_option(addr)
  addr = addr.map { |k, v| [k.to_sym, v] }.to_h
  if addr.values_at(:host, :port).any?(&:nil?)
    raise InvalidClientOptionError, 'Redis option of `cluster` must includes `:host` and `:port` keys'
  end
  addr
end

def parse_node_url(addr)
  uri = URI(addr)
  raise InvalidClientOptionError, "Invalid uri scheme #{addr}" unless VALID_SCHEMES.include?(uri.scheme)
  db = uri.path.split('/')[1]&.to_i
  username = uri.user ? URI.decode_www_form_component(uri.user) : nil
  password = uri.password ? URI.decode_www_form_component(uri.password) : nil
  { scheme: uri.scheme, username: username, password: password, host: uri.host, port: uri.port, db: db }
    .reject { |_, v| v.nil? || v == '' }
rescue URI::InvalidURIError => err
  raise InvalidClientOptionError, err.message
end

def per_node_key
  @node_opts.map do |opt|
    node_key = NodeKey.build_from_host_port(opt[:host], opt[:port])
    options = @options.merge(opt)
    options = options.merge(host: @fixed_hostname) if @fixed_hostname && !@fixed_hostname.empty?
    [node_key, options]
  end.to_h
end

def update_node(addrs)
  @node_opts = build_node_options(addrs)
end

def use_replica?
  @replica
end