require "httpi/adapter/base"
require "httpi/response"

module HTTPI
  module Adapter

    # An HTTPI adapter for `EventMachine::HttpRequest`. Due to limitations of
    # the em-httprequest library, not all features are supported. In particular,
    #
    # * CA files,
    # * certificate verification modes other than "none" and "peer,"
    # * NTLM authentication,
    # * digest authentication, and
    # * password-protected certificate keys
    #
    # are supported by HTTPI but not em-httprequest.
    #
    # In addition, some features of em-httprequest are not represented in HTTPI
    # and are therefore not supported. In particular,
    #
    # * SOCKS5 proxying,
    # * automatic redirect following,
    # * response streaming,
    # * file body streaming,
    # * keepalive,
    # * pipelining, and
    # * multi-request
    #
    # are supported by em-httprequest but not HTTPI.
    class EmHttpRequest < Base

      register :em_http, :deps => %w(em-synchrony em-synchrony/em-http em-http)

      def initialize(request)
        @request = request
        @client = EventMachine::HttpRequest.new build_request_url(request.url), connection_options
      end

      attr_reader :client

      def cert_directory
        @cert_directory ||= "/tmp"
      end

      attr_writer :cert_directory

      # Executes arbitrary HTTP requests.
      # @see HTTPI.request
      def request(method)
        _request { |options| @client.send method, options }
      end

      private

      def _request
        options = client_options
        setup_http_auth(options) if @request.auth.http?

        if @request.auth.ssl?
          raise NotSupportedError, "EM-HTTP-Request does not support SSL client auth"
        end

        if @request.on_body
          raise NotSupportedError, "EM-HTTP-Request does not support response streaming"
        end

        start_time = Time.now
        respond_with yield(options), start_time
      end

      def connection_options
        options = {
          :connect_timeout    => @request.open_timeout,
          :inactivity_timeout => @request.read_timeout
        }

        options[:proxy] = proxy_options if @request.proxy

        options
      end

      def client_options
        {
          :query => @request.url.query,
          :head  => @request.headers.to_hash,
          :body  => @request.body
        }
      end

      def proxy_options
        {
          :host          => @request.proxy.host,
          :port          => @request.proxy.port,
          :authorization => [@request.proxy.user, @request.proxy.password]
        }
      end

      def setup_http_auth(options)
        unless @request.auth.type == :basic
          raise NotSupportedError, "EM-HTTP-Request does only support HTTP basic auth"
        end

        options[:head] ||= {}
        options[:head][:authorization] = @request.auth.credentials
      end

      def respond_with(http, start_time)
        raise TimeoutError, "EM-HTTP-Request connection timed out: #{Time.now - start_time} sec" if http.response_header.status.zero?

        Response.new http.response_header.status,
          convert_headers(http.response_header), http.response
      end

      def build_request_url(url)
        "%s://%s:%s%s" % [url.scheme, url.host, url.port, url.path]
      end

      # Takes any header names with an underscore as a word separator and
      # converts the name to camel case, where words are separated by a dash.
      #
      # E.g. CONTENT_TYPE becomes Content-Type.
      def convert_headers(headers)
        return headers unless headers.keys.any? { |k| k =~ /_/ }

        result = {}

        headers.each do |k, v|
          words = k.split("_")
          key = words.map { |w| w.downcase.capitalize }.join("-")
          result[key] = v
        end

        result
      end
    end

  end
end