#
# A helper module to look a capability up from PuppetDB
#
# @todo lutter 2015-03-10: determine whether this should be based on
# Puppet::Pops::Evaluator::Collectors, or at least use
# Puppet::Util::Puppetdb::Http

require 'net/http'
require 'cgi'
require 'json'

# @api private
module Puppet::Resource::CapabilityFinder

  # Looks the capability resource from PuppetDB.
  # @param environment [String] environment name
  # @param code_id [String,nil] code_id of the catalog
  # @param cap [Puppet::Type] the capability resource type instance
  # @return [Puppet::Resource,nil] The found capability resource or `nil` if it could not be found
  def self.find(environment, code_id, cap)
    unless Puppet::Util.const_defined?('Puppetdb')
      raise Puppet::DevError, 'PuppetDB is not available'
    end

    query_terms = [
      'and',
      ['=', 'type', cap.type.capitalize],
      ['=', 'title', cap.title.to_s],
      ['=', 'tag', "producer:#{environment}"]
    ]

    unless code_id.nil?
      query_terms << ['in', 'certname',
        ['extract', 'certname',
          ['select_catalogs',
            ['=', 'code_id', code_id]]]]
    end

    Puppet.notice "Capability lookup #{cap}]: #{query_terms}"

    data = query_puppetdb(query_terms)

    # The format of the response body is documented at
    #   http://docs.puppetlabs.com/puppetdb/3.0/api/query/v4/resources.html#response-format
    # In a nutshell, we expect to get an array of resources back. If the
    # array is empty, the lookup failed and we return +nil+, if it
    # contains exactly one, we turn that resource back into a Puppet
    # ::Resource. If the array contains more than one entry, we have a
    # bug in the overall system, as we allowed multiple capabilities with
    # the same type and title to be produced in this environment.
    unless data.is_a?(Array)
      raise Puppet::DevError,
      "Unexpected response from PuppetDB when looking up #{cap}: " +
        "expected an Array but got #{data.inspect}"
    end
    if data.size > 1
      raise Puppet::DevError,
      "Unexpected response from PuppetDB when looking up #{cap}:\n" +
        "expected exactly one resource but got #{data.size};\n" +
        "returned data is:\n#{data.inspect}"
    end

    unless data.empty?
      resource_hash = data.first
      resource = Puppet::Resource.new(resource_hash['type'],
                                      resource_hash['title'])
      real_type = Puppet::Type.type(resource.type)
      if real_type.nil?
        fail Puppet::ParseError,
          "Could not find resource type #{resource.type} returned from PuppetDB"
      end
      real_type.parameters.each do |param|
        param = param.to_s
        next if param == 'name'
        if value = resource_hash['parameters'][param]
          resource[param] = value
        else
          Puppet.debug "No capability value for #{resource}->#{param}"
        end
      end
      return resource
    end
  end

  def self.query_puppetdb(query)
    # If using PuppetDB >= 4, use the API method query_puppetdb()
    if Puppet::Util::Puppetdb.respond_to?(:query_puppetdb)
      # PuppetDB 4 uses a unified query endpoint, so we have to specify what we're querying
      Puppet::Util::Puppetdb.query_puppetdb(["from", "resources", query])
    # For PuppetDB < 4, use the old internal method action()
    else
      url = "/pdb/query/v4/resource?query=#{CGI.escape(query.to_json)}"
      response = Puppet::Util::Puppetdb::Http.action(url) do |conn, uri|
        conn.get(uri, { 'Accept' => 'application/json'})
      end
      JSON.parse(response.body)
    end
  rescue JSON::JSONError => e
    raise Puppet::DevError,
      "Invalid JSON from PuppetDB when looking up #{cap}\n#{e}"
  end
end