Class: Mongo::URI::OptionsMapper Private

# File 'lib/mongo/uri/options_mapper.rb', line 218

def apply_transform(key, value, type)
  if type
    send("convert_#{type}", key, value)
  else
    value
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 536

def convert_array(_name, value)
  value.split(',')
end

# File 'lib/mongo/uri/options_mapper.rb', line 564

def convert_auth_mech(_name, value)
  auth_mech = AUTH_MECH_MAP[value.upcase]
  (auth_mech || value).tap do |_mech|
    log_warn("#{value} is not a valid auth mechanism") unless auth_mech
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 604

def convert_auth_mech_props(_name, value)
  properties = hash_extractor('authMechanismProperties', value)
  if properties
    properties.each do |k, v|
      properties[k] = (v.downcase == 'true') if k.to_s.downcase == 'canonicalize_host_name' && v
    end
  end
  properties
end

# File 'lib/mongo/uri/options_mapper.rb', line 325

def convert_bool(name, value)
  case value
  when true, 'true', 'TRUE'
    true
  when false, 'false', 'FALSE'
    false
  else
    log_warn("invalid boolean option for #{name}: #{value}")
    nil
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 432

def convert_integer(name, value)
  if value.is_a?(String) && /\A\d+\z/ !~ value
    log_warn("#{value} is not a valid integer for #{name}")
    return nil
  end

  value.to_i
end

# File 'lib/mongo/uri/options_mapper.rb', line 396

def convert_inverse_bool(name, value)
  b = convert_bool(name, value)

  if b.nil?
    nil
  else
    !b
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 642

def convert_max_staleness(_name, value)
  int = if value.is_a?(String) && /\A-?\d+\z/ =~ value
          value.to_i
        elsif value.is_a?(Integer)
          value
        end

  if int.nil?
    log_warn("Invalid max staleness value: #{value}")
    return nil
  end

  int = nil if int == -1

  if int && ((int > 0 && int < 90) || int < 0)
    log_warn("max staleness should be either 0 or greater than 90: #{value}")
    int = nil
  end

  int
end

# File 'lib/mongo/uri/options_mapper.rb', line 469

def convert_ms(name, value)
  case value
  when String
    unless /\A-?\d+(\.\d+)?\z/.match?(value)
      log_warn("Invalid ms value for #{name}: #{value}")
      return nil
    end
    if value.to_s[0] == '-'
      log_warn("#{name} cannot be a negative number")
      return nil
    end
  when Integer, Float
    if value < 0
      log_warn("#{name} cannot be a negative number")
      return nil
    end
  else
    raise ArgumentError, "Can only convert Strings, Integers, or Floats to ms. Given: #{value.class}"
  end

  value.to_f / 1000
end

# File 'lib/mongo/uri/options_mapper.rb', line 688

def convert_read_mode(_name, value)
  READ_MODE_MAP[value.downcase] || value
end

# File 'lib/mongo/uri/options_mapper.rb', line 764

def convert_read_set(_name, value)
  hash_extractor('readPreferenceTags', value)
end

# File 'lib/mongo/uri/options_mapper.rb', line 733

def convert_read_tags(name, value)
  converted = convert_read_set(name, value)
  return unless converted

  [ converted ]
end

# File 'lib/mongo/uri/options_mapper.rb', line 362

def convert_repeated_bool(name, value)
  [ convert_bool(name, value) ]
end

# File 'lib/mongo/uri/options_mapper.rb', line 708

def convert_server_monitoring_mode(_name, value)
  mode = value.downcase
  if SERVER_MONITORING_MODES.include?(mode)
    mode.to_sym
  else
    log_warn("#{value} is not a valid server monitoring mode")
    nil
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 516

def convert_symbol(_name, value)
  value.to_sym
end

# File 'lib/mongo/uri/options_mapper.rb', line 778

def convert_w(_name, value)
  case value
  when 'majority'
    :majority
  when /\A[0-9]+\z/
    value.to_i
  else
    value
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 819

def convert_zlib_compression_level(_name, value)
  i = if value.is_a?(String) && /\A-?\d+\z/ =~ value
        value.to_i
      elsif value.is_a?(Integer)
        value
      end

  if i && i >= -1 && i <= 9
    i
  else
    log_warn("#{value} is not a valid zlibCompressionLevel")
    nil
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 858

def hash_extractor(name, value)
  h = {}
  value.split(',').each do |tag|
    k, v = tag.split(':')
    if v.nil?
      log_warn("Invalid hash value for #{name}: key `#{k}` does not have a value: #{value}")
      next
    end

    h[k.to_sym] = v
  end
  if h.empty?
    nil
  else
    h
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 237

def merge_uri_option(target, value, name)
  if target.key?(name)
    if REPEATABLE_OPTIONS.include?(name)
      target[name] += value
    else
      log_warn("Repeated option key: #{name}.")
    end
  else
    target.merge!(name => value)
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 545

def revert_array(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 578

def revert_auth_mech(value)
  found = AUTH_MECH_MAP.detect do |_k, v|
    v == value
  end
  raise ArgumentError, "Unknown auth mechanism #{value}" unless found

  found.first
end

# File 'lib/mongo/uri/options_mapper.rb', line 619

def revert_auth_mech_props(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 342

def revert_bool(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 446

def revert_integer(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 411

def revert_inverse_bool(value)
  value.nil? ? nil : !value
end

# File 'lib/mongo/uri/options_mapper.rb', line 669

def revert_max_staleness(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 497

def revert_ms(value)
  (value * 1000).round
end

# File 'lib/mongo/uri/options_mapper.rb', line 697

def revert_read_mode(value)
  value.to_s.gsub(/_(\w)/) { ::Regexp.last_match(1).upcase }
end

# File 'lib/mongo/uri/options_mapper.rb', line 745

def revert_read_tags(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 371

def revert_repeated_bool(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 525

def revert_symbol(value)
  value.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 794

def revert_w(value)
  case value
  when Symbol
    value.to_s
  else
    value
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 839

def revert_zlib_compression_level(value)
  value
end

# File 'lib/mongo/uri/options_mapper.rb', line 117

def ruby_to_smc(opts)
  rv = {}
  URI_OPTION_MAP.each do |uri_key, spec|
    if spec[:group]
      v = opts[spec[:group]]
      v &&= v[spec[:name]]
    else
      v = opts[spec[:name]]
    end
    next if v.nil?

    if type = spec[:type]
      v = send("revert_#{type}", v)
    end
    canonical_key = URI_OPTION_CANONICAL_NAMES[uri_key]
    raise ArgumentError, "Option #{uri_key} is not known" unless canonical_key

    rv[canonical_key] = v
  end
  # For options that default to true, remove the value if it is true.
  %w[retryReads retryWrites].each do |k|
    rv.delete(k) if rv[k]
  end
  # Remove auth source when it is $external for mechanisms that default
  # (or require) that auth source.
  rv.delete('authSource') if %w[MONGODB-AWS].include?(rv['authMechanism']) && rv['authSource'] == '$external'
  # ssl and tls are aliases, remove ssl ones
  rv.delete('ssl')
  # TODO: remove authSource if it is the same as the database,
  # requires this method to know the database specified in the client.
  rv
end

# File 'lib/mongo/uri/options_mapper.rb', line 155

def ruby_to_string(opts)
  rv = {}
  URI_OPTION_MAP.each do |uri_key, spec|
    if spec[:group]
      v = opts[spec[:group]]
      v &&= v[spec[:name]]
    else
      v = opts[spec[:name]]
    end
    next if v.nil?

    if type = spec[:type]
      v = send("stringify_#{type}", v)
    end
    canonical_key = URI_OPTION_CANONICAL_NAMES[uri_key]
    raise ArgumentError, "Option #{uri_key} is not known" unless canonical_key

    rv[canonical_key] = v
  end
  # For options that default to true, remove the value if it is true.
  %w[retryReads retryWrites].each do |k|
    rv.delete(k) if rv[k]
  end
  # Remove auth source when it is $external for mechanisms that default
  # (or require) that auth source.
  rv.delete('authSource') if %w[MONGODB-AWS].include?(rv['authMechanism']) && rv['authSource'] == '$external'
  # ssl and tls are aliases, remove ssl ones
  rv.delete('ssl')
  # TODO: remove authSource if it is the same as the database,
  # requires this method to know the database specified in the client.
  rv
end

# File 'lib/mongo/uri/options_mapper.rb', line 83

def smc_to_ruby(opts)
  uri_options = {}

  opts.each do |key, value|
    strategy = URI_OPTION_MAP[key.downcase]
    if strategy.nil?
      log_warn("Unsupported URI option '#{key}' on URI '#{@string}'. It will be ignored.")
      return
    end

    group = strategy[:group]
    target = if group
               uri_options[group] || {}
             else
               uri_options
             end

    value = apply_transform(key, value, strategy[:type])
    # Sometimes the value here would be nil, for example if we are processing
    # read preference tags or auth mechanism properties and all of the
    # data within is invalid. Ignore such options.
    merge_uri_option(target, value, strategy[:name]) unless value.nil?

    uri_options[group] = target if group && !target.empty? && !uri_options.key?(group)
  end

  uri_options
end

# File 'lib/mongo/uri/options_mapper.rb', line 554

def stringify_array(value)
  value.join(',')
end

# File 'lib/mongo/uri/options_mapper.rb', line 592

def stringify_auth_mech(value)
  revert_auth_mech(value)
rescue StandardError
  nil
end

# File 'lib/mongo/uri/options_mapper.rb', line 628

def stringify_auth_mech_props(value)
  return if value.nil?

  value.map { |k, v| "#{k}:#{v}" }.join(',')
end

# File 'lib/mongo/uri/options_mapper.rb', line 351

def stringify_bool(value)
  revert_bool(value)&.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 455

def stringify_integer(value)
  revert_integer(value)&.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 420

def stringify_inverse_bool(value)
  revert_inverse_bool(value)&.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 678

def stringify_max_staleness(value)
  revert_max_staleness(value)&.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 506

def stringify_ms(value)
  revert_ms(value).to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 700

alias stringify_read_mode revert_read_mode

# File 'lib/mongo/uri/options_mapper.rb', line 754

def stringify_read_tags(value)
  value&.map { |ar| ar.map { |k, v| "#{k}:#{v}" }.join(',') }
end

# File 'lib/mongo/uri/options_mapper.rb', line 380

def stringify_repeated_bool(value)
  rep = revert_repeated_bool(value)
  if rep&.is_a?(Array)
    rep.join(',')
  else
    rep
  end
end

# File 'lib/mongo/uri/options_mapper.rb', line 723

def stringify_server_monitoring_mode(value)
  value.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 528

alias stringify_symbol revert_symbol

# File 'lib/mongo/uri/options_mapper.rb', line 808

def stringify_w(value)
  revert_w(value)&.to_s
end

# File 'lib/mongo/uri/options_mapper.rb', line 848

def stringify_zlib_compression_level(value)
  revert_zlib_compression_level(value)&.to_s
end