Contents

require "async/dns"
require "async/dns/system"

class Matchd::Rule::Passthrough < Matchd::Rule
  # @param [Hash] options
  # @option options [Array<Array>|Array<Hash>|Async::DNS::Resolver] "resolver" List of passthrough DNS servers. See `Matchd::Glue::AsyncEndpoint` for more formats.
  def initialize(options)
    super
    opts = options.fetch("passthrough")

    if opts.is_a?(Hash) && opts.key?("resolver")
      @resolver = opts["resolver"]
      @passthrough_options = Matchd::Helpers.extract_options(%w(force name), opts)
    else
      @resolver = opts
      @passthrough_options = {}
    end
  end

  attr_reader :resolver, :passthrough_options

  def visit!(server, _name, _resource_class, transaction)
    transaction.passthrough!(passthrough_resolver, passthrough_options) do |response|
      server.logger.debug ";; Passthrough to upstream resolver"
      server.logger.debug ";; Question"
      server.logger.debug(*response.question.map { |q, r| "#{q}\t#{r}" })
      server.logger.debug ";; Answer"
      if response.answer.any?
        response.answer.each do |name_in_answer, ttl, record|
          server.logger.debug "#{name_in_answer}\t#{ttl}\t#{record.class}\t#{record.address if record.respond_to?(:address)}"
        end
      else
        server.logger.debug ";; Empty"
      end
    end
  end

  # @private
  # Lazy convert the {resolver} into somethinge we can pass to {Async::DNS::Transaction#passthrough!}
  def passthrough_resolver
    case resolver
    when Async::DNS::Resolver
      resolver
    when "system", :system, nil
      Async::DNS::Resolver.new(Async::DNS::System.nameservers)
    else
      Async::DNS::Resolver.new(Matchd::Glue::AsyncEndpoint.parse(resolver))
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
matchd-0.1.0	lib/matchd/rule/passthrough.rb