Contents

# frozen_string_literal: true

require "resolv"
require "ipaddr"

module HTTPX
  module Resolver
    module ResolverMixin
      include Callbacks
      include Loggable

      CHECK_IF_IP = lambda do |name|
        begin
          IPAddr.new(name)
          true
        rescue ArgumentError
          false
        end
      end

      def uncache(connection)
        hostname = hostname || @queries.key(connection) || connection.origin.host
        Resolver.uncache(hostname)
        @_record_types[hostname].shift
      end

      private

      def emit_addresses(connection, addresses)
        addresses.map! do |address|
          address.is_a?(IPAddr) ? address : IPAddr.new(address.to_s)
        end
        log { "resolver: answer #{connection.origin.host}: #{addresses.inspect}" }
        connection.addresses = addresses
        emit(:resolve, connection)
      end

      def early_resolve(connection, hostname: connection.origin.host)
        addresses = connection.addresses ||
                    ip_resolve(hostname) ||
                    (@resolver_options[:cache] && Resolver.cached_lookup(hostname)) ||
                    system_resolve(hostname)
        return unless addresses

        emit_addresses(connection, addresses)
      end

      def ip_resolve(hostname)
        [hostname] if CHECK_IF_IP[hostname]
      end

      def system_resolve(hostname)
        @system_resolver ||= Resolv::Hosts.new
        ips = @system_resolver.getaddresses(hostname)
        return if ips.empty?

        ips.map { |ip| IPAddr.new(ip) }
      rescue IOError
      end

      def emit_resolve_error(connection, hostname = connection.origin.host, ex = nil)
        emit(:error, connection, resolve_error(hostname, ex))
      end

      def resolve_error(hostname, ex = nil)
        return ex if ex.is_a?(ResolveError)

        message = ex ? ex.message : "Can't resolve #{hostname}"
        error = ResolveError.new(message)
        error.set_backtrace(ex ? ex.backtrace : caller)
        error
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
httpx-0.18.7	lib/httpx/resolver/resolver_mixin.rb