# frozen_string_literal: true

require 'jeff'
require 'vacuum/response'

module Vacuum
  # An Amazon Product Advertising API request.
  class Request
    include Jeff

    BadLocale = Class.new(ArgumentError)

    LATEST_VERSION = '2013-08-01'

    HOSTS = {
      'AU' => 'webservices.amazon.com.au',
      'BR' => 'webservices.amazon.com.br',
      'CA' => 'webservices.amazon.ca',
      'CN' => 'webservices.amazon.cn',
      'DE' => 'webservices.amazon.de',
      'ES' => 'webservices.amazon.es',
      'FR' => 'webservices.amazon.fr',
      'GB' => 'webservices.amazon.co.uk',
      'IN' => 'webservices.amazon.in',
      'IT' => 'webservices.amazon.it',
      'JP' => 'webservices.amazon.co.jp',
      'MX' => 'webservices.amazon.com.mx',
      'TR' => 'webservices.amazon.com.tr',
      'US' => 'webservices.amazon.com'
    }.freeze

    OPERATIONS = %w[
      BrowseNodeLookup
      CartAdd
      CartClear
      CartCreate
      CartGet
      CartModify
      ItemLookup
      ItemSearch
      SimilarityLookup
    ].freeze
    private_constant :OPERATIONS

    params 'AssociateTag' => -> { associate_tag },
           'Service' => 'AWSECommerceService',
           'SubscriptionId' => -> { subscription_id },
           'Version' => -> { version }

    attr_accessor :associate_tag, :subscription_id
    attr_writer :version

    # Create a new request for given locale.
    #
    # locale - The String Product Advertising API locale (default: US).
    # secure - Whether to use the secure version of the endpoint (default:
    #          false)
    #
    # Raises a Bad Locale error if locale is not valid.
    def initialize(locale = 'US', secure = false)
      locale = 'GB' if locale == 'UK'
      host = HOSTS.fetch(locale) { raise BadLocale }
      @aws_endpoint = "#{secure ? 'https' : 'http'}://#{host}/onca/xml"
    end

    # Configure the Amazon Product Advertising API request.
    #
    # credentials - The Hash credentials of the API endpoint.
    #               :aws_access_key_id     - The String Amazon Web Services
    #                                        (AWS) key.
    #               :aws_secret_access_key - The String AWS secret.
    #               :associate_tag         - The String Associate Tag.
    #               :aws_version           - The String AWS version.
    #
    # Returns self.
    def configure(credentials)
      credentials.each { |key, val| send("#{key}=", val) }
      self
    end

    # Returns the API version.
    def version
      @version || LATEST_VERSION
    end

    # Execute an API operation. See `OPERATIONS` constant above for available
    # operation names.
    #
    # params - The Hash request parameters.
    # opts   - Options passed to Excon (default: {}).
    #
    # Alternatively, pass Excon options as first argument and include request
    # parameters as query key.
    #
    # Examples
    #
    #   req.item_search(
    #     'SearchIndex' => 'All',
    #     'Keywords' => 'Architecture'
    #   )
    #
    #   req.item_search(
    #     query: {
    #       'SearchIndex' => 'All',
    #       'Keywords' => 'Architecture'
    #     },
    #     persistent: true
    #   )
    #
    # Returns a Vacuum Response.
    OPERATIONS.each do |operation|
      method_name = operation.gsub(/(.)([A-Z])/, '\1_\2').downcase
      define_method(method_name) do |params, opts = {}|
        params.key?(:query) ? opts = params : opts.update(query: params)
        opts[:expects] ||= [200, 400, 403]
        opts[:query].update('Operation' => operation)

        Response.new(get(opts))
      end
    end
  end
end