Sha256: 200211e0cefe21d931edb6c61a77101a989b8e3ff47be5dda0956eb976578658
Contents?: true
Size: 1.85 KB
Versions: 12
Compression:
Stored size: 1.85 KB
Contents
# frozen_string_literal: true
require "forwardable"
require "resolv"
module HTTPX
class Resolver::Multi
include Callbacks
using ArrayExtensions
attr_reader :resolvers
def initialize(resolver_type, options)
@options = options
@resolver_options = @options.resolver_options
@resolvers = options.ip_families.map do |ip_family|
resolver = resolver_type.new(ip_family, options)
resolver.on(:resolve, &method(:on_resolver_connection))
resolver.on(:error, &method(:on_resolver_error))
resolver.on(:close) { on_resolver_close(resolver) }
resolver
end
@errors = Hash.new { |hs, k| hs[k] = [] }
end
def closed?
@resolvers.all?(&:closed?)
end
def timeout
@resolvers.filter_map(&:timeout).min
end
def close
@resolvers.each(&:close)
end
def connections
@resolvers.filter_map { |r| r.resolver_connection if r.respond_to?(:resolver_connection) }
end
def early_resolve(connection)
hostname = connection.origin.host
addresses = @resolver_options[:cache] && (connection.addresses || HTTPX::Resolver.nolookup_resolve(hostname))
return unless addresses
addresses = addresses.group_by(&:family)
@resolvers.each do |resolver|
addrs = addresses[resolver.family]
next if !addrs || addrs.empty?
resolver.emit_addresses(connection, resolver.family, addrs)
end
end
private
def on_resolver_connection(connection)
emit(:resolve, connection)
end
def on_resolver_error(connection, error)
@errors[connection] << error
return unless @errors[connection].size >= @resolvers.size
errors = @errors.delete(connection)
emit(:error, connection, errors.first)
end
def on_resolver_close(resolver)
emit(:close, resolver)
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems