Class: Mongo::URI::OptionsMapper Private

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

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 546

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

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

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 614

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

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

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 442

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 406

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 653

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

  if int == -1
    int = nil
  end

  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 479

def convert_ms(name, value)
  case value
  when String
    if /\A-?\d+(\.\d+)?\z/ !~ 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 701

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

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

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

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

def convert_read_tags(name, value)
  converted = convert_read_set(name, value)
  if converted
    [converted]
  else
    nil
  end
end

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

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

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

def convert_symbol(name, value)
  value.to_sym
end

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

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 809

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 848

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 234

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 555

def revert_array(value)
  value
end

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

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

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

def revert_auth_mech_props(value)
  value
end

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

def revert_bool(value)
  value
end

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

def revert_integer(value)
  value
end

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

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

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

def revert_max_staleness(value)
  value
end

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

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

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

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

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

def revert_read_tags(value)
  value
end

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

def revert_repeated_bool(value)
  value
end

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

def revert_symbol(value)
  value.to_s
end

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

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

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

def revert_zlib_compression_level(value)
  value
end

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

def ruby_to_smc(opts)
  rv = {}
  URI_OPTION_MAP.each do |uri_key, spec|
    if spec[:group]
      v = opts[spec[:group]]
      v = v && v[spec[:name]]
    else
      v = opts[spec[:name]]
    end
    unless v.nil?
      if type = spec[:type]
        v = send("revert_#{type}", v)
      end
      canonical_key = URI_OPTION_CANONICAL_NAMES[uri_key]
      unless canonical_key
        raise ArgumentError, "Option #{uri_key} is not known"
      end
      rv[canonical_key] = v
    end
  end
  # For options that default to true, remove the value if it is true.
  %w(retryReads retryWrites).each do |k|
    if rv[k]
      rv.delete(k)
    end
  end
  # Remove auth source when it is $external for mechanisms that default
  # (or require) that auth source.
  if %w(MONGODB-AWS).include?(rv['authMechanism']) && rv['authSource'] == '$external'
    rv.delete('authSource')
  end
  # 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 169

def ruby_to_string(opts)
  rv = {}
  URI_OPTION_MAP.each do |uri_key, spec|
    if spec[:group]
      v = opts[spec[:group]]
      v = v && v[spec[:name]]
    else
      v = opts[spec[:name]]
    end
    unless v.nil?
      if type = spec[:type]
        v = send("stringify_#{type}", v)
      end
      canonical_key = URI_OPTION_CANONICAL_NAMES[uri_key]
      unless canonical_key
        raise ArgumentError, "Option #{uri_key} is not known"
      end
      rv[canonical_key] = v
    end
  end
  # For options that default to true, remove the value if it is true.
  %w(retryReads retryWrites).each do |k|
    if rv[k]
      rv.delete(k)
    end
  end
  # Remove auth source when it is $external for mechanisms that default
  # (or require) that auth source.
  if %w(MONGODB-AWS).include?(rv['authMechanism']) && rv['authSource'] == '$external'
    rv.delete('authSource')
  end
  # 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 88

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.
    unless value.nil?
      merge_uri_option(target, value, strategy[:name])
    end

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

  uri_options
end

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

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

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

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

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

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 361

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

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

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

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

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

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

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

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

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

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

alias :stringify_read_mode :revert_read_mode

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

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

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

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 538

alias :stringify_symbol :revert_symbol

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

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

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

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