ad2games/soapy_cake

# frozen_string_literal: true

module SoapyCake
  class Request
    DATE_CLASSES = [Date, Time, DateTime, ActiveSupport::TimeWithZone].freeze

    attr_accessor :api_key, :time_converter
    attr_reader :role, :service, :method, :opts

    def initialize(role, service, method, opts = {})
      @role = role.to_s
      @service = service.to_s
      @method = method.to_s
      @opts = opts
    end

    def path
      "#{api_path}/#{service}.asmx"
    end

    def xml
      Nokogiri::XML::Builder.new do |xml|
        xml['env'].Envelope(xml_namespaces) do
          xml['env'].Header
          xml['env'].Body do
            xml['cake'].public_send(method.camelize.to_sym) do
              xml['cake'].api_key(api_key)
              xml_params(xml, opts)
            end
          end
        end
      end.to_xml
    end

    def short_response?
      %w[addedit track signup].include?(service)
    end

    def to_s
      "#{role}:#{service}:#{method}:#{version} #{opts.to_json}"
    end

    def read_only?
      (API_CONFIG.dig('read_only', role, service) || []).include?(method)
    end

    private

    def api_path
      "#{role == 'admin' ? '' : "/#{role.pluralize}"}/api/#{version}"
    end

    def xml_params(xml, opts)
      opts.each do |key, value|
        if value.is_a?(Array)
          xml['cake'].public_send(key) { value.each { |v| xml_params(xml, v) } }
        elsif value.is_a?(Hash)
          xml['cake'].public_send(key) { xml_params(xml, value) }
        else
          xml['cake'].public_send(key, format_param(key, value))
        end
      end
    end

    def xml_namespaces
      {
        'xmlns:env' => 'http://www.w3.org/2003/05/soap-envelope',
        'xmlns:cake' => "http://cakemarketing.com#{api_path}/"
      }
    end

    def format_param(key, value)
      return time_converter.to_cake(value) if DATE_CLASSES.include?(value.class)

      if key.to_s.end_with?('_date')
        raise Error, "You need to use a Time/DateTime/Date object for '#{key}'"
      end

      value
    end

    def version
      API_CONFIG.dig('versions', role, service, method) ||
        raise(Error, "Unknown API call #{role}::#{service}::#{method}")
    end
  end
end